flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [35/37] flink git commit: [FLINK-6203] [docs] [batch] Fix scala GroupReduce example
Date Thu, 06 Apr 2017 07:28:48 GMT
[FLINK-6203] [docs] [batch] Fix scala GroupReduce example


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf28a562
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf28a562
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cf28a562

Branch: refs/heads/table-retraction
Commit: cf28a562159a7a73deb2c214c221bd935250387b
Parents: dabb0ba
Author: zentol <chesnay@apache.org>
Authored: Wed Apr 5 23:40:32 2017 +0200
Committer: zentol <chesnay@apache.org>
Committed: Wed Apr 5 23:42:07 2017 +0200

----------------------------------------------------------------------
 docs/dev/batch/dataset_transformations.md | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/cf28a562/docs/dev/batch/dataset_transformations.md
----------------------------------------------------------------------
diff --git a/docs/dev/batch/dataset_transformations.md b/docs/dev/batch/dataset_transformations.md
index 1f942d4..fb85b07 100644
--- a/docs/dev/batch/dataset_transformations.md
+++ b/docs/dev/batch/dataset_transformations.md
@@ -620,6 +620,7 @@ val output = input.groupBy(0).sortGroup(1, Order.ASCENDING).reduceGroup
{
         for (t <- in) {
           if (prev == null || prev != t)
             out.collect(t)
+            prev = t
         }
     }
 


Mime
View raw message