public class ProcessEnvironmentFactory extends java.lang.Object implements EnvironmentFactory
EnvironmentFactory
which forks processes based on the parameters in the Environment.
The returned ProcessEnvironment
has to make sure to stop the processes.Modifier and Type | Class and Description |
---|---|
static class |
ProcessEnvironmentFactory.Provider
Provider of ProcessEnvironmentFactory.
|
Modifier and Type | Method and Description |
---|---|
static ProcessEnvironmentFactory |
create(ProcessManager processManager,
GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer,
ControlClientPool.Source clientSource,
IdGenerator idGenerator,
PipelineOptions pipelineOptions) |
RemoteEnvironment |
createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment,
java.lang.String workerId)
Creates a new, active
RemoteEnvironment backed by a forked process. |
public static ProcessEnvironmentFactory create(ProcessManager processManager, GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer, ControlClientPool.Source clientSource, IdGenerator idGenerator, PipelineOptions pipelineOptions)
public RemoteEnvironment createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, java.lang.String workerId) throws java.lang.Exception
RemoteEnvironment
backed by a forked process.createEnvironment
in interface EnvironmentFactory
java.lang.Exception