Repository: flink Updated Branches: refs/heads/master 268ff7a06 -> 06b2acf79
[FLINK-1428] [docs] Fix typos in Java code example for RichGroupReduceFunction [ci skip] This closes #340. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06b2acf7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06b2acf7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/06b2acf7 Branch: refs/heads/master Commit: 06b2acf7946efc03760cacf464cead5ec2d8daa6 Parents: 268ff7a Author: FelixNeutatz <[email protected]> Authored: Mon Jan 26 12:53:38 2015 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Mon Jan 26 13:40:20 2015 +0100 ---------------------------------------------------------------------- docs/dataset_transformations.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/06b2acf7/docs/dataset_transformations.md ---------------------------------------------------------------------- diff --git a/docs/dataset_transformations.md b/docs/dataset_transformations.md index 4460f81..2ef5123 100644 --- a/docs/dataset_transformations.md +++ b/docs/dataset_transformations.md @@ -462,7 +462,7 @@ public class MyCombinableGroupReducer public void reduce(Iterable<Tuple3<String, Integer, Double>> in, Collector<Tuple3<String, Integer, Double>> out) { - String key = null + String key = null; int intSum = 0; double doubleSum = 0.0; @@ -477,7 +477,7 @@ public class MyCombinableGroupReducer @Override public void combine(Iterable<Tuple3<String, Integer, Double>> in, - Collector<Tuple3<String, Integer, Double>> out)) { + Collector<Tuple3<String, Integer, Double>> out) { // in some cases combine() calls can simply be forwarded to reduce(). this.reduce(in, out); }
