Package org.apache.beam.runners.fnexecution.control

Interface BundleFinalizationHandler

All Known Implementing Classes:
BundleFinalizationHandlers.InMemoryFinalizer
public interface BundleFinalizationHandler
A handler for the runner when a finalization request has been received.

The runner is responsible for finalizing the bundle when all output from the bundle has been durably persisted.

See finalizing bundles for further details.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    requestsFinalization(String bundleId)
    This callback is invoked whenever an inflight bundle that is being processed requests finalization.

  • Method Details

    • requestsFinalization

      void requestsFinalization(String bundleId)
      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.