(flink) branch master updated: [hotfix][docs] add missing output method in Context interface

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guoweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new cf0ba268e13 [hotfix][docs] add missing output method in Context interface
cf0ba268e13 is described below

commit cf0ba268e13b20ac1423c326ae780d0f131abd03
Author: Luke Chen <sh...@gmail.com>
AuthorDate: Fri Jun 21 14:58:58 2024 +0800

    [hotfix][docs] add missing output method in Context interface
---
 docs/content.zh/docs/dev/datastream/operators/windows.md | 8 ++++++++
 docs/content.zh/docs/learn-flink/streaming_analytics.md  | 4 +++-
 docs/content/docs/dev/datastream/operators/windows.md    | 8 ++++++++
 docs/content/docs/learn-flink/streaming_analytics.md     | 2 ++
 4 files changed, 21 insertions(+), 1 deletion(-)

diff --git a/docs/content.zh/docs/dev/datastream/operators/windows.md b/docs/content.zh/docs/dev/datastream/operators/windows.md
index de284b6326b..714033b94ce 100644
--- a/docs/content.zh/docs/dev/datastream/operators/windows.md
+++ b/docs/content.zh/docs/dev/datastream/operators/windows.md
@@ -753,6 +753,14 @@ public abstract class ProcessWindowFunction<IN, OUT, KEY, W extends Window> impl
          * State accessor for per-key global state.
          */
         public abstract KeyedStateStore globalState();
+
+        /**
+         * Emits a record to the side output identified by the {@code OutputTag}.
+         *
+         * @param outputTag the {@code OutputTag} that identifies the side output to emit to.
+         * @param value The record to emit.
+         */
+        public abstract <X> void output(OutputTag<X> outputTag, X value);
     }
 
 }
diff --git a/docs/content.zh/docs/learn-flink/streaming_analytics.md b/docs/content.zh/docs/learn-flink/streaming_analytics.md
index d9795f91db3..dbcec0630b9 100644
--- a/docs/content.zh/docs/learn-flink/streaming_analytics.md
+++ b/docs/content.zh/docs/learn-flink/streaming_analytics.md
@@ -254,6 +254,8 @@ public abstract class Context implements java.io.Serializable {
 
     public abstract KeyedStateStore windowState();
     public abstract KeyedStateStore globalState();
+
+    public abstract <X> void output(OutputTag<X> outputTag, X value);
 }
 ```
 
@@ -366,7 +368,7 @@ stream
 
 可能我们会猜测以 Flink 的能力，想要做到这样看起来是可行的（前提是你使用的是 ReduceFunction 或 AggregateFunction ），但不是。
 
-之所以可行，是因为时间窗口产生的事件是根据窗口结束时的时间分配时间戳的。例如，一个小时小时的窗口所产生的所有事件都将带有标记一个小时结束的时间戳。后面的窗口内的数据消费和前面的流产生的数据是一致的。
+之所以可行，是因为时间窗口产生的事件是根据窗口结束时的时间分配时间戳的。例如，一个小时的窗口所产生的所有事件都将带有标记一个小时结束的时间戳。后面的窗口内的数据消费和前面的流产生的数据是一致的。
 
 <a name="no-results-for-empty-timewindows"></a>
 
diff --git a/docs/content/docs/dev/datastream/operators/windows.md b/docs/content/docs/dev/datastream/operators/windows.md
index 582d357582a..9b040fe6f11 100644
--- a/docs/content/docs/dev/datastream/operators/windows.md
+++ b/docs/content/docs/dev/datastream/operators/windows.md
@@ -780,6 +780,14 @@ public abstract class ProcessWindowFunction<IN, OUT, KEY, W extends Window> impl
          * State accessor for per-key global state.
          */
         public abstract KeyedStateStore globalState();
+
+        /**
+         * Emits a record to the side output identified by the {@code OutputTag}.
+         *
+         * @param outputTag the {@code OutputTag} that identifies the side output to emit to.
+         * @param value The record to emit.
+         */
+        public abstract <X> void output(OutputTag<X> outputTag, X value);
     }
 
 }
diff --git a/docs/content/docs/learn-flink/streaming_analytics.md b/docs/content/docs/learn-flink/streaming_analytics.md
index ce563f27407..405c5310d08 100644
--- a/docs/content/docs/learn-flink/streaming_analytics.md
+++ b/docs/content/docs/learn-flink/streaming_analytics.md
@@ -287,6 +287,8 @@ public abstract class Context implements java.io.Serializable {
 
     public abstract KeyedStateStore windowState();
     public abstract KeyedStateStore globalState();
+
+    public abstract <X> void output(OutputTag<X> outputTag, X value);
 }
 ```