|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.oozie.command.XCommand<T> org.apache.oozie.command.coord.CoordinatorXCommand<Void> org.apache.oozie.command.coord.CoordPushDependencyCheckXCommand
public class CoordPushDependencyCheckXCommand
Field Summary | |
---|---|
protected String |
actionId
|
static String |
CONF_COORD_PUSH_CHECK_REQUEUE_INTERVAL
Property name of command re-queue interval for coordinator push check in milliseconds. |
protected CoordinatorActionBean |
coordAction
|
protected CoordinatorJobBean |
coordJob
|
protected JPAService |
jpaService
|
Fields inherited from class org.apache.oozie.command.XCommand |
---|
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo |
Constructor Summary | |
---|---|
|
CoordPushDependencyCheckXCommand(String actionId)
|
|
CoordPushDependencyCheckXCommand(String actionId,
boolean registerForNotification)
|
|
CoordPushDependencyCheckXCommand(String actionId,
boolean registerForNotification,
boolean removeAvailDependencies)
|
protected |
CoordPushDependencyCheckXCommand(String actionName,
String actionId)
|
Method Summary | |
---|---|
protected void |
eagerLoadState()
Load the necessary state to perform an eager precondition check. |
protected void |
eagerVerifyPrecondition()
Verify the precondition for the command before obtaining a lock. |
protected Void |
execute()
Command execution body. |
long |
getCoordPushCheckRequeueInterval()
Return the re-queue interval for coord push dependency check |
String |
getEntityKey()
Return the entity key for the command. |
String |
getKey()
Get command key |
protected boolean |
isLockRequired()
Indicate if the the command requires locking. |
protected boolean |
isTimeout()
Returns true if timeout period has been reached |
protected void |
loadState()
Load the necessary state to perform the precondition check and to execute the command. |
protected void |
onAllPushDependenciesAvailable()
|
static void |
unregisterMissingDependencies(List<String> missingDeps,
String actionId)
|
protected void |
updateCoordAction(CoordinatorActionBean coordAction,
boolean isChangeInDependency)
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command. |
Methods inherited from class org.apache.oozie.command.coord.CoordinatorXCommand |
---|
generateEvent, generateEvent |
Methods inherited from class org.apache.oozie.command.XCommand |
---|
call, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected String actionId
protected JPAService jpaService
protected CoordinatorActionBean coordAction
protected CoordinatorJobBean coordJob
public static final String CONF_COORD_PUSH_CHECK_REQUEUE_INTERVAL
Constructor Detail |
---|
public CoordPushDependencyCheckXCommand(String actionId)
public CoordPushDependencyCheckXCommand(String actionId, boolean registerForNotification)
public CoordPushDependencyCheckXCommand(String actionId, boolean registerForNotification, boolean removeAvailDependencies)
protected CoordPushDependencyCheckXCommand(String actionName, String actionId)
Method Detail |
---|
protected Void execute() throws CommandException
XCommand
execute
in class XCommand<Void>
CommandException
- thrown if the command execution failed.public long getCoordPushCheckRequeueInterval()
protected boolean isTimeout()
protected void onAllPushDependenciesAvailable() throws CommandException
CommandException
protected void updateCoordAction(CoordinatorActionBean coordAction, boolean isChangeInDependency) throws CommandException
CommandException
public static void unregisterMissingDependencies(List<String> missingDeps, String actionId)
public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<Void>
getEntityKey
in class XCommand<Void>
public String getKey()
XCommand
getKey
in interface XCallable<Void>
getKey
in class XCommand<Void>
protected boolean isLockRequired()
XCommand
isLockRequired
in class XCommand<Void>
true/false
protected void eagerLoadState() throws CommandException
XCommand
eagerLoadState
in class XCommand<Void>
CommandException
protected void eagerVerifyPrecondition() throws CommandException, PreconditionException
XCommand
eagerVerifyPrecondition
in class XCommand<Void>
CommandException
- thrown if the precondition is not met.
PreconditionException
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |