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 a27acf3 Merge pull request #9892: [BEAM-8427] [SQL] buildIOWrite for
MongoDb Table
add 7b482e4 [BEAM-7233, BEAM-6868] Create an implementation for a bundle
finalizer that stores bundle finalization requests in memory. (#10074)
No new revisions were added by this update.
Summary of changes:
.../control/BundleFinalizationHandler.java | 11 +++-
.../control/BundleFinalizationHandlers.java | 65 ++++++++++++++++++++++
.../fnexecution/control/SdkHarnessClient.java | 4 +-
.../control/BundleFinalizationHandlersTest.java | 56 +++++++++++++++++++
.../fnexecution/control/SdkHarnessClientTest.java | 12 +---
5 files changed, 134 insertions(+), 14 deletions(-)
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleFinalizationHandlers.java
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/BundleFinalizationHandlersTest.java
