public interface BundleFinalizationHandler
The runner is responsible for finalizing the bundle when all output from the bundle has been durably persisted.
See finalizing bundles for further details.
|Modifier and Type||Method and Description|
This callback is invoked whenever an inflight bundle that is being processed requests finalization.
void requestsFinalization(java.lang.String bundleId)
The runner is responsible for invoking bundle finalization when the output of the bundle has been durably persisted.