org.apache.beam.runners.fnexecution.control

Class DefaultJobBundleFactory.SimpleStageBundleFactory

java.lang.Object

org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.SimpleStageBundleFactory

All Implemented Interfaces:

java.lang.AutoCloseable, StageBundleFactory

Enclosing class:

DefaultJobBundleFactory

protected static class DefaultJobBundleFactory.SimpleStageBundleFactory
extends java.lang.Object
implements StageBundleFactory

A simple stage bundle factory for remotely processing bundles.

Method Summary

Modifier and Type	Method and Description
void	close()
RemoteBundle	getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler) Get a new bundle for processing the data in an executable stage.
ProcessBundleDescriptors.ExecutableProcessBundleDescriptor	getProcessBundleDescriptor()

Methods inherited from class java.lang.Object

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

Method Detail

getBundle

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

Description copied from interface: StageBundleFactory

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

Specified by:

getBundle in interface StageBundleFactory

Throws:

java.lang.Exception

getProcessBundleDescriptor

public ProcessBundleDescriptors.ExecutableProcessBundleDescriptor getProcessBundleDescriptor()

Specified by:

getProcessBundleDescriptor in interface StageBundleFactory

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception