Package org.apache.beam.runners.fnexecution.environment
package org.apache.beam.runners.fnexecution.environment
Classes used to instantiate and manage SDK harness environments.
-
ClassDescriptionAn
EnvironmentFactory
that creates docker containers by shelling out to docker.Provider for DockerEnvironmentFactory.AnEnvironmentFactory
that communicates to aFnHarness
which is executing in the same process.Provider of EmbeddedEnvironmentFactory.Createsenvironments
which communicate to anSdkHarnessClient
.Provider for aEnvironmentFactory
andServerFactory
for the environment.AnEnvironmentFactory
which requests workers via the given URL in the Environment.Provider of ExternalEnvironmentFactory.Environment for process-based execution.AnEnvironmentFactory
which forks processes based on the parameters in the Environment.Provider of ProcessEnvironmentFactory.A simple process manager which forks processes and kills them if necessary.A handle to an available remoteRunnerApi.Environment
.ARemoteEnvironment
which uses the defaultRemoteEnvironment.close()
behavior.ARemoteEnvironment
that connects to Dataflow runner harness.AnEnvironmentFactory
that creates StaticRemoteEnvironment used by a runner harness that would like to use an existing InstructionRequestHandler.Provider for StaticRemoteEnvironmentFactory.