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

Class RemoteEnvironment.SimpleRemoteEnvironment

java.lang.Object

org.apache.beam.runners.fnexecution.environment.RemoteEnvironment.SimpleRemoteEnvironment

All Implemented Interfaces:

AutoCloseable, RemoteEnvironment

Enclosing interface:

RemoteEnvironment

public abstract static class RemoteEnvironment.SimpleRemoteEnvironment
extends Object
implements RemoteEnvironment

A RemoteEnvironment which uses the default RemoteEnvironment.close() behavior.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.runners.fnexecution.environment.RemoteEnvironment

RemoteEnvironment.SimpleRemoteEnvironment

Constructor Summary

Constructors

Constructor	Description
SimpleRemoteEnvironment()

Method Summary

Modifier and Type	Method	Description
abstract org.apache.beam.model.pipeline.v1.RunnerApi.Environment	getEnvironment()	Return the environment that the remote handles.
abstract InstructionRequestHandler	getInstructionRequestHandler()	Return an InstructionRequestHandler which can communicate with the environment.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.runners.fnexecution.environment.RemoteEnvironment

close

Constructor Details

SimpleRemoteEnvironment

public SimpleRemoteEnvironment()

Method Details

getEnvironment

public abstract org.apache.beam.model.pipeline.v1.RunnerApi.Environment getEnvironment()

Description copied from interface: RemoteEnvironment

Return the environment that the remote handles.

Specified by:

getEnvironment in interface RemoteEnvironment

getInstructionRequestHandler

public abstract InstructionRequestHandler getInstructionRequestHandler()

Description copied from interface: RemoteEnvironment

Return an InstructionRequestHandler which can communicate with the environment.

Specified by:

getInstructionRequestHandler in interface RemoteEnvironment