Repository: flink Updated Branches: refs/heads/master ea710204e -> 32a04e42d
[docs] Corrects combineGroup documentation example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/32a04e42 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/32a04e42 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/32a04e42 Branch: refs/heads/master Commit: 32a04e42d8766ecdfe0db0516b899008bd3d0c3e Parents: ea71020 Author: Till Rohrmann <trohrm...@apache.org> Authored: Fri Apr 17 11:02:39 2015 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Fri Apr 17 11:02:39 2015 +0200 ---------------------------------------------------------------------- docs/dataset_transformations.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/32a04e42/docs/dataset_transformations.md ---------------------------------------------------------------------- diff --git a/docs/dataset_transformations.md b/docs/dataset_transformations.md index 3bb3cec..04f6a4f 100644 --- a/docs/dataset_transformations.md +++ b/docs/dataset_transformations.md @@ -567,7 +567,7 @@ DataSet<Tuple2<String, Integer>> combinedWords = groupedInput.combineGroup(new G DataSet<Tuple2<String, Integer>> groupedCombinedWords = combinedWords.groupBy(0); // group by words again -DataSet<Tuple2<String, Integer>> output = combinedWords.groupReduce(new GroupReduceFunction() { // group reduce with full data exchange +DataSet<Tuple2<String, Integer>> output = combinedWords.reduceGroup(new GroupReduceFunction() { // group reduce with full data exchange public void reduce(Iterable<Tuple2<String, Integer>>, Collector<Tuple2<String, Integer>>) { int count = 0; @@ -586,7 +586,7 @@ DataSet<Tuple2<String, Integer>> output = combinedWords.groupReduce(new GroupRed val input: DataSet[String] = [..] // The words received as input val groupedInput: DataSet[String] = input.groupBy(0) -val combinedWords: DataSet[(String, Int)] = groupedInput.groupCombine { +val combinedWords: DataSet[(String, Int)] = groupedInput.combineGroup { (words, out: Collector[(String, Int)]) => var count = 0 for (word <- words) { @@ -597,7 +597,7 @@ val combinedWords: DataSet[(String, Int)] = groupedInput.groupCombine { val groupedCombinedWords: DataSet[(String, Int)] = combinedWords.groupBy(0) -val output: DataSet[(String, Int)] = groupedInput.groupCombine { +val output: DataSet[(String, Int)] = groupedInput.reduceGroup { (words, out: Collector[(String, Int)]) => var count = 0 for ((word, Int) <- words) {
