Skip to content

Commit

Permalink
[hotfix] [docs] Fix Java typo in dataset transformations doc
Browse files Browse the repository at this point in the history
This closes apache#4300
  • Loading branch information
kgeis authored and StephanEwen committed Jul 11, 2017
1 parent 89fd635 commit 9ff92c9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions docs/dev/batch/dataset_transformations.md
Original file line number Diff line number Diff line change
Expand Up @@ -782,7 +782,7 @@ an alternative WordCount implementation.
DataSet<String> input = [..] // The words received as input

DataSet<Tuple2<String, Integer>> combinedWords = input
.groupBy(0); // group identical words
.groupBy(0) // group identical words
.combineGroup(new GroupCombineFunction<String, Tuple2<String, Integer>() {

public void combine(Iterable<String> words, Collector<Tuple2<String, Integer>>) { // combine
Expand All @@ -799,7 +799,7 @@ DataSet<Tuple2<String, Integer>> combinedWords = input
});

DataSet<Tuple2<String, Integer>> output = combinedWords
.groupBy(0); // group by words again
.groupBy(0) // group by words again
.reduceGroup(new GroupReduceFunction() { // group reduce with full data exchange

public void reduce(Iterable<Tuple2<String, Integer>>, Collector<Tuple2<String, Integer>>) {
Expand Down

0 comments on commit 9ff92c9

Please sign in to comment.