org.apache.oozie.sla.service

Class SLAService

java.lang.Object

org.apache.oozie.sla.service.SLAService

All Implemented Interfaces:

Service

public class SLAService
extends Object
implements Service

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_ALERT_EVENTS
static String	CONF_CALCULATOR_IMPL
static String	CONF_CAPACITY
static String	CONF_EVENTS_MODIFIED_AFTER
static String	CONF_JOB_EVENT_LATENCY
static String	CONF_PREFIX
static String	CONF_SLA_CALC_LOCK_TIMEOUT
static String	CONF_SLA_CHECK_INITIAL_DELAY
static String	CONF_SLA_CHECK_INTERVAL
static String	CONF_SLA_HISTORY_PURGE_INTERVAL
static XLog	LOG

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
SLAService()

Method Summary

Modifier and Type	Method and Description
boolean	addRegistrationEvent(SLARegistrationBean reg)
boolean	addStatusEvent(String jobId, String status, JobEvent.EventStatus eventStatus, Date startTime, Date endTime)
boolean	changeDefinition(List<Pair<String,Map<String,String>>> idSlaDefinitionList) Change jobs Sla definitions It takes list of pairs of jobid and key/value pairs of el evaluated sla definition.
void	destroy() Destroy the service.
boolean	disableAlert(List<String> jobIds) Disable jobs Sla alert.
boolean	disableChildJobAlert(List<String> parentJobIds) Disable child jobs Sla alert.
boolean	enableAlert(List<String> jobIds) Enable jobs sla alert.
boolean	enableChildJobAlert(List<String> parentJobIds) Enable child jobs sla alert.
Class<? extends Service>	getInterface() Return the public interface of the service.
SLACalculator	getSLACalculator()
void	init(Services services) Initialize the service.
static boolean	isEnabled()
void	removeRegistration(String jobId)
void	runSLAWorker()
void	startSLAWorker()
boolean	updateRegistrationEvent(SLARegistrationBean reg)

Methods inherited from class java.lang.Object

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

Field Detail

CONF_PREFIX

public static final String CONF_PREFIX

See Also:

Constant Field Values

CONF_CALCULATOR_IMPL

public static final String CONF_CALCULATOR_IMPL

See Also:

Constant Field Values

CONF_CAPACITY

public static final String CONF_CAPACITY

See Also:

Constant Field Values

CONF_ALERT_EVENTS

public static final String CONF_ALERT_EVENTS

See Also:

Constant Field Values

CONF_EVENTS_MODIFIED_AFTER

public static final String CONF_EVENTS_MODIFIED_AFTER

See Also:

Constant Field Values

CONF_JOB_EVENT_LATENCY

public static final String CONF_JOB_EVENT_LATENCY

See Also:

Constant Field Values

CONF_SLA_CHECK_INTERVAL

public static final String CONF_SLA_CHECK_INTERVAL

See Also:

Constant Field Values

CONF_SLA_CHECK_INITIAL_DELAY

public static final String CONF_SLA_CHECK_INITIAL_DELAY

See Also:

Constant Field Values

CONF_SLA_CALC_LOCK_TIMEOUT

public static final String CONF_SLA_CALC_LOCK_TIMEOUT

See Also:

Constant Field Values

CONF_SLA_HISTORY_PURGE_INTERVAL

public static final String CONF_SLA_HISTORY_PURGE_INTERVAL

See Also:

Constant Field Values

LOG

public static XLog LOG

Constructor Detail

SLAService

public SLAService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

Throws:

ServiceException - thrown if the service could not initialize.

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.

isEnabled

public static boolean isEnabled()

getSLACalculator

public SLACalculator getSLACalculator()

runSLAWorker

public void runSLAWorker()

startSLAWorker

public void startSLAWorker()

addRegistrationEvent

public boolean addRegistrationEvent(SLARegistrationBean reg)
                             throws ServiceException

Throws:

ServiceException

updateRegistrationEvent

public boolean updateRegistrationEvent(SLARegistrationBean reg)
                                throws ServiceException

Throws:

ServiceException

addStatusEvent

public boolean addStatusEvent(String jobId,
                              String status,
                              JobEvent.EventStatus eventStatus,
                              Date startTime,
                              Date endTime)
                       throws ServiceException

Throws:

ServiceException

removeRegistration

public void removeRegistration(String jobId)

enableAlert

public boolean enableAlert(List<String> jobIds)
                    throws ServiceException

Enable jobs sla alert.

Parameters:

jobIds - the job ids

Returns:

true, if successful

Throws:

ServiceException - the service exception

enableChildJobAlert

public boolean enableChildJobAlert(List<String> parentJobIds)
                            throws ServiceException

Enable child jobs sla alert.

Parameters:

parentJobIds - the parent job ids

Returns:

true, if successful

Throws:

ServiceException - the service exception

disableAlert

public boolean disableAlert(List<String> jobIds)
                     throws ServiceException

Disable jobs Sla alert.

Parameters:

jobIds - the job ids

Returns:

true, if successful

Throws:

ServiceException - the service exception

disableChildJobAlert

public boolean disableChildJobAlert(List<String> parentJobIds)
                             throws ServiceException

Disable child jobs Sla alert.

Parameters:

parentJobIds - the parent job ids

Returns:

true, if successful

Throws:

ServiceException - the service exception

changeDefinition

public boolean changeDefinition(List<Pair<String,Map<String,String>>> idSlaDefinitionList)
                         throws ServiceException

Change jobs Sla definitions It takes list of pairs of jobid and key/value pairs of el evaluated sla definition. Support definition are sla-should-start, sla-should-end, sla-nominal-time and sla-max-duration.

Parameters:

idSlaDefinitionList - the job ids sla pair

Returns:

true, if successful

Throws:

ServiceException - the service exception