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

Class ProcessEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.ProcessEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class ProcessEnvironmentFactory
extends Object
implements EnvironmentFactory

An EnvironmentFactory which forks processes based on the parameters in the Environment. The returned ProcessEnvironment has to make sure to stop the processes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProcessEnvironmentFactory.Provider	Provider of ProcessEnvironmentFactory.

Method Summary

Modifier and Type	Method	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, String workerId)	Creates a new, active RemoteEnvironment backed by a forked process.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static ProcessEnvironmentFactory create(ProcessManager processManager,
 GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer,
 ControlClientPool.Source clientSource,
 IdGenerator idGenerator,
 PipelineOptions pipelineOptions)

createEnvironment

public RemoteEnvironment createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment,
 String workerId)
                                    throws Exception

Creates a new, active RemoteEnvironment backed by a forked process.

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

Exception