org.apache.oozie.command.coord
Class CoordinatorCommand<T>

java.lang.Object
  org.apache.oozie.command.Command<T,CoordinatorStore>
      org.apache.oozie.command.coord.CoordinatorCommand<T>

All Implemented Interfaces:

Callable<T>, XCallable<T>

Direct Known Subclasses:

CoordActionMaterializeCommand

public abstract class CoordinatorCommand<T>
extends Command<T,CoordinatorStore>

Field Summary

Fields inherited from class org.apache.oozie.command.Command

dryrun, instrumentation, LOCK_FAILURE_REQUEUE_INTERVAL

Constructor Summary

CoordinatorCommand(String name, String type, int priority, int logMask)

CoordinatorCommand(String name, String type, int priority, int logMask, boolean withStore)

CoordinatorCommand(String name, String type, int priority, int logMask, boolean withStore, boolean dryrun)

Method Summary

Class<? extends Store>

getStoreClass() Return the public interface of the Coordinator Store.

Methods inherited from class org.apache.oozie.command.Command

call, call, execute, getCreatedTime, getEntityKey, getInstrumentation, getKey, getName, getPriority, getType, incrCommandCounter, incrJobCounter, incrJobCounter, inInterruptMode, lock, logQueueCallableFalse, queueCallable, queueCallable, queueCallable, queueCallableForException, resetLogInfoAction, resetLogInfoWorkflow, setInterruptMode, setLogInfo, setLogInfo, setLogInfo, setLogInfo, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CoordinatorCommand

public CoordinatorCommand(String name,
                          String type,
                          int priority,
                          int logMask)

CoordinatorCommand

public CoordinatorCommand(String name,
                          String type,
                          int priority,
                          int logMask,
                          boolean withStore)

CoordinatorCommand

public CoordinatorCommand(String name,
                          String type,
                          int priority,
                          int logMask,
                          boolean withStore,
                          boolean dryrun)

Method Detail

getStoreClass

public Class<? extends Store> getStoreClass()

Return the public interface of the Coordinator Store.

Specified by:

getStoreClass in class Command<T,CoordinatorStore>

Returns:

WorkflowStore