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

Class StaticRemoteEnvironment

java.lang.Object

org.apache.beam.runners.fnexecution.environment.StaticRemoteEnvironment

All Implemented Interfaces:

AutoCloseable, RemoteEnvironment

@ThreadSafe
public class StaticRemoteEnvironment
extends Object
implements RemoteEnvironment

A RemoteEnvironment that connects to Dataflow runner harness.

Nested Class Summary

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

RemoteEnvironment.SimpleRemoteEnvironment

Method Summary

Modifier and Type	Method	Description
void	close()	.
org.apache.beam.model.pipeline.v1.RunnerApi.Environment	getEnvironment()	Return the environment that the remote handles.
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

Method Details

getEnvironment

public 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 InstructionRequestHandler getInstructionRequestHandler()

Description copied from interface: RemoteEnvironment

Return an InstructionRequestHandler which can communicate with the environment.

Specified by:

getInstructionRequestHandler in interface RemoteEnvironment

close

public void close()
           throws Exception

Description copied from interface: RemoteEnvironment

.

By default, closes the RemoteEnvironment.getInstructionRequestHandler().

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RemoteEnvironment

Throws:

Exception