public class SdkHarnessClient.BundleProcessor
extends java.lang.Object
BeamFnApi.ProcessBundleDescriptor
.Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<org.apache.beam.model.fnexecution.v1.BeamFnApi.RegisterResponse> |
getRegistrationFuture() |
SdkHarnessClient.ActiveBundle |
newBundle()
Start a new bundle for the given
BeamFnApi.ProcessBundleDescriptor identifier. |
public java.util.concurrent.Future<org.apache.beam.model.fnexecution.v1.BeamFnApi.RegisterResponse> getRegistrationFuture()
public SdkHarnessClient.ActiveBundle newBundle()
BeamFnApi.ProcessBundleDescriptor
identifier.
The input channels for the returned SdkHarnessClient.ActiveBundle
are derived from the instructions
in the BeamFnApi.ProcessBundleDescriptor
.