diff --git a/docs/dev/batch/dataset_transformations.md b/docs/dev/batch/dataset_transformations.md index fb85b076efc08..c322f22780a86 100644 --- a/docs/dev/batch/dataset_transformations.md +++ b/docs/dev/batch/dataset_transformations.md @@ -782,7 +782,7 @@ an alternative WordCount implementation. DataSet input = [..] // The words received as input DataSet> combinedWords = input - .groupBy(0); // group identical words + .groupBy(0) // group identical words .combineGroup(new GroupCombineFunction() { public void combine(Iterable words, Collector>) { // combine @@ -799,7 +799,7 @@ DataSet> combinedWords = input }); DataSet> 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>, Collector>) {