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 2018/05/21 16:20:24 UTC

[beam] 01/01: [BEAM-4271] Support side inputs for ExecutableStage and provide runner side utilities for handling multimap side inputs.

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 <lc...@google.com>
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
lcwik@apache.org.