This closes #1234
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/323ec118 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/323ec118 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/323ec118 Branch: refs/heads/gearpump-runner Commit: 323ec1188d2dffcdad640701e1827f90965994a8 Parents: 3933b55 45570b9 Author: Kenneth Knowles <[email protected]> Authored: Thu Nov 3 09:39:17 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Nov 3 09:39:17 2016 -0700 ---------------------------------------------------------------------- .../gearpump/GearpumpPipelineTranslator.java | 2 +- .../translators/ParDoBoundMultiTranslator.java | 17 +- .../translators/ParDoBoundTranslator.java | 3 +- .../translators/functions/DoFnFunction.java | 19 +- .../translators/utils/DoFnRunnerFactory.java | 77 +++ .../translators/utils/GearpumpDoFnRunner.java | 516 ------------------- .../utils/NoOpAggregatorFactory.java | 41 ++ 7 files changed, 143 insertions(+), 532 deletions(-) ----------------------------------------------------------------------
