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 d7cc0bd Merge pull request #5707: Remove unused import
new 72d3c7b Make ImmutableExecutableStage constructors public
new 0471713 [BEAM-4285] Implement Flink batch side input handler
new 1c42e90 This closes #5688: [BEAM-4285] Implement Flink batch side
input handler
The 3 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:
.../graph/ImmutableExecutableStage.java | 4 +-
.../BatchFlinkExecutableStageContext.java | 28 ++-
.../FlinkBatchSideInputHandlerFactory.java | 131 ++++++++++++++
.../functions/FlinkBatchStateRequestHandler.java | 42 -----
.../FlinkBatchSideInputHandlerFactoryTest.java | 199 +++++++++++++++++++++
.../control/DockerJobBundleFactory.java | 3 +-
6 files changed, 361 insertions(+), 46 deletions(-)
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkBatchSideInputHandlerFactory.java
delete mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkBatchStateRequestHandler.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/functions/FlinkBatchSideInputHandlerFactoryTest.java
