|
||||||||||
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.TransitionXCommand<T> org.apache.oozie.command.RerunTransitionXCommand<Void> org.apache.oozie.command.bundle.BundleRerunXCommand
public class BundleRerunXCommand
Rerun bundle coordinator jobs by a list of coordinator names or dates. User can specify if refresh or noCleanup.
The "refresh" is used to indicate if user wants to refresh an action's input/outpur dataset urls The "noCleanup" is used to indicate if user wants to cleanup output events for given rerun actions
Field Summary | |
---|---|
protected boolean |
prevPending
|
Fields inherited from class org.apache.oozie.command.RerunTransitionXCommand |
---|
jobId, prevStatus, ret |
Fields inherited from class org.apache.oozie.command.TransitionXCommand |
---|
insertList, job, updateList |
Fields inherited from class org.apache.oozie.command.XCommand |
---|
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo |
Constructor Summary | |
---|---|
BundleRerunXCommand(String jobId,
String coordScope,
String dateScope,
boolean refresh,
boolean noCleanup)
The constructor for class BundleRerunXCommand |
Method Summary | |
---|---|
String |
getEntityKey()
Return the entity key for the command. |
org.apache.oozie.client.Job |
getJob()
Get the Job for the command. |
XLog |
getLog()
Get XLog log |
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 |
rerunChildren()
Rerun actions associated with the job |
void |
updateJob()
Update the parent job. |
Methods inherited from class org.apache.oozie.command.RerunTransitionXCommand |
---|
eagerLoadState, eagerVerifyPrecondition, execute, getPrevStatus, transitToNext, verifyPrecondition |
Methods inherited from class org.apache.oozie.command.TransitionXCommand |
---|
setJob |
Methods inherited from class org.apache.oozie.command.XCommand |
---|
call, executeInterrupts, getCreatedTime, getInstrumentation, getKey, getLockTimeOut, 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 boolean prevPending
Constructor Detail |
---|
public BundleRerunXCommand(String jobId, String coordScope, String dateScope, boolean refresh, boolean noCleanup)
BundleRerunXCommand
jobId
- the bundle job idcoordScope
- the rerun scope for coordinator job names separated by ","dateScope
- the rerun scope for coordinator nominal times separated by ","refresh
- true if user wants to refresh input/outpur dataset urlsnoCleanup
- false if user wants to cleanup output events for given rerun actionsMethod Detail |
---|
protected void loadState() throws CommandException
XCommand
loadState
in class XCommand<Void>
CommandException
public void rerunChildren() throws CommandException
RerunTransitionXCommand
rerunChildren
in class RerunTransitionXCommand<Void>
CommandException
- thrown if failed to rerun actionspublic void updateJob()
TransitionXCommand
updateJob
in class TransitionXCommand<Void>
public void performWrites() throws CommandException
TransitionXCommand
performWrites
in class TransitionXCommand<Void>
CommandException
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
public org.apache.oozie.client.Job getJob()
TransitionXCommand
getJob
in class TransitionXCommand<Void>
public void notifyParent() throws CommandException
TransitionXCommand
notifyParent
in class TransitionXCommand<Void>
CommandException
public XLog getLog()
XCommand
getLog
in class XCommand<Void>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |