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

Interface EnvironmentFactory.Provider

All Known Implementing Classes:

DockerEnvironmentFactory.Provider, EmbeddedEnvironmentFactory.Provider, ExternalEnvironmentFactory.Provider, ProcessEnvironmentFactory.Provider, StaticRemoteEnvironmentFactory.Provider

Enclosing interface:

EnvironmentFactory

public static interface EnvironmentFactory.Provider

Provider for a EnvironmentFactory and ServerFactory for the environment.

Method Summary

Modifier and Type	Method	Description
EnvironmentFactory	createEnvironmentFactory(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer, GrpcFnServer<GrpcLoggingService> loggingServiceServer, GrpcFnServer<ArtifactRetrievalService> retrievalServiceServer, GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer, ControlClientPool clientPool, IdGenerator idGenerator)	Creates EnvironmentFactory for the provided GrpcServices.
default ServerFactory	getServerFactory()	Create the ServerFactory applicable to this environment.

Method Details

createEnvironmentFactory

EnvironmentFactory createEnvironmentFactory(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer,
 GrpcFnServer<GrpcLoggingService> loggingServiceServer,
 GrpcFnServer<ArtifactRetrievalService> retrievalServiceServer,
 GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer,
 ControlClientPool clientPool,
 IdGenerator idGenerator)

Creates EnvironmentFactory for the provided GrpcServices.

getServerFactory

default ServerFactory getServerFactory()

Create the ServerFactory applicable to this environment.