org.apache.beam.runners.fnexecution.jobsubmission

Interface JobInvocation

All Known Implementing Classes:

FlinkJobInvocation

public interface JobInvocation

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

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.
static java.lang.Boolean	isTerminated(org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum state)
void	start() Start the job.

Method Detail

start

void start()

Start the job.

getId

java.lang.String getId()

Returns:

Unique identifier for the job invocation.

cancel

void cancel()

Cancel the job.

getState

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

Retrieve the job's current state.

addStateListener

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

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

Listen for job messages with a Consumer.

isTerminated

static java.lang.Boolean isTerminated(org.apache.beam.model.jobmanagement.v1.JobApi.JobState.Enum state)