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

Class EmbeddedEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.EmbeddedEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class EmbeddedEnvironmentFactory
extends Object
implements EnvironmentFactory

An EnvironmentFactory that communicates to a FnHarness which is executing in the same process.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method	Description
static EnvironmentFactory	create(PipelineOptions options, GrpcFnServer<GrpcLoggingService> loggingServer, GrpcFnServer<FnApiControlClientPoolService> controlServer, ControlClientPool.Source clientSource)
RemoteEnvironment	createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId)	Creates an active RunnerApi.Environment and returns a handle to it.

Methods inherited from class java.lang.Object

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

Method Details

create

public static EnvironmentFactory create(PipelineOptions options,
 GrpcFnServer<GrpcLoggingService> loggingServer,
 GrpcFnServer<FnApiControlClientPoolService> controlServer,
 ControlClientPool.Source clientSource)

createEnvironment

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

Description copied from interface: EnvironmentFactory

Creates an active RunnerApi.Environment and returns a handle to it.

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

Exception