public abstract class CoordSLAAlertsXCommand extends SLAAlertsXCommand
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG
Constructor and Description |
---|
CoordSLAAlertsXCommand(String jobId,
String name,
String type,
String actions,
String dates) |
Modifier and Type | Method and Description |
---|---|
protected String |
getActionDateListAsString()
Gets the action and date list as string.
|
protected List<String> |
getActionList()
Gets the action list.
|
protected XConfiguration |
getJobConf() |
protected boolean |
isJobRequest() |
protected void |
loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
protected void |
updateJobConf(org.apache.hadoop.conf.Configuration newConf)
Update job conf.
|
protected void |
updateJobSLA(Map<String,String> newParams)
Update job sla.
|
void |
updateSlaTagElement(org.jdom.Element elem,
String tagName,
String value)
Update Sla tag element.
|
execute, executeSlaCommand, getEntityKey, getJobId, getKey, isLockRequired, setLogInfo, updateJob, validateSLAChangeParam, verifyPrecondition
call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, toString
protected void loadState() throws CommandException
XCommand
Subclasses must implement this method and load the state needed to do the precondition check and execute the command.
loadState
in class SLAAlertsXCommand
CommandException
protected void updateJobConf(org.apache.hadoop.conf.Configuration newConf) throws CommandException
newConf
- the new confCommandException
- the command exceptionprotected void updateJobSLA(Map<String,String> newParams) throws CommandException
newParams
- the new paramsCommandException
- the command exceptionprotected String getActionDateListAsString()
protected List<String> getActionList()
protected boolean isJobRequest()
isJobRequest
in class SLAAlertsXCommand
public void updateSlaTagElement(org.jdom.Element elem, String tagName, String value)
elem
- the elemtagName
- the tag namevalue
- the valueprotected XConfiguration getJobConf() throws JPAExecutorException, CommandException
JPAExecutorException
CommandException
Copyright © 2016 Apache Software Foundation. All rights reserved.