public class SubmitMRXCommand extends SubmitHttpXCommand
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 |
---|
SubmitMRXCommand(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkMandatoryConf(org.apache.hadoop.conf.Configuration conf) |
protected org.jdom.Element |
generateSection(org.apache.hadoop.conf.Configuration conf,
org.jdom.Namespace ns) |
String |
getEntityKey()
Return the entity key for the command.
|
protected org.jdom.Namespace |
getSectionNamespace() |
protected String |
getWorkflowName() |
protected boolean |
isLockRequired()
Indicate if the the command requires locking.
|
protected void |
loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
execute, generateConfigurationSection, getWorkflowNamespace, getWorkflowXml
generateEvent, generateEvent, generateEvent, updateParentIfNecessary, updateParentIfNecessary
call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getKey, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, setLogInfo, toString
public SubmitMRXCommand(org.apache.hadoop.conf.Configuration conf)
protected org.jdom.Namespace getSectionNamespace()
getSectionNamespace
in class SubmitHttpXCommand
protected String getWorkflowName()
getWorkflowName
in class SubmitHttpXCommand
protected org.jdom.Element generateSection(org.apache.hadoop.conf.Configuration conf, org.jdom.Namespace ns)
generateSection
in class SubmitHttpXCommand
protected void checkMandatoryConf(org.apache.hadoop.conf.Configuration conf)
checkMandatoryConf
in class SubmitHttpXCommand
public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<String>
getEntityKey
in class XCommand<String>
protected boolean isLockRequired()
XCommand
Subclasses should override this method if they require locking.
isLockRequired
in class XCommand<String>
true/false
protected void loadState()
XCommand
Subclasses must implement this method and load the state needed to do the precondition check and execute the command.
protected void verifyPrecondition() throws CommandException
XCommand
verifyPrecondition
in class XCommand<String>
CommandException
- thrown if the precondition is not met.Copyright © 2018 Apache Software Foundation. All rights reserved.