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 d1b513d [BEAM-8575] Add a Python test to test windowing in DoFn
finish_bundle() (#10145)
add 9407578 [BEAM-3419] Flesh out iterable side inputs and key
enumeration for multimaps in shared libraries (#10147)
No new revisions were added by this update.
Summary of changes:
.../fn-execution/src/main/proto/beam_fn_api.proto | 60 +-
.../core/InMemoryMultimapSideInputView.java | 62 +-
.../core/InMemoryMultimapSideInputViewTest.java | 30 +
.../functions/FlinkExecutableStageFunction.java | 2 +
.../functions/FlinkSideInputReader.java | 7 +-
.../FlinkStreamingSideInputHandlerFactory.java | 94 ++-
.../streaming/ExecutableStageDoFnOperator.java | 2 +
.../dataflow/worker/IsmSideInputReader.java | 8 +-
.../control/DataflowSideInputHandlerFactory.java | 54 +-
.../fn/control/ProcessRemoteBundleOperation.java | 2 +
.../DataflowSideInputHandlerFactoryTest.java | 40 +-
.../control/ProcessBundleDescriptors.java | 6 +-
.../fnexecution/state/StateRequestHandlers.java | 279 ++++++--
.../translation/BatchSideInputHandlerFactory.java | 159 ++---
.../fnexecution/control/RemoteExecutionTest.java | 85 ++-
.../BatchSideInputHandlerFactoryTest.java | 95 ++-
.../translation/SparkExecutableStageFunction.java | 2 +
.../beam/model/fnexecution_v1/beam_fn_api.pb.go | 779 ++++++++++++---------
.../beam/model/pipeline_v1/beam_runner_api.pb.go | 187 ++---
.../org/apache/beam/sdk/transforms/DoFnTester.java | 14 +-
.../beam/sdk/transforms/Materializations.java | 53 +-
.../beam/fn/harness/state/MultimapSideInput.java | 18 +
.../runners/portability/fn_api_runner.py | 35 +-
.../apache_beam/runners/worker/bundle_processor.py | 17 +-
24 files changed, 1259 insertions(+), 831 deletions(-)
