org.apache.beam.runners.fnexecution.environment

Class DockerEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class DockerEnvironmentFactory
extends java.lang.Object
implements EnvironmentFactory

An EnvironmentFactory that creates docker containers by shelling out to docker. Returned RemoteEnvironments own their respective docker containers. Not thread-safe.

Method Summary

Modifier and Type	Method and Description
RemoteEnvironment	createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment) Creates a new, active RemoteEnvironment backed by a local Docker container.
static DockerEnvironmentFactory	forServices(GrpcFnServer<FnApiControlClientPoolService> controlServiceServer, GrpcFnServer<GrpcLoggingService> loggingServiceServer, GrpcFnServer<ArtifactRetrievalService> retrievalServiceServer, GrpcFnServer<StaticGrpcProvisionService> provisioningServiceServer, ControlClientPool.Source clientSource, IdGenerator idGenerator) Returns a DockerEnvironmentFactory for the provided servers using the default DockerCommand.

Methods inherited from class java.lang.Object

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

Method Detail

forServices

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

Returns a DockerEnvironmentFactory for the provided servers using the default DockerCommand.

createEnvironment

public RemoteEnvironment createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment)
                                    throws java.lang.Exception

Creates a new, active RemoteEnvironment backed by a local Docker container.

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

java.lang.Exception