This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 279a056 Merge pull request #5797: [BEAM-4394] Spotless Java everywhere
add f95ca80 [BEAM-4285] Extend side input handlers to handle multiple
access patterns.
add 1207c28 Rename several MultimapSideInput* classes to more generic
SideInput*.
new 0688774 Merge pull request #5814: [BEAM-4285] Extend side input
handlers to handle multiple access patterns.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../core/construction/PTransformTranslation.java | 5 +
.../BatchFlinkExecutableStageContext.java | 8 +-
.../FlinkBatchSideInputHandlerFactory.java | 106 +++++++++++++++++---
.../FlinkBatchSideInputHandlerFactoryTest.java | 93 +++++++++++++----
.../control/ProcessBundleDescriptors.java | 79 ++++++++-------
.../fnexecution/state/StateRequestHandlers.java | 111 +++++++++++----------
.../fnexecution/control/RemoteExecutionTest.java | 25 +++--
7 files changed, 289 insertions(+), 138 deletions(-)
