public static class BundleFinalizationHandlers.InMemoryFinalizer extends java.lang.Object implements BundleFinalizationHandler
Modifier and Type | Method and Description |
---|---|
void |
finalizeAllOutstandingBundles()
All finalization requests will be sent without waiting for the responses.
|
void |
requestsFinalization(java.lang.String bundleId)
This callback is invoked whenever an inflight bundle that is being processed requests
finalization.
|
public void finalizeAllOutstandingBundles()
public void requestsFinalization(java.lang.String bundleId)
BundleFinalizationHandler
The runner is responsible for invoking bundle finalization when the output of the bundle has been durably persisted.
requestsFinalization
in interface BundleFinalizationHandler