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

Class ProcessEnvironment

java.lang.Object

org.apache.beam.runners.fnexecution.environment.ProcessEnvironment

All Implemented Interfaces:

AutoCloseable, RemoteEnvironment

public class ProcessEnvironment
extends Object
implements RemoteEnvironment

Environment for process-based execution. The environment is responsible for stopping the process.

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()	.
static RemoteEnvironment	create(ProcessManager processManager, org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId, InstructionRequestHandler instructionHandler)
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

create

public static RemoteEnvironment create(ProcessManager processManager,
 org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment,
 String workerId,
 InstructionRequestHandler instructionHandler)

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