|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface FlowStepListener
Interface FlowStepListener provides hooks for receiving events on various stages of a FlowStep
execution.
Method Summary | |
---|---|
void |
onStepCompleted(FlowStep flowStep)
The onStepCompleted event is fired when a flowStepJob completed its work |
void |
onStepRunning(FlowStep flowStep)
The onStepRunning event is fired when a given FlowStep moves into the running state |
void |
onStepStarting(FlowStep flowStep)
The onStarting event is fired when a given FlowStep job has been submitted i.e. |
void |
onStepStopping(FlowStep flowStep)
The onStepStopping event is fired when a given FlowStep job is stopped |
boolean |
onStepThrowable(FlowStep flowStep,
Throwable throwable)
The onStepThrowable event is fired if a given FlowStep throws a Throwable type. |
Method Detail |
---|
void onStepStarting(FlowStep flowStep)
FlowStep
job has been submitted i.e. to hadoop cluster
flowStep
- void onStepStopping(FlowStep flowStep)
FlowStep
job is stopped
flowStep
- void onStepRunning(FlowStep flowStep)
FlowStep
moves into the running state
flowStep
- void onStepCompleted(FlowStep flowStep)
flowStep
- boolean onStepThrowable(FlowStep flowStep, Throwable throwable)
FlowStep
throws a Throwable type. This throwable is passed
as an argument to the event. This event method should return true if the given throwable was handled and should
not be rethrown from the Flow.complete()
method.
flowStep
- throwable
-
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |