protected static class DefaultJobBundleFactory.SimpleStageBundleFactory extends java.lang.Object implements StageBundleFactory
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. |
public RemoteBundle getBundle(OutputReceiverFactory outputReceiverFactory, StateRequestHandler stateRequestHandler, BundleProgressHandler progressHandler) throws java.lang.Exception
StageBundleFactory
bundle
for processing the data in an executable stage.getBundle
in interface StageBundleFactory
java.lang.Exception
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception