You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/06/16 19:03:49 UTC
[3/3] beam git commit: [BEAM-1347] Break apart ProcessBundleHandler
to use service locator pattern based upon URNs.
[BEAM-1347] Break apart ProcessBundleHandler to use service locator pattern based upon URNs.
This closes #3375
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa555f59
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aa555f59
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aa555f59
Branch: refs/heads/master
Commit: aa555f593a3265ca015214a6059372aa6b0ce0af
Parents: 54f3078 c9c1a05
Author: Luke Cwik <lc...@google.com>
Authored: Fri Jun 16 12:03:35 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Fri Jun 16 12:03:35 2017 -0700
----------------------------------------------------------------------
sdks/java/harness/pom.xml | 6 +
.../harness/control/ProcessBundleHandler.java | 293 +++--------
.../beam/runners/core/BeamFnDataReadRunner.java | 70 ++-
.../runners/core/BeamFnDataWriteRunner.java | 67 ++-
.../beam/runners/core/BoundedSourceRunner.java | 74 ++-
.../beam/runners/core/DoFnRunnerFactory.java | 182 +++++++
.../runners/core/PTransformRunnerFactory.java | 81 +++
.../control/ProcessBundleHandlerTest.java | 521 +++----------------
.../runners/core/BeamFnDataReadRunnerTest.java | 112 +++-
.../runners/core/BeamFnDataWriteRunnerTest.java | 120 ++++-
.../runners/core/BoundedSourceRunnerTest.java | 124 ++++-
.../runners/core/DoFnRunnerFactoryTest.java | 209 ++++++++
12 files changed, 1134 insertions(+), 725 deletions(-)
----------------------------------------------------------------------