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/08/16 21:49:00 UTC
[2/2] beam git commit: [BEAM-1347] Plumb through a yet to be created
state client through PTransformRunnerFactory
[BEAM-1347] Plumb through a yet to be created state client through PTransformRunnerFactory
This closes #3723
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8503adbb
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8503adbb
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8503adbb
Branch: refs/heads/master
Commit: 8503adbbc3a590cd0dc2939f6a45d335682a9442
Parents: d0deb6c cfb7988
Author: Luke Cwik <lc...@google.com>
Authored: Wed Aug 16 14:48:45 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Aug 16 14:48:45 2017 -0700
----------------------------------------------------------------------
.../beam/fn/harness/BeamFnDataReadRunner.java | 2 ++
.../beam/fn/harness/BeamFnDataWriteRunner.java | 2 ++
.../beam/fn/harness/BoundedSourceRunner.java | 2 ++
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 8 +++++++
.../org/apache/beam/fn/harness/FnHarness.java | 7 ++++--
.../fn/harness/PTransformRunnerFactory.java | 5 +++-
.../harness/control/ProcessBundleHandler.java | 11 +++++++--
.../fn/harness/state/BeamFnStateClient.java | 25 ++++++++++++++++++++
.../beam/fn/harness/state/package-info.java | 22 +++++++++++++++++
.../fn/harness/BeamFnDataReadRunnerTest.java | 1 +
.../fn/harness/BeamFnDataWriteRunnerTest.java | 1 +
.../fn/harness/BoundedSourceRunnerTest.java | 1 +
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 1 +
.../control/ProcessBundleHandlerTest.java | 9 +++++++
14 files changed, 92 insertions(+), 5 deletions(-)
----------------------------------------------------------------------