org.apache.beam.runners.fnexecution.control

Class SdkHarnessClient.ActiveBundle<InputT>

java.lang.Object

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

Enclosing class:

SdkHarnessClient

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

An active bundle for a particular BeamFnApi.ProcessBundleDescriptor.

Constructor Summary

Constructors

Constructor and Description
ActiveBundle()

Method Summary

Modifier and Type	Method and Description
static <InputT> SdkHarnessClient.ActiveBundle<InputT>	create(java.lang.String bundleId, java.util.concurrent.CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> response, CloseableFnDataReceiver<org.apache.beam.sdk.util.WindowedValue<InputT>> dataReceiver, java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,InboundDataClient> outputClients)
abstract java.lang.String	getBundleId()
abstract java.util.concurrent.CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse>	getBundleResponse()
abstract CloseableFnDataReceiver<org.apache.beam.sdk.util.WindowedValue<InputT>>	getInputReceiver()
abstract java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,InboundDataClient>	getOutputClients()

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveBundle

public ActiveBundle()

Method Detail

getBundleId

public abstract java.lang.String getBundleId()

getBundleResponse

public abstract java.util.concurrent.CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> getBundleResponse()

getInputReceiver

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

getOutputClients

public abstract java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,InboundDataClient> getOutputClients()

create

public static <InputT> SdkHarnessClient.ActiveBundle<InputT> create(java.lang.String bundleId,
                                                                    java.util.concurrent.CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> response,
                                                                    CloseableFnDataReceiver<org.apache.beam.sdk.util.WindowedValue<InputT>> dataReceiver,
                                                                    java.util.Map<org.apache.beam.model.fnexecution.v1.BeamFnApi.Target,InboundDataClient> outputClients)