This project has retired. For details please refer to its Attic page.

org.apache.oozie.command
Class UnpauseTransitionXCommand

java.lang.Object
  org.apache.oozie.command.XCommand<T>
      org.apache.oozie.command.TransitionXCommand<Void>
          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.