public final class DriverStatusManager extends Object
Modifier and Type | Method and Description |
---|---|
boolean |
isClosing()
Check if the driver is in process of shutting down (either gracefully or due to an error).
|
boolean |
isShuttingDownOrFailing()
Deprecated.
TODO[JIRA REEF-1560] Use isClosing() method instead. Remove after version 0.16
|
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 |
onRuntimeStop(Optional<Throwable> exception)
Sends the final message to the client.
|
void |
sendJobEndingMessageToClient(Optional<Throwable> exception)
Deprecated.
TODO[JIRA REEF-1548] Do not use DriverStatusManager as a proxy to the job client.
After release 0.16, make this method private and use it inside onRuntimeStop() method instead.
|
public void onInit()
public void onRunning()
public void onError(Throwable exception)
exception
- Exception that causes the driver shutdown.public void onComplete()
public void onRuntimeStop(Optional<Throwable> exception)
exception
- Exception that caused the job to end (optional).@Deprecated public void sendJobEndingMessageToClient(Optional<Throwable> exception)
exception
- Exception that caused the job to end (can be absent).@Deprecated public boolean isShuttingDownOrFailing()
public boolean isClosing()
Copyright © 2017 The Apache Software Foundation. All rights reserved.