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 and Description
void	requestsFinalization(java.lang.String bundleId) This callback is invoked whenever an inflight bundle that is being processed requests finalization.

Method Detail

requestsFinalization

void requestsFinalization(java.lang.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.