This closed #2331
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3178f07b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3178f07b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3178f07b Branch: refs/heads/master Commit: 3178f07b9dbd913c44f29b828ae199fea2af36bf Parents: 75728a4 d4a9f60 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Apr 25 16:43:42 2017 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Tue Apr 25 16:43:42 2017 +0200 ---------------------------------------------------------------------- .../flink/FlinkBatchTransformTranslators.java | 78 ++----- .../functions/AbstractFlinkCombineRunner.java | 182 +++++++++++++++++ .../FlinkMergingNonShuffleReduceFunction.java | 165 ++------------- .../FlinkMergingPartialReduceFunction.java | 201 ------------------- .../functions/FlinkMergingReduceFunction.java | 199 ------------------ .../functions/FlinkPartialReduceFunction.java | 114 ++--------- .../functions/FlinkReduceFunction.java | 110 ++-------- .../functions/HashingFlinkCombineRunner.java | 173 ++++++++++++++++ .../functions/SortingFlinkCombineRunner.java | 185 +++++++++++++++++ 9 files changed, 611 insertions(+), 796 deletions(-) ----------------------------------------------------------------------
