public class SdkHarnessClient.BundleProcessor.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> |
getInputReceivers()
Get a map of PCollection ids to
receiver s which consume input
elements, forwarding them to the remote environment. |
java.util.Map<KV<java.lang.String,java.lang.String>,FnDataReceiver<org.apache.beam.runners.core.construction.Timer>> |
getTimerReceivers()
Get a map of (transform id, timer id) to
receiver s which consume timers,
forwarding them to the remote environment. |
void |
requestProgress()
Ask the remote bundle for progress.
|
void |
split(double fractionOfRemainder)
Ask the remote bundle to split its current processing based upon its knowledge of remaining
work.
|
public java.lang.String getId()
getId
in interface RemoteBundle
public java.util.Map<java.lang.String,FnDataReceiver> getInputReceivers()
receiver
s which consume input
elements, forwarding them to the remote environment.getInputReceivers
in interface RemoteBundle
public java.util.Map<KV<java.lang.String,java.lang.String>,FnDataReceiver<org.apache.beam.runners.core.construction.Timer>> getTimerReceivers()
RemoteBundle
receiver
s which consume timers,
forwarding them to the remote environment.getTimerReceivers
in interface RemoteBundle
public void requestProgress()
RemoteBundle
This method will return after the request has been issue. Any progress reports will be
forwarded to the BundleProgressHandler
.
requestProgress
in interface RemoteBundle
public void split(double fractionOfRemainder)
RemoteBundle
This method will return after the request has been issued. Any splits will be forwarded to
the BundleSplitHandler
.
split
in interface RemoteBundle
public void close() throws java.lang.Exception
input receiver
.
timer 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