public abstract class SubmitHttpXCommand extends WorkflowXCommand<String>
Modifier and Type | Field and Description |
---|---|
protected static Set<String> |
MANDATORY_OOZIE_CONFS |
protected static Set<String> |
OPTIONAL_OOZIE_CONFS |
INSTR_FAILED_JOBS_COUNTER_NAME, INSTR_KILLED_JOBS_COUNTER_NAME, INSTR_SUCCEEDED_JOBS_COUNTER_NAME
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG
Constructor and Description |
---|
SubmitHttpXCommand(String name,
String type,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkMandatoryConf(org.apache.hadoop.conf.Configuration conf) |
protected String |
execute()
Command execution body.
|
protected org.jdom.Element |
generateConfigurationSection(List<String> Dargs,
org.jdom.Namespace ns) |
protected abstract org.jdom.Element |
generateSection(org.apache.hadoop.conf.Configuration conf,
org.jdom.Namespace ns) |
protected abstract org.jdom.Namespace |
getSectionNamespace() |
protected abstract String |
getWorkflowName() |
protected org.jdom.Namespace |
getWorkflowNamespace() |
protected String |
getWorkflowXml(org.apache.hadoop.conf.Configuration conf)
Generate workflow xml from conf object
|
generateEvent, generateEvent, generateEvent, updateParentIfNecessary, updateParentIfNecessary
call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getEntityKey, getInstrumentation, getKey, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isLockRequired, isReQueueRequired, loadState, queue, queue, resetUsed, setInterruptMode, setLogInfo, toString, verifyPrecondition
protected static final Set<String> MANDATORY_OOZIE_CONFS
protected static final Set<String> OPTIONAL_OOZIE_CONFS
public SubmitHttpXCommand(String name, String type, org.apache.hadoop.conf.Configuration conf)
protected abstract org.jdom.Element generateSection(org.apache.hadoop.conf.Configuration conf, org.jdom.Namespace ns)
protected abstract org.jdom.Namespace getSectionNamespace()
protected abstract String getWorkflowName()
protected void checkMandatoryConf(org.apache.hadoop.conf.Configuration conf)
protected org.jdom.Namespace getWorkflowNamespace()
protected String getWorkflowXml(org.apache.hadoop.conf.Configuration conf)
conf
- the configuration objectprotected org.jdom.Element generateConfigurationSection(List<String> Dargs, org.jdom.Namespace ns)
protected String execute() throws CommandException
XCommand
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.
execute
in class XCommand<String>
CommandException
- thrown if the command execution failed.Copyright © 2016 Apache Software Foundation. All rights reserved.