You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/01/19 23:21:16 UTC
[2/2] beam git commit: This closes #1798: Moves
PerKeyCombineFnRunners back to runners-core
This closes #1798: Moves PerKeyCombineFnRunners back to runners-core
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2f580caf
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2f580caf
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2f580caf
Branch: refs/heads/master
Commit: 2f580caff3cca9aa00a3ba36aaebd02feaa87f1c
Parents: 4203670 1a3292f
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Jan 19 14:26:56 2017 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Jan 19 14:26:56 2017 -0800
----------------------------------------------------------------------
.../runners/core/PerKeyCombineFnRunner.java | 45 ----
.../runners/core/PerKeyCombineFnRunners.java | 161 +++++++++++++
.../runners/flink/OldPerKeyCombineFnRunner.java | 62 +++++
.../flink/OldPerKeyCombineFnRunners.java | 155 ++++++++++++
.../runners/flink/PerKeyCombineFnRunners.java | 239 -------------------
.../FlinkMergingNonShuffleReduceFunction.java | 8 +-
.../FlinkMergingPartialReduceFunction.java | 8 +-
.../functions/FlinkMergingReduceFunction.java | 8 +-
.../functions/FlinkPartialReduceFunction.java | 8 +-
.../functions/FlinkReduceFunction.java | 8 +-
10 files changed, 398 insertions(+), 304 deletions(-)
----------------------------------------------------------------------