org.apache.oozie.command.wf
Class WorkflowCommand<T>

java.lang.Object
  extended by org.apache.oozie.command.Command<T,WorkflowStore>
      extended by org.apache.oozie.command.wf.WorkflowCommand<T>
All Implemented Interfaces:
Callable<T>, XCallable<T>
Direct Known Subclasses:
ActionCommand, CompletedActionCommand, DefinitionCommand, ExternalIdCommand, JobCommand, JobsCommand, KillCommand, NotificationCommand, PurgeCommand, ReRunCommand, ResumeCommand, SignalCommand, SubmitCommand, SubmitHttpCommand, SuspendCommand, WorkflowActionInfoCommand

public abstract class WorkflowCommand<T>
extends Command<T,WorkflowStore>


Field Summary
 
Fields inherited from class org.apache.oozie.command.Command
dryrun, instrumentation, LOCK_FAILURE_REQUEUE_INTERVAL
 
Constructor Summary
WorkflowCommand(String name, String type, int priority, int logMask)
          Create a command that uses a WorkflowStore instance.
WorkflowCommand(String name, String type, int priority, int logMask, boolean withStore)
          Create a command.
 
Method Summary
 Class<? extends Store> getStoreClass()
          Return the public interface of the Workflow Store.
 
Methods inherited from class org.apache.oozie.command.Command
call, call, execute, getCreatedTime, getInstrumentation, getKey, getName, getPriority, getType, incrCommandCounter, incrJobCounter, incrJobCounter, lock, logQueueCallableFalse, queueCallable, queueCallable, queueCallable, queueCallableForException, resetLogInfoAction, resetLogInfoWorkflow, setLogInfo, setLogInfo, setLogInfo, setLogInfo, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

WorkflowCommand

public WorkflowCommand(String name,
                       String type,
                       int priority,
                       int logMask)
Create a command that uses a WorkflowStore instance.

The current XLog.Info values are captured for execution.

Parameters:
name - command name.
type - command type.
priority - priority of the command, used when queuing for asynchronous execution.
logMask - log mask for the command logging calls.

WorkflowCommand

public WorkflowCommand(String name,
                       String type,
                       int priority,
                       int logMask,
                       boolean withStore)
Create a command.

The current XLog.Info values are captured for execution.

Parameters:
name - command name.
type - command type.
priority - priority of the command, used when queuing for asynchronous execution.
logMask - log mask for the command logging calls.
withStore - indicates if the command needs a WorkflowStore instance or not.
Method Detail

getStoreClass

public Class<? extends Store> getStoreClass()
Return the public interface of the Workflow Store.

Specified by:
getStoreClass in class Command<T,WorkflowStore>
Returns:
WorkflowStore


Copyright © 2012 Apache Software Foundation. All Rights Reserved.