org.apache.beam.runners.fnexecution.control

Interface StageBundleFactory<T>

All Superinterfaces:

java.lang.AutoCloseable

public interface StageBundleFactory<T>
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
RemoteBundle<T>	getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler) Get a new bundle for processing the data in an executable stage.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

getBundle

RemoteBundle<T> getBundle(OutputReceiverFactory outputReceiverFactory,
                          StateRequestHandler stateRequestHandler)
                   throws java.lang.Exception

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

Throws:

java.lang.Exception