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

Class ExternalEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.ExternalEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class ExternalEnvironmentFactory
extends Object
implements EnvironmentFactory

An EnvironmentFactory which requests workers via the given URL in the Environment.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method	Description
static ExternalEnvironmentFactory	create(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer, GrpcFnServer<GrpcLoggingService> loggingServiceServer, GrpcFnServer<ArtifactRetrievalService> retrievalServiceServer, GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer, ControlClientPool.Source clientSource, IdGenerator idGenerator)
RemoteEnvironment	createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId)	Creates a new, active RemoteEnvironment backed by an unmanaged worker.

Methods inherited from class java.lang.Object

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

Method Details

create

public static ExternalEnvironmentFactory create(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer,
 GrpcFnServer<GrpcLoggingService> loggingServiceServer,
 GrpcFnServer<ArtifactRetrievalService> retrievalServiceServer,
 GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer,
 ControlClientPool.Source clientSource,
 IdGenerator idGenerator)

createEnvironment

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

Creates a new, active RemoteEnvironment backed by an unmanaged worker.

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

Exception