org.apache.beam.runners.fnexecution.control

Interface StageBundleFactory

All Superinterfaces:

java.lang.AutoCloseable

public interface StageBundleFactory
extends java.lang.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 and Description
default RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler) Get a new bundle for processing the data in an executable stage.
RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, TimerReceiverFactory timerReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler) Get a new bundle for processing the data in an executable stage.
ProcessBundleDescriptors.ExecutableProcessBundleDescriptor	getProcessBundleDescriptor()

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

getBundle

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

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

Throws:

java.lang.Exception

getBundle

RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory,
                       TimerReceiverFactory timerReceiverFactory,
                       StateRequestHandler stateRequestHandler,
                       BundleProgressHandler progressHandler)
                throws java.lang.Exception

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

Throws:

java.lang.Exception

getProcessBundleDescriptor

ProcessBundleDescriptors.ExecutableProcessBundleDescriptor getProcessBundleDescriptor()