You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ke...@apache.org on 2018/10/10 19:30:53 UTC

[beam] 01/01: Merge pull request #6621: Plumb names properly through streaming side input consuming DoFns

This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 31a3e3ec950318a62ddc4a8431a77e356128c72d
Merge: dc96860 577e0e4
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Wed Oct 10 12:30:46 2018 -0700

    Merge pull request #6621: Plumb names properly through streaming side input consuming DoFns

 .../worker/BeamFnMapTaskExecutorFactory.java       |  13 +-
 .../worker/StreamingModeExecutionContext.java      |  41 +++--
 ...nsertFetchAndFilterStreamingSideInputNodes.java |   9 +-
 .../beam/runners/dataflow/worker/graph/Nodes.java  |   7 +-
 .../worker/StreamingDataflowWorkerTest.java        | 197 +++++----------------
 .../worker/StreamingModeExecutionContextTest.java  |   4 +-
 ...tFetchAndFilterStreamingSideInputNodesTest.java |   4 +-
 .../runners/dataflow/worker/graph/NodesTest.java   |  11 +-
 8 files changed, 110 insertions(+), 176 deletions(-)