org.apache.beam.runners.flink

Class FlinkJobInvocation

java.lang.Object

org.apache.beam.runners.flink.FlinkJobInvocation

All Implemented Interfaces:

JobInvocation

public class FlinkJobInvocation
extends java.lang.Object
implements JobInvocation

Invocation of a Flink Job via FlinkRunner.

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.
static FlinkJobInvocation	create(java.lang.String id, java.lang.String retrievalToken, ListeningExecutorService executorService, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, FlinkPipelineOptions pipelineOptions, java.util.List<java.lang.String> filesToStage)
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

Method Detail

create

public static FlinkJobInvocation create(java.lang.String id,
                                        java.lang.String retrievalToken,
                                        ListeningExecutorService executorService,
                                        org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
                                        FlinkPipelineOptions pipelineOptions,
                                        java.util.List<java.lang.String> filesToStage)

start

public void start()

Description copied from interface: JobInvocation

Start the job.

Specified by:

start in interface JobInvocation

getId

public java.lang.String getId()

Specified by:

getId in interface JobInvocation

Returns:

Unique identifier for the job invocation.

cancel

public void cancel()

Description copied from interface: JobInvocation

Cancel the job.

Specified by:

cancel in interface JobInvocation

getState

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

Description copied from interface: JobInvocation

Retrieve the job's current state.

Specified by:

getState in interface JobInvocation

addStateListener

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

Description copied from interface: JobInvocation

Listen for job state changes with a Consumer.

Specified by:

addStateListener in interface JobInvocation

addMessageListener

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

Description copied from interface: JobInvocation

Listen for job messages with a Consumer.

Specified by:

addMessageListener in interface JobInvocation