public interface RemoteBundle extends java.lang.AutoCloseable
bundle descriptorby forwarding them to a remote environment for processing.
When a RemoteBundle is closed, it will block until bundle processing is finished on remote resources, and throw an exception if bundle processing has failed.
|Modifier and Type||Method and Description|
Closes this bundle.
Get an id used to represent this bundle.
Get a map of PCollection ids to
receivers which consume input elements, forwarding them to the remote environment.
void close() throws java.lang.Exception
FnDataReceiverto be closed (future calls to that
FnDataReceiverwill throw an exception), and causes the
RemoteBundleto produce any buffered outputs. The call to
close()will block until all of the outputs produced by this bundle have been received.