org.apache.beam.runners.fnexecution.control

Class BundleFinalizationHandlers

java.lang.Object

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

public class BundleFinalizationHandlers
extends java.lang.Object

Utility methods for creating BundleFinalizationHandlers.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
BundleFinalizationHandlers()

Method Summary

Modifier and Type	Method and 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 Detail

BundleFinalizationHandlers

public BundleFinalizationHandlers()

Method Detail

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().