org.apache.oozie.command.wf
Class SubmitHttpXCommand

java.lang.Object
  org.apache.oozie.command.XCommand<T>
      org.apache.oozie.command.wf.WorkflowXCommand<String>
          org.apache.oozie.command.wf.SubmitHttpXCommand

All Implemented Interfaces:

Callable<String>, XCallable<String>

Direct Known Subclasses:

SubmitMRXCommand, SubmitPigXCommand

public abstract class SubmitHttpXCommand
extends WorkflowXCommand<String>

Field Summary

protected static Set<String>	MANDATORY_OOZIE_CONFS
protected static Set<String>	OPTIONAL_OOZIE_CONFS

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

DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, instrumentation, INSTRUMENTATION_GROUP, LOG, logInfo

Constructor Summary

SubmitHttpXCommand(String name, String type, org.apache.hadoop.conf.Configuration conf, String authToken)

Method Summary

protected String	execute() Command execution body.
protected abstract String	getWorkflowXml(org.apache.hadoop.conf.Configuration conf) Generate workflow xml from conf object

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

call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getEntityKey, getInstrumentation, getKey, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isLockRequired, isReQueueRequired, loadState, queue, queue, resetUsed, setInterruptMode, verifyPrecondition

Methods inherited from class java.lang.Object

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

Field Detail

MANDATORY_OOZIE_CONFS

protected static final Set<String> MANDATORY_OOZIE_CONFS

OPTIONAL_OOZIE_CONFS

protected static final Set<String> OPTIONAL_OOZIE_CONFS

Constructor Detail

SubmitHttpXCommand

public SubmitHttpXCommand(String name,
                          String type,
                          org.apache.hadoop.conf.Configuration conf,
                          String authToken)

Method Detail

getWorkflowXml

protected abstract String getWorkflowXml(org.apache.hadoop.conf.Configuration conf)

Generate workflow xml from conf object

Parameters:

conf - the configuration object

Returns:

workflow xml def string representation

execute

protected String 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.

Specified by:

execute in class XCommand<String>

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.