public abstract static class SdkHarnessClient.ActiveBundle<InputT>
extends java.lang.Object
BeamFnApi.ProcessBundleDescriptor
.Constructor and Description |
---|
ActiveBundle() |
Modifier and Type | Method and Description |
---|---|
static <InputT> SdkHarnessClient.ActiveBundle<InputT> |
create(java.lang.String bundleId,
java.util.concurrent.Future<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> response,
CloseableFnDataReceiver<InputT> dataReceiver) |
abstract java.lang.String |
getBundleId() |
abstract java.util.concurrent.Future<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> |
getBundleResponse() |
abstract CloseableFnDataReceiver<InputT> |
getInputReceiver() |
public abstract java.lang.String getBundleId()
public abstract java.util.concurrent.Future<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> getBundleResponse()
public abstract CloseableFnDataReceiver<InputT> getInputReceiver()
public static <InputT> SdkHarnessClient.ActiveBundle<InputT> create(java.lang.String bundleId, java.util.concurrent.Future<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse> response, CloseableFnDataReceiver<InputT> dataReceiver)