Repository: flink Updated Branches: refs/heads/master edafb3e6c -> f866de6ec
[FLINK-3629] Fix quick start description for the ".timeWindow()" function call Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f866de6e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f866de6e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f866de6e Branch: refs/heads/master Commit: f866de6ec0a0a6fe26270d48ab9af791efa59dd8 Parents: edafb3e Author: Li Fanxi <lifa...@hotmail.com> Authored: Thu Mar 17 14:49:42 2016 +0800 Committer: Li Fanxi <lifa...@hotmail.com> Committed: Thu Mar 17 20:27:39 2016 +0800 ---------------------------------------------------------------------- docs/quickstart/run_example_quickstart.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f866de6e/docs/quickstart/run_example_quickstart.md ---------------------------------------------------------------------- diff --git a/docs/quickstart/run_example_quickstart.md b/docs/quickstart/run_example_quickstart.md index b4475b6..5515c29 100644 --- a/docs/quickstart/run_example_quickstart.md +++ b/docs/quickstart/run_example_quickstart.md @@ -183,7 +183,7 @@ DataStream<Tuple2<String, Long>> result = keyedEdits }); {% endhighlight %} -The first call, `.window()`, specifies that we want to have tumbling (non-overlapping) windows +The first call, `.timeWindow()`, specifies that we want to have tumbling (non-overlapping) windows of five seconds. The second call specifies a *Fold transformation* on each window slice for each unique key. In our case we start from an initial value of `("", 0L)` and add to it the byte difference of every edit in that time window for a user. The resulting Stream now contains
