[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 <ches...@apache.org> Authored: Wed Apr 5 23:40:32 2017 +0200 Committer: zentol <ches...@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 } }
