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

Class BundleFinalizationHandlers

java.lang.Object

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

public class BundleFinalizationHandlers
extends Object

Utility methods for creating BundleFinalizationHandlers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BundleFinalizationHandlers.InMemoryFinalizer	See inMemoryFinalizer(InstructionRequestHandler) for details.

Constructor Summary

Constructors

Constructor	Description
BundleFinalizationHandlers()

Method Summary

Modifier and Type	Method	Description
static BundleFinalizationHandlers.InMemoryFinalizer	inMemoryFinalizer(InstructionRequestHandler fnApiControlClient)	A bundle finalizer that stores all bundle finalization requests in memory.

Methods inherited from class java.lang.Object

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

Constructor Details

BundleFinalizationHandlers

public BundleFinalizationHandlers()

Method Details

inMemoryFinalizer

public static BundleFinalizationHandlers.InMemoryFinalizer inMemoryFinalizer(InstructionRequestHandler fnApiControlClient)

A bundle finalizer that stores all bundle finalization requests in memory. After the runner durably persists the output, the runner is responsible for invoking BundleFinalizationHandlers.InMemoryFinalizer.finalizeAllOutstandingBundles().