public static class SdkHarnessClient.ActiveBundle extends java.lang.Object implements RemoteBundle
BeamFnApi.ProcessBundleDescriptor
.Modifier and Type | Method and Description |
---|---|
void |
close()
Blocks until bundle processing is finished.
|
java.lang.String |
getId()
Returns an id used to represent this bundle.
|
java.util.Map<java.lang.String,FnDataReceiver<org.apache.beam.sdk.util.WindowedValue<?>>> |
getInputReceivers()
Get a map of PCollection ids to
receiver s which consume input
elements, forwarding them to the remote environment. |
public java.lang.String getId()
getId
in interface RemoteBundle
public java.util.Map<java.lang.String,FnDataReceiver<org.apache.beam.sdk.util.WindowedValue<?>>> getInputReceivers()
receiver
s which consume input
elements, forwarding them to the remote environment.getInputReceivers
in interface RemoteBundle
public void close() throws java.lang.Exception
input receiver
.
This method will throw an exception if bundle processing has failed. Throwable.getSuppressed()
will return all the reasons as to why processing has failed.
close
in interface java.lang.AutoCloseable
close
in interface RemoteBundle
java.lang.Exception