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/05 20:06:18 UTC
[2/2] beam git commit: [BEAM-1347] Migrate to Runner API constructs
within the Java SDK harness
[BEAM-1347] Migrate to Runner API constructs within the Java SDK harness
This closes #3297
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf2d3005
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf2d3005
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bf2d3005
Branch: refs/heads/master
Commit: bf2d30058bc0624ab167b79085695fda1e45f589
Parents: ad2c1f1 9511257
Author: Luke Cwik <lc...@google.com>
Authored: Mon Jun 5 13:06:02 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Jun 5 13:06:02 2017 -0700
----------------------------------------------------------------------
sdks/java/harness/pom.xml | 5 +
.../harness/control/ProcessBundleHandler.java | 178 ++++++---
.../fn/harness/control/RegisterHandler.java | 12 +-
.../harness/data/BeamFnDataGrpcMultiplexer.java | 8 +-
.../beam/runners/core/BeamFnDataReadRunner.java | 12 +-
.../runners/core/BeamFnDataWriteRunner.java | 12 +-
.../beam/runners/core/BoundedSourceRunner.java | 10 +-
.../control/ProcessBundleHandlerTest.java | 400 ++++++++-----------
.../fn/harness/control/RegisterHandlerTest.java | 26 +-
.../runners/core/BeamFnDataReadRunnerTest.java | 18 +-
.../runners/core/BeamFnDataWriteRunnerTest.java | 20 +-
.../runners/core/BoundedSourceRunnerTest.java | 8 +-
12 files changed, 371 insertions(+), 338 deletions(-)
----------------------------------------------------------------------