Package org.apache.beam.runners.fnexecution.environment

package org.apache.beam.runners.fnexecution.environment

Classes used to instantiate and manage SDK harness environments.

Related Packages

Package	Description
org.apache.beam.runners.fnexecution.environment.testing	Test utilities for the environment management package.

Class	Description
DockerEnvironmentFactory	An EnvironmentFactory that creates docker containers by shelling out to docker.
DockerEnvironmentFactory.Provider	Provider for DockerEnvironmentFactory.
EmbeddedEnvironmentFactory	An EnvironmentFactory that communicates to a FnHarness which is executing in the same process.
EmbeddedEnvironmentFactory.Provider	Provider of EmbeddedEnvironmentFactory.
EnvironmentFactory	Creates environments which communicate to an SdkHarnessClient.
EnvironmentFactory.Provider	Provider for a EnvironmentFactory and ServerFactory for the environment.
ExternalEnvironmentFactory	An EnvironmentFactory which requests workers via the given URL in the Environment.
ExternalEnvironmentFactory.Provider	Provider of ExternalEnvironmentFactory.
ProcessEnvironment	Environment for process-based execution.
ProcessEnvironmentFactory	An EnvironmentFactory which forks processes based on the parameters in the Environment.
ProcessEnvironmentFactory.Provider	Provider of ProcessEnvironmentFactory.
ProcessManager	A simple process manager which forks processes and kills them if necessary.
ProcessManager.RunningProcess
RemoteEnvironment	A handle to an available remote RunnerApi.Environment.
RemoteEnvironment.SimpleRemoteEnvironment	A RemoteEnvironment which uses the default RemoteEnvironment.close() behavior.
StaticRemoteEnvironment	A RemoteEnvironment that connects to Dataflow runner harness.
StaticRemoteEnvironmentFactory	An EnvironmentFactory that creates StaticRemoteEnvironment used by a runner harness that would like to use an existing InstructionRequestHandler.
StaticRemoteEnvironmentFactory.Provider	Provider for StaticRemoteEnvironmentFactory.