org.apache.reef.runtime.common.driver

Class DriverStatusManager

java.lang.Object

org.apache.reef.runtime.common.driver.DriverStatusManager

public final class DriverStatusManager
extends Object

Manages the Driver's status.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isShuttingDownOrFailing()
void	onComplete() Perform a clean shutdown of the Driver.
void	onError(Throwable exception) End the Driver with an exception.
void	onInit() Changes the driver status to INIT and sends message to the client about the transition.
void	onRunning() Changes the driver status to RUNNING and sends message to the client about the transition.
void	sendJobEndingMessageToClient(Optional<Throwable> exception) Sends the final message to the Driver.

Methods inherited from class java.lang.Object

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

Method Detail

onInit

public void onInit()

Changes the driver status to INIT and sends message to the client about the transition.

onRunning

public void onRunning()

Changes the driver status to RUNNING and sends message to the client about the transition. If the driver is in status 'PRE_INIT', this first calls onInit();

onError

public void onError(Throwable exception)

End the Driver with an exception.

Parameters:

exception -

onComplete

public void onComplete()

Perform a clean shutdown of the Driver.

sendJobEndingMessageToClient

public void sendJobEndingMessageToClient(Optional<Throwable> exception)

Sends the final message to the Driver. This is used by DriverRuntimeStopHandler.onNext().

Parameters:

exception -

isShuttingDownOrFailing

public boolean isShuttingDownOrFailing()