public class SubmitXCommand extends WorkflowXCommand<String>
Modifier and Type | Field and Description |
---|---|
static String |
CONFIG_DEFAULT |
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 |
---|
SubmitXCommand(boolean dryrun,
org.apache.hadoop.conf.Configuration conf)
Constructor to create the workflow Submit Command.
|
SubmitXCommand(org.apache.hadoop.conf.Configuration conf)
Constructor to create the workflow Submit Command.
|
SubmitXCommand(org.apache.hadoop.conf.Configuration conf,
String parentId)
Constructor for submitting wf through coordinator
|
Modifier and Type | Method and Description |
---|---|
static ELEvaluator |
createELEvaluatorForGroup(org.apache.hadoop.conf.Configuration conf,
String group)
Create an EL evaluator for a given group.
|
protected String |
execute()
Command execution body.
|
String |
getEntityKey()
Return the entity key for the command.
|
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.
|
static String |
resolveSla(org.jdom.Element eSla,
ELEvaluator evalSla)
Resolve variables in sla xml element.
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
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 static final String CONFIG_DEFAULT
public SubmitXCommand(org.apache.hadoop.conf.Configuration conf)
conf
- : Configuration for workflow jobpublic SubmitXCommand(org.apache.hadoop.conf.Configuration conf, String parentId)
conf
- : Configuration for workflow jobparentId
- the coord action idpublic SubmitXCommand(boolean dryrun, org.apache.hadoop.conf.Configuration conf)
dryrun
- : if dryrunconf
- : Configuration for workflow jobprotected 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.public static String resolveSla(org.jdom.Element eSla, ELEvaluator evalSla) throws CommandException
eSla
- sla xml elementevalSla
- sla evaluatorCommandException
public static ELEvaluator createELEvaluatorForGroup(org.apache.hadoop.conf.Configuration conf, String group)
conf
- configuration variablegroup
- group variablepublic 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.