org.apache.oozie.command.wf

Class ForkedActionStartXCommand

java.lang.Object

org.apache.oozie.command.XCommand<T>

org.apache.oozie.command.wf.WorkflowXCommand<T>

org.apache.oozie.command.wf.ActionXCommand<ActionXCommand.ActionExecutorContext>

org.apache.oozie.command.wf.ActionStartXCommand

org.apache.oozie.command.wf.ForkedActionStartXCommand

All Implemented Interfaces:

Callable<ActionXCommand.ActionExecutorContext>, XCallable<ActionXCommand.ActionExecutorContext>

public class ForkedActionStartXCommand
extends ActionStartXCommand

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.command.wf.ActionXCommand

ActionXCommand.ActionExecutorContext, ActionXCommand.ForkedActionExecutorContext

Field Summary

Fields inherited from class org.apache.oozie.command.wf.ActionStartXCommand

actionId, context, COULD_NOT_START, EL_ERROR, EL_EVAL_ERROR, EXEC_DATA_MISSING, START_DATA_MISSING, wfAction, wfJob

Fields inherited from class org.apache.oozie.command.wf.ActionXCommand

RECOVERY_ID_SEPARATOR

Fields inherited from class org.apache.oozie.command.wf.WorkflowXCommand

INSTR_FAILED_JOBS_COUNTER_NAME, INSTR_KILLED_JOBS_COUNTER_NAME, INSTR_SUCCEEDED_JOBS_COUNTER_NAME

Fields inherited from class org.apache.oozie.command.XCommand

DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, LOG

Constructor Summary

Constructors

Constructor and Description
ForkedActionStartXCommand(String actionId, String type)
ForkedActionStartXCommand(WorkflowJobBean wfJob, String id, String type)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	callActionEnd()
protected void	endWF()
protected ActionXCommand.ActionExecutorContext	execute() Command execution body.
void	failJob(ActionExecutor.Context context, WorkflowActionBean action) Fail the job due to failed action
protected ActionXCommand.ActionExecutorContext	getContext(boolean isRetry, boolean isUserRetry) Get action executor context
String	getEntityKey() Return the entity key for the command.
protected void	handleError(ActionXCommand.ActionExecutorContext context, WorkflowJobBean workflow, WorkflowActionBean action)
protected void	handleNonTransient(ActionExecutor.Context context, ActionExecutor executor, WorkflowAction.Status status) Takes care of non transient failures.
protected void	queue(XCommand<?> command, long msDelay) Queue a command for delayed execution after the current command execution completes.
protected void	updateJobLastModified()
protected void	updateParentIfNecessary(WorkflowJobBean wfjob, int maxRetries)

Methods inherited from class org.apache.oozie.command.wf.ActionStartXCommand

getKey, isLockRequired, loadState, queueCommandForTransientFailure, setLogInfo, verifyPrecondition

Methods inherited from class org.apache.oozie.command.wf.ActionXCommand

addActionCron, failJob, handleError, handleTransient, handleUserRetry, incrActionCounter

Methods inherited from class org.apache.oozie.command.wf.WorkflowXCommand

generateEvent, generateEvent, generateEvent, updateParentIfNecessary

Methods inherited from class org.apache.oozie.command.XCommand

call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, resetUsed, setInterruptMode, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkedActionStartXCommand

public ForkedActionStartXCommand(String actionId,
                         String type)

ForkedActionStartXCommand

public ForkedActionStartXCommand(WorkflowJobBean wfJob,
                         String id,
                         String type)

Method Detail

execute

protected ActionXCommand.ActionExecutorContext execute()
                                                throws CommandException

Description copied from class: XCommand

Command execution body.

This method will be invoked after the {link #loadState} and {link #verifyPrecondition} methods.

If the command requires locking, this method will be invoked ONLY if the lock has been acquired.

Overrides:

execute in class ActionStartXCommand

Returns:

a return value from the execution of the command, only meaningful if the command is executed synchronously.

Throws:

CommandException - thrown if the command execution failed.

getEntityKey

public String getEntityKey()

Description copied from class: XCommand

Return the entity key for the command.

Specified by:

getEntityKey in interface XCallable<ActionXCommand.ActionExecutorContext>

Overrides:

getEntityKey in class ActionStartXCommand

Returns:

the entity key for the command.

queue

protected void queue(XCommand<?> command,
         long msDelay)

Description copied from class: XCommand

Queue a command for delayed execution after the current command execution completes.

All commands queued during the execution of the current command with the same delay will be queued for a single serial execution.

If the command execution throws an exception, no command will be effectively queued.

Overrides:

queue in class ActionStartXCommand

Parameters:

command - command to queue.

msDelay - delay in milliseconds.

failJob

public void failJob(ActionExecutor.Context context,
           WorkflowActionBean action)
             throws CommandException

Description copied from class: ActionXCommand

Fail the job due to failed action

Overrides:

failJob in class ActionXCommand<ActionXCommand.ActionExecutorContext>

Parameters:

context - the execution context.

action - the action that caused the workflow to fail

Throws:

CommandException - thrown if unable to fail job

updateParentIfNecessary

protected void updateParentIfNecessary(WorkflowJobBean wfjob,
                           int maxRetries)
                                throws CommandException

Overrides:

updateParentIfNecessary in class WorkflowXCommand<ActionXCommand.ActionExecutorContext>

Throws:

CommandException

handleNonTransient

protected void handleNonTransient(ActionExecutor.Context context,
                      ActionExecutor executor,
                      WorkflowAction.Status status)
                           throws CommandException

Description copied from class: ActionXCommand

Takes care of non transient failures. The job is suspended, and the state of the action is changed to *MANUAL and set pending flag of action to false

Overrides:

handleNonTransient in class ActionXCommand<ActionXCommand.ActionExecutorContext>

Parameters:

context - the execution context.

executor - the executor instance being used.

status - the status to be set for the action.

Throws:

CommandException - thrown if unable to suspend job

handleError

protected void handleError(ActionXCommand.ActionExecutorContext context,
               WorkflowJobBean workflow,
               WorkflowActionBean action)
                    throws CommandException

Overrides:

handleError in class ActionStartXCommand

Throws:

CommandException

updateJobLastModified

protected void updateJobLastModified()

Overrides:

updateJobLastModified in class ActionStartXCommand

endWF

protected void endWF()

Overrides:

endWF in class ActionStartXCommand

callActionEnd

protected void callActionEnd()

Overrides:

callActionEnd in class ActionStartXCommand

getContext

protected ActionXCommand.ActionExecutorContext getContext(boolean isRetry,
                                              boolean isUserRetry)

Description copied from class: ActionStartXCommand

Get action executor context

Overrides:

getContext in class ActionStartXCommand

Returns: