[beam] branch master updated (4135a5d -> 35bf2bd)

[lc...@apache.org]

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