org.apache.oozie.command
Class UnpauseTransitionXCommand

java.lang.Object
  extended by org.apache.oozie.command.XCommand<T>
      extended by org.apache.oozie.command.TransitionXCommand<Void>
          extended by org.apache.oozie.command.UnpauseTransitionXCommand
Type Parameters:
T -
All Implemented Interfaces:
Callable<Void>, XCallable<Void>
Direct Known Subclasses:
BundleUnpauseXCommand, CoordUnpauseXCommand

public abstract class UnpauseTransitionXCommand
extends TransitionXCommand<Void>

Transition command for unpause the job. The derived class has to override these following functions:

updateJob() : update job status and attributes unpauseChildren() : submit or queue commands to unpause children notifyParent() : update the status to upstream if any


Field Summary
 
Fields inherited from class org.apache.oozie.command.TransitionXCommand
job
 
Fields inherited from class org.apache.oozie.command.XCommand
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo
 
Constructor Summary
UnpauseTransitionXCommand(String name, String type, int priority)
          The constructor for abstract class UnpauseTransitionXCommand
 
Method Summary
protected  Void execute()
          Command execution body.
 void transitToNext()
          Transit to the next status based on the result of the Job.
abstract  void unpauseChildren()
          Unpause actions associated with the job
 
Methods inherited from class org.apache.oozie.command.TransitionXCommand
getJob, notifyParent, setJob, updateJob
 
Methods inherited from class org.apache.oozie.command.XCommand
call, eagerLoadState, eagerVerifyPrecondition, getCreatedTime, getEntityKey, getInstrumentation, getKey, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, isLockRequired, isReQueueRequired, loadState, queue, queue, resetUsed, verifyPrecondition
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UnpauseTransitionXCommand

public UnpauseTransitionXCommand(String name,
                                 String type,
                                 int priority)
The constructor for abstract class UnpauseTransitionXCommand

Parameters:
name - the command name
type - the command type
priority - the command priority
Method Detail

unpauseChildren

public abstract void unpauseChildren()
                              throws CommandException
Unpause actions associated with the job

Throws:
CommandException - thrown if failed to unpause actions

transitToNext

public final void transitToNext()
                         throws CommandException
Description copied from class: TransitionXCommand
Transit to the next status based on the result of the Job.

Specified by:
transitToNext in class TransitionXCommand<Void>
Throws:
CommandException

execute

protected Void 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 TransitionXCommand<Void>
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.


Copyright © 2012 Apache Software Foundation. All Rights Reserved.