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

Interface StageBundleFactory

All Superinterfaces:

AutoCloseable

public interface StageBundleFactory
extends AutoCloseable

A bundle factory scoped to a particular ExecutableStage, which has all of the resources it needs to provide new RemoteBundles.

Closing a StageBundleFactory signals that the stage has completed and any resources bound to its lifetime can be cleaned up.

Method Summary

Modifier and Type	Method	Description
default RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, TimerReceiverFactory timerReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler)	Get a new bundle for processing the data in an executable stage.
default RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, TimerReceiverFactory timerReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler, BundleFinalizationHandler finalizationHandler)
RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, TimerReceiverFactory timerReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler, BundleFinalizationHandler finalizationHandler, BundleCheckpointHandler checkpointHandler)
default RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler)	Get a new bundle for processing the data in an executable stage.
default RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler, BundleFinalizationHandler finalizationHandler)
default RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler, BundleFinalizationHandler finalizationHandler, BundleCheckpointHandler checkpointHandler)
InstructionRequestHandler	getInstructionRequestHandler()
ProcessBundleDescriptors.ExecutableProcessBundleDescriptor	getProcessBundleDescriptor()

Methods inherited from interface java.lang.AutoCloseable

close

Method Details

getBundle

default RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
 StateRequestHandler stateRequestHandler,
 BundleProgressHandler progressHandler)
                        throws Exception

Get a new bundle for processing the data in an executable stage.

Throws:

Exception

getBundle

default RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
 StateRequestHandler stateRequestHandler,
 BundleProgressHandler progressHandler,
 BundleFinalizationHandler finalizationHandler)
                        throws Exception

Throws:

Exception

getBundle

default RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
 StateRequestHandler stateRequestHandler,
 BundleProgressHandler progressHandler,
 BundleFinalizationHandler finalizationHandler,
 BundleCheckpointHandler checkpointHandler)
                        throws Exception

Throws:

Exception

getBundle

default RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
 TimerReceiverFactory timerReceiverFactory,
 StateRequestHandler stateRequestHandler,
 BundleProgressHandler progressHandler)
                        throws Exception

Get a new bundle for processing the data in an executable stage.

Throws:

Exception

getBundle

default RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
 TimerReceiverFactory timerReceiverFactory,
 StateRequestHandler stateRequestHandler,
 BundleProgressHandler progressHandler,
 BundleFinalizationHandler finalizationHandler)
                        throws Exception

Throws:

Exception

getBundle

RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
 TimerReceiverFactory timerReceiverFactory,
 StateRequestHandler stateRequestHandler,
 BundleProgressHandler progressHandler,
 BundleFinalizationHandler finalizationHandler,
 BundleCheckpointHandler checkpointHandler)
                throws Exception

Throws:

Exception

getProcessBundleDescriptor

ProcessBundleDescriptors.ExecutableProcessBundleDescriptor getProcessBundleDescriptor()

getInstructionRequestHandler

InstructionRequestHandler getInstructionRequestHandler()