[hotfix][docs] Fix typos in window document This closes #5408.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d5d584ea Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d5d584ea Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d5d584ea Branch: refs/heads/master Commit: d5d584ea689caa128af549f1ee925a5911665061 Parents: dddfebf Author: zhouhai02 <[email protected]> Authored: Sun Feb 4 13:30:09 2018 +0800 Committer: zentol <[email protected]> Committed: Tue Feb 6 20:20:47 2018 +0100 ---------------------------------------------------------------------- docs/dev/stream/operators/windows.md | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d5d584ea/docs/dev/stream/operators/windows.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/operators/windows.md b/docs/dev/stream/operators/windows.md index 4deacce..649bfe8 100644 --- a/docs/dev/stream/operators/windows.md +++ b/docs/dev/stream/operators/windows.md @@ -757,7 +757,7 @@ input class MyProcessWindowFunction extends ProcessWindowFunction[(String, Long), String, String, TimeWindow] { - def apply(key: String, context: Context, input: Iterable[(String, Long)], out: Collector[String]): () = { + def process(key: String, context: Context, input: Iterable[(String, Long)], out: Collector[String]): () = { var count = 0L for (in <- input) { count = count + 1 @@ -812,7 +812,7 @@ private static class MyReduceFunction implements ReduceFunction<SensorReading> { private static class MyProcessWindowFunction implements ProcessWindowFunction<SensorReading, Tuple2<Long, SensorReading>, String, TimeWindow> { - public void apply(String key, + public void process(String key, Context context, Iterable<SensorReading> minReadings, Collector<Tuple2<Long, SensorReading>> out) { @@ -895,7 +895,7 @@ private static class AverageAggregate private static class MyProcessWindowFunction implements ProcessWindowFunction<Double, Tuple2<String, Double>, String, TimeWindow> { - public void apply(String key, + public void process(String key, Context context, Iterable<Double> averages, Collector<Tuple2<String, Double>> out) { @@ -936,11 +936,7 @@ class AverageAggregate extends AggregateFunction[(String, Long), (Long, Long), D class MyProcessWindowFunction extends ProcessWindowFunction[Double, (String, Double), String, TimeWindow] { - def apply(key: String, context: Context, averages: Iterable[Double], out: Collector[(String, Double]): () = { - var count = 0L - for (in <- input) { - count = count + 1 - } + def process(key: String, context: Context, averages: Iterable[Double], out: Collector[(String, Double]): () = { val average = averages.iterator.next() out.collect((key, average)) }
