Repository: flink Updated Branches: refs/heads/master b9a6a5cb5 -> a065ed091
[Docs] Fixed code example in streaming docs This closes #1498. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a065ed09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a065ed09 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a065ed09 Branch: refs/heads/master Commit: a065ed0910fa5636a26c47b3ece5cb48cdbf33f7 Parents: b9a6a5c Author: mjsax <mj...@apache.org> Authored: Tue Jan 12 10:32:38 2016 +0100 Committer: mjsax <mj...@apache.org> Committed: Tue Jan 12 13:26:53 2016 +0100 ---------------------------------------------------------------------- docs/apis/streaming_guide.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a065ed09/docs/apis/streaming_guide.md ---------------------------------------------------------------------- diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md index a1d4d37..de7d46e 100644 --- a/docs/apis/streaming_guide.md +++ b/docs/apis/streaming_guide.md @@ -603,12 +603,12 @@ dataStream.windowAll(TumblingTimeWindows.of(Time.of(5, TimeUnit.SECONDS))); // L <p><strong>Note:</strong> If you are using a windowAll transformation, you need to use an AllWindowFunction instead.</p> {% highlight java %} windowedStream.apply (new WindowFunction<Tuple2<String,Integer>, Integer, Tuple, Window>() { - public void apply (Tuple tuple, + public void apply (Tuple key, Window window, Iterable<Tuple2<String, Integer>> values, Collector<Integer> out) throws Exception { int sum = 0; - for (value t: values) { + for (Tuple2<String,Integer> t: values) { sum += t.f1; } out.collect (new Integer(sum)); @@ -621,7 +621,7 @@ allWindowedStream.apply (new AllWindowFunction<Tuple2<String,Integer>, Integer, Iterable<Tuple2<String, Integer>> values, Collector<Integer> out) throws Exception { int sum = 0; - for (value t: values) { + for (Tuple2<String,Integer> t: values) { sum += t.f1; } out.collect (new Integer(sum));
