org.apache.beam.runners.fnexecution.control

Class BundleFinalizationHandlers.InMemoryFinalizer

java.lang.Object

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

All Implemented Interfaces:

BundleFinalizationHandler

Enclosing class:

BundleFinalizationHandlers

public static class BundleFinalizationHandlers.InMemoryFinalizer
extends java.lang.Object
implements BundleFinalizationHandler

See BundleFinalizationHandlers.inMemoryFinalizer(InstructionRequestHandler) for details.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

finalizeAllOutstandingBundles

public void finalizeAllOutstandingBundles()

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

requestsFinalization

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