public final class DriverStatusManager extends Object
Modifier and Type | Method and Description |
---|---|
int |
getNumPreviousContainers() |
int |
getNumRecoveredContainers() |
boolean |
isShuttingDownOrFailing() |
void |
onComplete()
Perform a clean shutdown of the Driver.
|
void |
oneContainerRecovered()
Indicate that this Driver has re-established the connection with one more Evaluator of a previous run.
|
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.
|
void |
setNumPreviousContainers(int num)
Set the number of containers to expect still active from a previous execution of the Driver in a restart situation.
|
void |
setRestartCompleted()
Indicate that the Driver restart is complete.
|
public void onInit()
public void onRunning()
public void onError(Throwable exception)
exception
- public void onComplete()
public void sendJobEndingMessageToClient(Optional<Throwable> exception)
exception
- public void setRestartCompleted()
public int getNumPreviousContainers()
public void setNumPreviousContainers(int num)
num
- public int getNumRecoveredContainers()
public void oneContainerRecovered()
public boolean isShuttingDownOrFailing()
Copyright © 2015 The Apache Software Foundation. All rights reserved.