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 35bf2bd [BEAM-5605] Add support for channel splitting to the gRPC
read "source" and propagate "split" calls to the downstream receiver (#10501)
add f2d19fd [BEAM-5605] Add support for additional parameters to
SplittableDofn methods (#10556)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/transforms/DoFn.java | 62 ++++++++-
.../beam/sdk/transforms/reflect/DoFnSignature.java | 60 ++++++--
.../sdk/transforms/reflect/DoFnSignatures.java | 153 +++++++++++++++++----
.../reflect/DoFnSignaturesProcessElementTest.java | 4 +-
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 111 +++++++++++----
5 files changed, 325 insertions(+), 65 deletions(-)
