Repository: flink Updated Branches: refs/heads/release-0.8 00117f7ff -> 11f4a65aa
[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/11f4a65a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/11f4a65a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/11f4a65a Branch: refs/heads/release-0.8 Commit: 11f4a65aa8a869f4d422b98f5ace8b0e273173c0 Parents: 00117f7 Author: FelixNeutatz <[email protected]> Authored: Mon Jan 26 12:53:38 2015 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Mon Jan 26 13:41:23 2015 +0100 ---------------------------------------------------------------------- docs/dataset_transformations.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/11f4a65a/docs/dataset_transformations.md ---------------------------------------------------------------------- diff --git a/docs/dataset_transformations.md b/docs/dataset_transformations.md index 94933d0..da77890 100644 --- a/docs/dataset_transformations.md +++ b/docs/dataset_transformations.md @@ -459,7 +459,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; @@ -474,7 +474,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); }
