Package com.netflix.genie.agent.execution.statemachine

Class JobExecutionStateMachineImpl

java.lang.Object

com.netflix.genie.agent.execution.statemachine.JobExecutionStateMachineImpl

All Implemented Interfaces:

JobExecutionStateMachine

public class JobExecutionStateMachineImpl
extends Object
implements JobExecutionStateMachine

Implementation of the job execution state machine.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
JobExecutionStateMachineImpl(List<ExecutionStage> executionStages, com.netflix.genie.agent.execution.statemachine.ExecutionContext executionContext, Collection<JobExecutionListener> listeners, JobProcessManager jobProcessManager)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	kill(KillService.KillSource killSource)	Abort execution, if necessary by stopping the running job process.
void	run()	Runs the state machine until completion.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.netflix.genie.agent.execution.statemachine.JobExecutionStateMachine

getExecutionContext, getExecutionStages

Constructor Details

JobExecutionStateMachineImpl

public JobExecutionStateMachineImpl(List<ExecutionStage> executionStages,
 com.netflix.genie.agent.execution.statemachine.ExecutionContext executionContext,
 Collection<JobExecutionListener> listeners,
 JobProcessManager jobProcessManager)

Constructor.

Parameters:

executionStages - the (ordered) list of execution stages

executionContext - the execution context passed across stages during execution

listeners - the list of listeners

jobProcessManager - the job process manager

Method Details

run

public void run()

Runs the state machine until completion.

Specified by:

run in interface JobExecutionStateMachine

kill

public void kill(KillService.KillSource killSource)

Description copied from interface: JobExecutionStateMachine

Abort execution, if necessary by stopping the running job process. The state machine still runs to termination, but may skip steps as appropriate.

Specified by:

kill in interface JobExecutionStateMachine

Parameters:

killSource - a representation of who/what requested the kill