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 java.lang.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 and Description
static class	ProcessEnvironmentFactory.Provider Provider of ProcessEnvironmentFactory.

Method Summary

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.

Methods inherited from class java.lang.Object

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

Method Detail

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,
                                           java.lang.String workerId)
                                    throws java.lang.Exception

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

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

java.lang.Exception