public abstract class SubmitHttpXCommand extends WorkflowXCommand<String>
INSTR_FAILED_JOBS_COUNTER_NAME, INSTR_KILLED_JOBS_COUNTER_NAME, INSTR_SUCCEEDED_JOBS_COUNTER_NAME, KEEP_WF_ACTION_DIR
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
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 © 2018 Apache Software Foundation. All rights reserved.