This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4135a5d Merge pull request #10537: [BEAM-8630] Use column numbers for
BeamZetaSqlCalRel
add 35bf2bd [BEAM-5605] Add support for channel splitting to the gRPC
read "source" and propagate "split" calls to the downstream receiver (#10501)
No new revisions were added by this update.
Summary of changes:
.../beam/fn/harness/BeamFnDataReadRunner.java | 115 ++++++++++-
.../org/apache/beam/fn/harness/HandlesSplits.java | 28 +--
.../harness/data/ElementCountFnDataReceiver.java | 69 -------
.../harness/data/MultiplexingFnDataReceiver.java | 48 -----
.../harness/data/PCollectionConsumerRegistry.java | 226 +++++++++++++++++----
.../fn/harness/data/QueueingBeamFnDataClient.java | 3 +-
.../beam/fn/harness/AssignWindowsRunnerTest.java | 2 +-
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 207 +++++++++++++++++--
.../data/ElementCountFnDataReceiverTest.java | 98 ---------
.../data/MultiplexingFnDataReceiverTest.java | 111 ----------
.../data/PCollectionConsumerRegistryTest.java | 186 ++++++++++++++++-
11 files changed, 693 insertions(+), 400 deletions(-)
copy
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/RemoteInputDestination.java
=>
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/HandlesSplits.java
(62%)
delete mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/ElementCountFnDataReceiver.java
delete mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/MultiplexingFnDataReceiver.java
delete mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/data/ElementCountFnDataReceiverTest.java
delete mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/data/MultiplexingFnDataReceiverTest.java
