Package org.apache.beam.runners.fnexecution.control

Utilities for a Beam runner to interact with the Fn API Control Service via java abstractions.

See: Description

Interface Summary

Interface	Description
SdkHarnessClient.IdGenerator	A supply of unique identifiers, used internally.

Class Summary

Class	Description
FnApiControlClientPoolService	A Fn API control service which adds incoming SDK harness connections to a pool.
SdkHarnessClient	A high-level client for an SDK harness.
SdkHarnessClient.ActiveBundle<InputT>	An active bundle for a particular BeamFnApi.ProcessBundleDescriptor.
SdkHarnessClient.RemoteInputDestination<T>	A pair of Coder and BeamFnApi.Target which can be handled by the remote SDK harness to receive elements sent from the runner.
SdkHarnessClient.RemoteOutputReceiver<T>	A pair of Coder and FnDataReceiver which can be registered to receive elements for a LogicalEndpoint.

Package org.apache.beam.runners.fnexecution.control Description

Utilities for a Beam runner to interact with the Fn API Control Service via java abstractions.