org.apache.oozie.command.bundle

Class BundleSLAAlertsXCommand

java.lang.Object

org.apache.oozie.command.XCommand<Void>

org.apache.oozie.command.SLAAlertsXCommand

org.apache.oozie.command.bundle.BundleSLAAlertsXCommand

All Implemented Interfaces:

Callable<Void>, XCallable<Void>

Direct Known Subclasses:

BundleSLAAlertsDisableXCommand, BundleSLAAlertsEnableXCommand, BundleSLAChangeXCommand

public abstract class BundleSLAAlertsXCommand
extends SLAAlertsXCommand

Field Summary

Fields inherited from class org.apache.oozie.command.XCommand

DEFAULT_LOCK_TIMEOUT, DEFAULT_REQUEUE_DELAY, dryrun, eventService, instrumentation, INSTRUMENTATION_GROUP, LOG

Constructor Summary

Constructors

Constructor and Description
BundleSLAAlertsXCommand(String jobId, String actions, String dates, String childIds)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	executeCoordCommand(String id, String actions, String dates)
protected boolean	executeSlaCommand() Execute sla command.
protected String	getActions() Gets the actions.
protected String	getCoordJobs() Gets the coord jobs.
protected Set<String>	getCoordJobsFromBundle(String id, String coords) Gets the coord jobs from bundle.
protected String	getDates() Gets the dates.
protected boolean	isJobRequest()
protected void	loadState() Load the necessary state to perform the precondition check and to execute the command.

Methods inherited from class org.apache.oozie.command.SLAAlertsXCommand

execute, getEntityKey, getJobId, getKey, isLockRequired, setLogInfo, updateJob, validateSLAChangeParam, verifyPrecondition

Methods inherited from class org.apache.oozie.command.XCommand

call, call, eagerLoadState, eagerVerifyPrecondition, executeInterrupts, getCreatedTime, getInstrumentation, getLockTimeOut, getLog, getName, getPriority, getRequeueDelay, getType, inInterruptMode, isReQueueRequired, queue, queue, resetUsed, setInterruptMode, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BundleSLAAlertsXCommand

public BundleSLAAlertsXCommand(String jobId,
                       String actions,
                       String dates,
                       String childIds)

Method Detail

loadState

protected void loadState()
                  throws CommandException

Description copied from class: XCommand

Load the necessary state to perform the precondition check and to execute the command.

Subclasses must implement this method and load the state needed to do the precondition check and execute the command.

Overrides:

loadState in class SLAAlertsXCommand

Throws:

CommandException

getCoordJobsFromBundle

protected Set<String> getCoordJobsFromBundle(String id,
                                 String coords)
                                      throws CommandException

Gets the coord jobs from bundle.

Parameters:

id - the bundle id

coords - the coords name/id

Returns:

the coord jobs from bundle

Throws:

CommandException - the command exception

getCoordJobs

protected String getCoordJobs()

Gets the coord jobs.

Returns:

the coord jobs

getActions

protected String getActions()

Gets the actions.

Returns:

the actions

getDates

protected String getDates()

Gets the dates.

Returns:

the dates

isJobRequest

protected boolean isJobRequest()

Specified by:

isJobRequest in class SLAAlertsXCommand

executeSlaCommand

protected boolean executeSlaCommand()
                             throws ServiceException,
                                    CommandException

Description copied from class: SLAAlertsXCommand

Execute sla command.

Specified by:

executeSlaCommand in class SLAAlertsXCommand

Returns:

true, if successful

Throws:

ServiceException - the service exception

CommandException - the command exception

executeCoordCommand

protected abstract void executeCoordCommand(String id,
                       String actions,
                       String dates)
                                     throws ServiceException,
                                            CommandException

Throws:

ServiceException

CommandException