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

Class StaticRemoteEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.StaticRemoteEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class StaticRemoteEnvironmentFactory
extends Object
implements EnvironmentFactory

An EnvironmentFactory that creates StaticRemoteEnvironment used by a runner harness that would like to use an existing InstructionRequestHandler.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StaticRemoteEnvironmentFactory.Provider	Provider for StaticRemoteEnvironmentFactory.

Method Summary

Modifier and Type	Method	Description
RemoteEnvironment	createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId)	Creates an active RunnerApi.Environment and returns a handle to it.
static StaticRemoteEnvironmentFactory	forService(InstructionRequestHandler instructionRequestHandler)

Methods inherited from class java.lang.Object

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

Method Details

forService

public static StaticRemoteEnvironmentFactory forService(InstructionRequestHandler instructionRequestHandler)

createEnvironment

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

Description copied from interface: EnvironmentFactory

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

Specified by:

createEnvironment in interface EnvironmentFactory