public class CoordUpdateXCommand extends CoordSubmitXCommand
bundleId, conf, CONF_CHECK_MAX_FREQUENCY, CONF_DEFAULT_CONCURRENCY, CONF_DEFAULT_MAX_TIMEOUT, CONF_DEFAULT_THROTTLE, CONF_DEFAULT_TIMEOUT_NORMAL, CONF_MAT_THROTTLING_FACTOR, CONF_QUEUE_SIZE, CONFIG_DEFAULT, COORD_INPUT_EVENTS, COORD_INPUT_EVENTS_DATA_IN, COORD_OUTPUT_EVENTS, COORD_OUTPUT_EVENTS_DATA_OUT, COORDINATOR_XML_FILE, coordJob, coordName, dryrun, jpaService
insertList, job, updateList
DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG
Constructor and Description |
---|
CoordUpdateXCommand(boolean dryrun,
org.apache.hadoop.conf.Configuration conf,
String jobId) |
CoordUpdateXCommand(boolean dryrun,
org.apache.hadoop.conf.Configuration conf,
String jobId,
boolean showDiff) |
Modifier and Type | Method and Description |
---|---|
void |
check(CoordinatorJobBean oldCoord,
CoordinatorJobBean newCoord)
Check.
|
String |
getDryRun(CoordinatorJobBean job)
Gets the dryrun output.
|
String |
getEntityKey()
Return the entity key for the command.
|
String |
getKey()
Get command key
|
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.
|
void |
notifyParent()
This will be used to notify the parent about the status of that perticular job.
|
protected void |
queueMaterializeTransitionXCommand(String jobId)
Queue MaterializeTransitionXCommand
|
protected String |
storeToDB(String xmlElement,
org.jdom.Element eJob,
CoordinatorJobBean coordJob)
Write a coordinator job into database
|
protected String |
submit()
Submit the job
|
void |
transitToNext()
Transit to the next status based on the result of the Job.
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
basicResolveAndIncludeDS, getJob, includeDataSets, initEvaluators, mergeDefaultConfig, performWrites, readAndValidateXml, readDefinition, resolveInitial, submitJob, updateJob
execute
generateEvents, setJob
call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, setLogInfo, toString
public CoordUpdateXCommand(boolean dryrun, org.apache.hadoop.conf.Configuration conf, String jobId)
public CoordUpdateXCommand(boolean dryrun, org.apache.hadoop.conf.Configuration conf, String jobId, boolean showDiff)
protected String storeToDB(String xmlElement, org.jdom.Element eJob, CoordinatorJobBean coordJob) throws CommandException
CoordSubmitXCommand
storeToDB
in class CoordSubmitXCommand
xmlElement
- : Coordinator definition xmleJob
- : XML element of jobcoordJob
- : Coordinator job beanCommandException
- thrown if unable to save coordinator job to dbprotected 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 CoordSubmitXCommand
CommandException
protected void verifyPrecondition() throws CommandException
XCommand
verifyPrecondition
in class CoordSubmitXCommand
CommandException
- thrown if the precondition is not met.protected String submit() throws CommandException
SubmitTransitionXCommand
submit
in class CoordSubmitXCommand
CommandException
- thrown if unable to submitpublic void check(CoordinatorJobBean oldCoord, CoordinatorJobBean newCoord) throws CommandException
oldCoord
- the old coordnewCoord
- the new coordCommandException
- the command exceptionprotected void queueMaterializeTransitionXCommand(String jobId)
CoordSubmitXCommand
queueMaterializeTransitionXCommand
in class CoordSubmitXCommand
public void notifyParent() throws CommandException
TransitionXCommand
notifyParent
in class CoordSubmitXCommand
CommandException
protected boolean isLockRequired()
XCommand
Subclasses should override this method if they require locking.
isLockRequired
in class CoordSubmitXCommand
true/false
public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<String>
getEntityKey
in class CoordSubmitXCommand
public void transitToNext()
TransitionXCommand
transitToNext
in class SubmitTransitionXCommand
public String getDryRun(CoordinatorJobBean job) throws Exception
CoordSubmitXCommand
getDryRun
in class CoordSubmitXCommand
job
- the coordinatorJobBeanException
- the exceptionCopyright © 2018 Apache Software Foundation. All rights reserved.