Package org.apache.flink.kubernetes.operator.observer

Class JobStatusObserver<R extends AbstractFlinkResource<?,?>>

java.lang.Object

org.apache.flink.kubernetes.operator.observer.JobStatusObserver<R>

public class JobStatusObserver<R extends AbstractFlinkResource<?,?>>
extends java.lang.Object

An observer to observe the job status.

Field Summary

Fields

Modifier and Type	Field	Description
protected EventRecorder	eventRecorder
static java.lang.String	JOB_NOT_FOUND_ERR

Constructor Summary

Constructors

Constructor	Description
JobStatusObserver(EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
boolean	observe(FlinkResourceContext<R> ctx)	Observe the status of the flink job.
protected void	onTargetJobNotFound(FlinkResourceContext<R> ctx)	Callback when no matching target job was found on a cluster where jobs were found.
protected void	onTimeout(FlinkResourceContext<R> ctx)	Callback when list jobs timeout.

Methods inherited from class java.lang.Object

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

Field Detail

JOB_NOT_FOUND_ERR

public static final java.lang.String JOB_NOT_FOUND_ERR

See Also:

Constant Field Values

eventRecorder

protected final EventRecorder eventRecorder

Constructor Detail

JobStatusObserver

public JobStatusObserver(EventRecorder eventRecorder)

Method Detail

observe

public boolean observe(FlinkResourceContext<R> ctx)

Observe the status of the flink job.

Parameters:

ctx - Resource context.

Returns:

If job found return true, otherwise return false.

onTargetJobNotFound

protected void onTargetJobNotFound(FlinkResourceContext<R> ctx)

Callback when no matching target job was found on a cluster where jobs were found.

Parameters:

ctx - The Flink resource context.

onTimeout

protected void onTimeout(FlinkResourceContext<R> ctx)

Callback when list jobs timeout.

Parameters:

ctx - Resource context.