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 <k...@google.com> Authored: Thu Jan 19 14:26:56 2017 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------