beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [2/2] beam git commit: This closes #2112: Use provided Function Runners in Flink Batch Runner
Date Mon, 27 Feb 2017 12:23:53 GMT
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 <aljoscha.krettek@gmail.com>
Authored: Mon Feb 27 13:22:49 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message