public class BundleCoordSubmitXCommand 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 |
---|
BundleCoordSubmitXCommand(org.apache.hadoop.conf.Configuration conf,
String bundleId,
String coordName) |
Modifier and Type | Method and Description |
---|---|
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.
|
protected void |
verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
basicResolveAndIncludeDS, getDryRun, getJob, includeDataSets, initEvaluators, mergeDefaultConfig, notifyParent, performWrites, queueMaterializeTransitionXCommand, readAndValidateXml, readDefinition, resolveInitial, storeToDB, submit, submitJob, updateJob
execute, transitToNext
generateEvents, setJob
call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, setLogInfo, toString
public BundleCoordSubmitXCommand(org.apache.hadoop.conf.Configuration conf, String bundleId, String coordName)
public String getEntityKey()
XCommand
getEntityKey
in interface XCallable<String>
getEntityKey
in class CoordSubmitXCommand
protected boolean isLockRequired()
XCommand
Subclasses should override this method if they require locking.
isLockRequired
in class CoordSubmitXCommand
true/false
protected void verifyPrecondition() throws CommandException
XCommand
verifyPrecondition
in class CoordSubmitXCommand
CommandException
- thrown if the precondition is not met.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 CoordSubmitXCommand
CommandException
Copyright © 2016 Apache Software Foundation. All rights reserved.