BundleFinalizationHandlers.InMemoryFinalizer (Apache Beam 2.67.0)

java.lang.Object

org.apache.beam.runners.fnexecution.control.BundleFinalizationHandlers.InMemoryFinalizer

All Implemented Interfaces:: BundleFinalizationHandler

Enclosing class:: BundleFinalizationHandlers

public static class BundleFinalizationHandlers.InMemoryFinalizer extends Object implements BundleFinalizationHandler

See BundleFinalizationHandlers.inMemoryFinalizer(InstructionRequestHandler) for details.

Method Summary

Modifier and Type

Method

Description

void

finalizeAllOutstandingBundles()

All finalization requests will be sent without waiting for the responses.

void

requestsFinalization(String bundleId)

This callback is invoked whenever an inflight bundle that is being processed requests finalization.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- finalizeAllOutstandingBundles
  
  public void finalizeAllOutstandingBundles()
  
  All finalization requests will be sent without waiting for the responses.
- requestsFinalization
  
  public void requestsFinalization(String bundleId)
  
  Description copied from interface: BundleFinalizationHandler
  
  This callback is invoked whenever an inflight bundle that is being processed requests finalization.
  The runner is responsible for invoking bundle finalization when the output of the bundle has been durably persisted.
  
  Specified by:
  
  requestsFinalization in interface BundleFinalizationHandler