Control Service via java abstractions.See: Description
| Interface | Description |
|---|---|
| BundleProgressHandler |
A handler for bundle progress messages, both during bundle execution and on its completion.
|
| ControlClientPool |
A pool of control clients that brokers incoming SDK harness connections (in the form of
InstructionRequestHandlers. |
| ControlClientPool.Sink |
A sink for
InstructionRequestHandlers keyed by worker id. |
| ControlClientPool.Source |
A source of
InstructionRequestHandlers. |
| InstructionRequestHandler |
Interface for any function that can handle a Fn API
BeamFnApi.InstructionRequest. |
| JobBundleFactory |
A factory that has all job-scoped information, and can be combined with stage-scoped information
to create a
StageBundleFactory. |
| OutputReceiverFactory |
A factory that can create output receivers during an executable stage.
|
| RemoteBundle |
A bundle capable of handling input data elements for a
bundle descriptor by
forwarding them to a remote environment for processing. |
| StageBundleFactory |
A bundle factory scoped to a particular
ExecutableStage, which has all of the resources
it needs to provide new RemoteBundles. |
| Class | Description |
|---|---|
| DefaultJobBundleFactory |
A
JobBundleFactory for which the implementation can specify a custom EnvironmentFactory for environment management. |
| DefaultJobBundleFactory.SimpleStageBundleFactory |
A simple stage bundle factory for remotely processing bundles.
|
| DefaultJobBundleFactory.WrappedSdkHarnessClient |
Holder for an
SdkHarnessClient along with its associated state and data servers. |
| 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 sink.
|
| MapControlClientPool |
A
ControlClientPool backed by a client map. |
| ProcessBundleDescriptors |
Utility methods for creating
BeamFnApi.ProcessBundleDescriptor instances. |
| ProcessBundleDescriptors.BagUserStateSpec<K,V,W extends BoundedWindow> |
A container type storing references to the key, value, and window
Coder used when
handling bag user state requests. |
| ProcessBundleDescriptors.ExecutableProcessBundleDescriptor | |
| ProcessBundleDescriptors.SideInputSpec<K,T,W extends BoundedWindow> |
A container type storing references to the key, value, and window
Coder used when
handling side input state requests. |
| ProcessBundleDescriptors.TimerSpec<K,V,W extends BoundedWindow> |
A container type storing references to the key, timer and payload coders and the remote input
destination used when handling timer requests.
|
| RemoteOutputReceiver<T> |
A pair of
Coder and FnDataReceiver which can be registered to receive elements
for a LogicalEndpoint. |
| SdkHarnessClient |
A high-level client for an SDK harness.
|
| SdkHarnessClient.ActiveBundle |
An active bundle for a particular
BeamFnApi.ProcessBundleDescriptor. |
| SingleEnvironmentInstanceJobBundleFactory | Deprecated
replace with a
DefaultJobBundleFactory when appropriate if the EnvironmentFactory is a DockerEnvironmentFactory, or create an
InProcessJobBundleFactory and inline the creation of the environment if appropriate. |
Control Service via java abstractions.