org.apache.beam.runners.fnexecution.control

Class SdkHarnessClient.ActiveBundle<InputT>

java.lang.Object

org.apache.beam.runners.fnexecution.control.SdkHarnessClient.ActiveBundle<InputT>

All Implemented Interfaces:

java.lang.AutoCloseable, RemoteBundle<InputT>

Enclosing class:

SdkHarnessClient

public static class SdkHarnessClient.ActiveBundle<InputT>
extends java.lang.Object
implements RemoteBundle<InputT>

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.
FnDataReceiver<org.apache.beam.sdk.util.WindowedValue<InputT>>	getInputReceiver() Returns a receiver which consumes input elements forwarding them to the SDK.

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<InputT>

getInputReceiver

public FnDataReceiver<org.apache.beam.sdk.util.WindowedValue<InputT>> getInputReceiver()

Returns a receiver which consumes input elements forwarding them to the SDK.

Specified by:

getInputReceiver in interface RemoteBundle<InputT>

close

public void close()
           throws java.lang.Exception

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

• closing the 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<InputT>

Throws:

java.lang.Exception