You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/07/11 18:02:52 UTC
flink git commit: [hotfix] [docs] Fix Java typo in dataset
transformations doc
Repository: flink
Updated Branches:
refs/heads/release-1.3 faf797456 -> 9a376536a
[hotfix] [docs] Fix Java typo in dataset transformations doc
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9a376536
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9a376536
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9a376536
Branch: refs/heads/release-1.3
Commit: 9a376536a03326c1ade06b4d7e1be9e170055001
Parents: faf7974
Author: Ken Geis <ge...@gmail.com>
Authored: Tue Jul 11 09:01:22 2017 -0700
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Jul 11 20:02:07 2017 +0200
----------------------------------------------------------------------
docs/dev/batch/dataset_transformations.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/9a376536/docs/dev/batch/dataset_transformations.md
----------------------------------------------------------------------
diff --git a/docs/dev/batch/dataset_transformations.md b/docs/dev/batch/dataset_transformations.md
index fb85b07..c322f22 100644
--- a/docs/dev/batch/dataset_transformations.md
+++ b/docs/dev/batch/dataset_transformations.md
@@ -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
@@ -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>>) {