This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 48cdfd1154aab9a3255ccfd3cbabfaf0d7b68eb5 Merge: d72cfc5 381f6f2 Author: Lukasz Cwik <[email protected]> AuthorDate: Mon May 21 09:20:19 2018 -0700 [BEAM-4271] Support side inputs for ExecutableStage and provide runner side utilities for handling multimap side inputs. .../fnexecution/control/FnApiControlClient.java | 1 + .../control/ProcessBundleDescriptors.java | 155 ++++++++++- .../fnexecution/state/GrpcStateService.java | 25 +- .../fnexecution/state/StateRequestHandlers.java | 286 +++++++++++++++++++++ .../fnexecution/control/RemoteExecutionTest.java | 129 ++++++++++ .../org/apache/beam/sdk/fn/stream/DataStreams.java | 120 ++++++++- .../apache/beam/sdk/fn/stream/DataStreamsTest.java | 48 ++++ 7 files changed, 748 insertions(+), 16 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
