org.apache.beam.runners.fnexecution.control

Class SdkHarnessClient.ActiveBundle

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, RemoteBundle

Enclosing class:

SdkHarnessClient

public static class SdkHarnessClient.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 till 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 receivers which consume input elements, forwarding them to the remote environment.

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<org.apache.beam.sdk.util.WindowedValue<?>>> 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

close

public void close()
           throws java.lang.Exception

Blocks till 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