org.apache.beam.runners.fnexecution.environment

Class InProcessEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.InProcessEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class InProcessEnvironmentFactory
extends java.lang.Object
implements EnvironmentFactory

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

Method Summary

Modifier and Type	Method and 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 container) 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 Detail

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 container)
                                    throws java.lang.Exception

Description copied from interface: EnvironmentFactory

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

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

java.lang.Exception