public class CoordSuspendXCommand extends SuspendTransitionXCommand
insertList, job, updateList
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo
Constructor and Description |
---|
CoordSuspendXCommand(String id) |
Modifier and Type | Method and Description |
---|---|
String |
getEntityKey()
Return the entity key for the command.
|
org.apache.oozie.client.Job |
getJob()
Get the Job for the command.
|
String |
getKey()
Get command key
|
protected boolean |
isLockRequired()
Indicate if the the command requires locking.
|
protected void |
loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
void |
notifyParent()
This will be used to notify the parent about the status of that perticular job.
|
void |
performWrites()
This will be used to perform atomically all the writes within this command.
|
void |
suspendChildren()
Suspend all children of the job
|
void |
transitToNext()
Transit job to suspended from running or to prepsuspended from prep.
|
void |
updateJob()
Update the parent job.
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
execute
generateEvents, setJob
call, call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, toString
public CoordSuspendXCommand(String id)
public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<Void>
getEntityKey
in class XCommand<Void>
protected boolean isLockRequired()
XCommand
isLockRequired
in class XCommand<Void>
true/false
protected void loadState() throws CommandException
XCommand
loadState
in class XCommand<Void>
CommandException
protected void verifyPrecondition() throws CommandException, PreconditionException
XCommand
verifyPrecondition
in class XCommand<Void>
CommandException
- thrown if the precondition is not met.PreconditionException
public void suspendChildren() throws CommandException
SuspendTransitionXCommand
suspendChildren
in class SuspendTransitionXCommand
CommandException
public void notifyParent() throws CommandException
TransitionXCommand
notifyParent
in class TransitionXCommand<Void>
CommandException
public void updateJob()
TransitionXCommand
updateJob
in class TransitionXCommand<Void>
public void performWrites() throws CommandException
TransitionXCommand
performWrites
in class TransitionXCommand<Void>
CommandException
public org.apache.oozie.client.Job getJob()
TransitionXCommand
getJob
in class TransitionXCommand<Void>
public void transitToNext()
transitToNext
in class SuspendTransitionXCommand
TransitionXCommand.transitToNext()
Copyright © 2014 Apache Software Foundation. All Rights Reserved.