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
InstructionRequestHandler	Interface for any function that can handle a Fn API BeamFnApi.InstructionRequest.
SdkHarnessClient.IdGenerator	A supply of unique identifiers, used internally.

Class Summary

Class	Description
FnApiControlClient	A client for the control plane of an SDK harness, which can issue requests to it over the Fn API.
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.
SdkHarnessClientControlService	A service providing SdkHarnessClient based on an internally managed FnApiControlClientPoolService.

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

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