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/31 18:18:50 UTC
[2/2] beam git commit: [BEAM-1347] Wire up the
BeamFnStateGrpcClientCache implementation into the ProcessBundleHandler
[BEAM-1347] Wire up the BeamFnStateGrpcClientCache implementation into the ProcessBundleHandler
This closes #3795
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c9653f27
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c9653f27
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c9653f27
Branch: refs/heads/master
Commit: c9653f27056d9d4dd85f7951f4edbd9da524b894
Parents: 5cb7be7 7f8c6e8
Author: Luke Cwik <lc...@google.com>
Authored: Thu Aug 31 11:18:40 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Aug 31 11:18:40 2017 -0700
----------------------------------------------------------------------
.../fn-api/src/main/proto/beam_fn_api.proto | 5 +
.../org/apache/beam/fn/harness/FnHarness.java | 9 +-
.../harness/control/ProcessBundleHandler.java | 147 ++++++++++++++----
.../control/ProcessBundleHandlerTest.java | 153 ++++++++++++++++++-
4 files changed, 279 insertions(+), 35 deletions(-)
----------------------------------------------------------------------