[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 <[email protected]> Authored: Fri Jun 16 12:03:35 2017 -0700 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
