[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 <[email protected]> Authored: Wed Aug 16 14:48:45 2017 -0700 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
