org.apache.hive.spark.client

Interface JobHandle.Listener<T extends Serializable>

Enclosing interface:

JobHandle<T extends Serializable>

public static interface JobHandle.Listener<T extends Serializable>

A listener for monitoring the state of the job in the remote context. Callbacks are called when the corresponding state change occurs.

Method Summary

Methods

Modifier and Type	Method and Description
void	onJobCancelled(JobHandle<T> job)
void	onJobFailed(JobHandle<T> job, Throwable cause)
void	onJobQueued(JobHandle<T> job)
void	onJobStarted(JobHandle<T> job)
void	onJobSucceeded(JobHandle<T> job, T result)
void	onSparkJobStarted(JobHandle<T> job, int sparkJobId) Called when a monitored Spark job is started on the remote context.

Method Detail

onJobQueued

void onJobQueued(JobHandle<T> job)

onJobStarted

void onJobStarted(JobHandle<T> job)

onJobCancelled

void onJobCancelled(JobHandle<T> job)

onJobFailed

void onJobFailed(JobHandle<T> job,
               Throwable cause)

onJobSucceeded

void onJobSucceeded(JobHandle<T> job,
                  T result)

onSparkJobStarted

void onSparkJobStarted(JobHandle<T> job,
                     int sparkJobId)

Called when a monitored Spark job is started on the remote context. This callback does not indicate a state change in the client job's status.