org.apache.beam.runners.fnexecution.control

Class SdkHarnessClient.BundleProcessor.ActiveBundle

java.lang.Object

org.apache.beam.runners.fnexecution.control.SdkHarnessClient.BundleProcessor.ActiveBundle

All Implemented Interfaces:

java.lang.AutoCloseable, RemoteBundle

Enclosing class:

SdkHarnessClient.BundleProcessor

public class SdkHarnessClient.BundleProcessor.ActiveBundle
extends java.lang.Object
implements RemoteBundle

An active bundle for a particular BeamFnApi.ProcessBundleDescriptor.

Method Summary

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 receivers which consume input elements, forwarding them to the remote environment.
void	split(double fractionOfRemainder) Ask the remote bundle to split its current processing based upon its knowledge of remaining work.

Methods inherited from class java.lang.Object

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

Method Detail

getId

public java.lang.String getId()

Returns an id used to represent this bundle.

Specified by:

getId in interface RemoteBundle

getInputReceivers

public java.util.Map<java.lang.String,FnDataReceiver> getInputReceivers()

Get a map of PCollection ids to receivers which consume input elements, forwarding them to the remote environment.

Specified by:

getInputReceivers in interface RemoteBundle

split

public void split(double fractionOfRemainder)

Description copied from interface: RemoteBundle

Ask the remote bundle to split its current processing based upon its knowledge of remaining work. A fraction of 0, is equivalent to asking the SDK to checkpoint.

This method will return after the request has been issued. Any splits will be forwarded to the BundleSplitHandler.

Specified by:

split in interface RemoteBundle

close

public void close()
           throws java.lang.Exception

Blocks until bundle processing is finished. This is comprised of:

• closing each input receiver.
• waiting for the SDK to say that processing the bundle is finished.
• waiting for all inbound data clients to complete

This method will throw an exception if bundle processing has failed. Throwable.getSuppressed() will return all the reasons as to why processing has failed.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface RemoteBundle

Throws:

java.lang.Exception