org.apache.beam.runners.fnexecution.jobsubmission

Class JobInvocation

java.lang.Object

org.apache.beam.runners.fnexecution.jobsubmission.JobInvocation

public class JobInvocation
extends java.lang.Object

Internal representation of a Job which has been invoked (prepared and run) by a client.

Constructor Summary

Constructors

Constructor and Description
JobInvocation(JobInfo jobInfo, org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.ListeningExecutorService executorService, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, PortablePipelineRunner pipelineRunner)

Method Summary

Modifier and Type	Method and Description
void	addMessageListener(java.util.function.Consumer<org.apache.beam.model.jobmanagement.v1.JobApi.JobMessage> messageStreamObserver) Listen for job messages with a Consumer.
void	addStateListener(java.util.function.Consumer<org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum> stateStreamObserver) Listen for job state changes with a Consumer.
void	cancel() Cancel the job.
java.lang.String	getId()
org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum	getState() Retrieve the job's current state.
void	start() Start the job.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobInvocation

public JobInvocation(JobInfo jobInfo,
                     org.apache.beam.vendor.guava.v20_0.com.google.common.util.concurrent.ListeningExecutorService executorService,
                     org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
                     PortablePipelineRunner pipelineRunner)

Method Detail

start

public void start()

Start the job.

getId

public java.lang.String getId()

Returns:

Unique identifier for the job invocation.

cancel

public void cancel()

Cancel the job.

getState

public org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum getState()

Retrieve the job's current state.

addStateListener

public void addStateListener(java.util.function.Consumer<org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum> stateStreamObserver)

Listen for job state changes with a Consumer.

addMessageListener

public void addMessageListener(java.util.function.Consumer<org.apache.beam.model.jobmanagement.v1.JobApi.JobMessage> messageStreamObserver)

Listen for job messages with a Consumer.