You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/10/23 15:09:54 UTC
flink git commit: [FLINK-6245] Fix late side output documentation in
Window documents.
Repository: flink
Updated Branches:
refs/heads/master e49bc428c -> b2cc4515a
[FLINK-6245] Fix late side output documentation in Window documents.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b2cc4515
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b2cc4515
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b2cc4515
Branch: refs/heads/master
Commit: b2cc4515a842dea029bcf854fb5479e271192a09
Parents: e49bc42
Author: Bowen Li <bo...@gmail.com>
Authored: Mon Oct 23 00:27:09 2017 +0800
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Mon Oct 23 17:09:13 2017 +0200
----------------------------------------------------------------------
docs/dev/stream/operators/windows.md | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b2cc4515/docs/dev/stream/operators/windows.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/operators/windows.md b/docs/dev/stream/operators/windows.md
index f31d2e5..3794677 100644
--- a/docs/dev/stream/operators/windows.md
+++ b/docs/dev/stream/operators/windows.md
@@ -42,6 +42,7 @@ for the rest of the page.
[.allowedLateness(...)] <- optional: "lateness" (else zero)
[.sideOutputLateData(...)] <- optional: "output tag" (else no side output for late data)
.reduce/aggregate/fold/apply() <- required: "function"
+ [.getSideOutput(...)] <- optional: "output tag"
**Non-Keyed Windows**
@@ -52,6 +53,7 @@ for the rest of the page.
[.allowedLateness(...)] <- optional: "lateness" (else zero)
[.sideOutputLateData(...)] <- optional: "output tag" (else no side output for late data)
.reduce/aggregate/fold/apply() <- required: "function"
+ [.getSideOutput(...)] <- optional: "output tag"
In the above, the commands in square brackets ([...]) are optional. This reveals that Flink allows you to customize your
windowing logic in many different ways so that it best fits your needs.
@@ -1235,7 +1237,7 @@ final OutputTag<T> lateOutputTag = new OutputTag<T>("late-data"){};
DataStream<T> input = ...;
-DataStream<T> result = input
+SingleOutputStreamOperator<T> result = input
.keyBy(<key selector>)
.window(<window assigner>)
.allowedLateness(<time>)