This closes #2112: Use provided Function Runners in Flink Batch Runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b261d489 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b261d489 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b261d489 Branch: refs/heads/master Commit: b261d489061e9a92b7df28ca71bce00844f7dfa6 Parents: 3082178 0ae2a38 Author: Aljoscha Krettek <[email protected]> Authored: Mon Feb 27 13:22:49 2017 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Mon Feb 27 13:22:49 2017 +0100 ---------------------------------------------------------------------- .../flink/FlinkBatchTransformTranslators.java | 9 +- .../runners/flink/OldPerKeyCombineFnRunner.java | 62 ----- .../flink/OldPerKeyCombineFnRunners.java | 155 ----------- .../functions/FlinkAggregatorFactory.java | 53 ++++ .../functions/FlinkDoFnFunction.java | 96 +++---- .../FlinkMergingNonShuffleReduceFunction.java | 65 ++--- .../FlinkMergingPartialReduceFunction.java | 45 ++-- .../functions/FlinkMergingReduceFunction.java | 39 ++- .../functions/FlinkMultiOutputDoFnFunction.java | 101 +++---- .../FlinkMultiOutputProcessContext.java | 118 -------- .../functions/FlinkNoElementAssignContext.java | 68 ----- .../functions/FlinkNoOpStepContext.java | 73 +++++ .../functions/FlinkPartialReduceFunction.java | 53 ++-- .../functions/FlinkProcessContextBase.java | 267 ------------------- .../functions/FlinkReduceFunction.java | 49 ++-- .../functions/FlinkSideInputReader.java | 80 ++++++ .../FlinkSingleOutputProcessContext.java | 69 ----- 17 files changed, 419 insertions(+), 983 deletions(-) ----------------------------------------------------------------------
