org.apache.oozie.sla

Interface SLACalculator

All Known Implementing Classes:

SLACalculatorMemory

public interface SLACalculator

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addJobStatus(String jobId, String jobStatus, JobEvent.EventStatus jobEventStatus, Date startTime, Date endTime)
boolean	addRegistration(String jobId, SLARegistrationBean reg)
boolean	changeDefinition(List<Pair<String,Map<String,String>>> jobIdsSLAPair) Change jobs Sla definitions It takes list of pairs of jobid and key/value pairs of el evaluated sla definition.
void	clear()
boolean	disableAlert(List<String> jobId) Disable jobs Sla alert.
boolean	disableChildJobAlert(List<String> parentJobIds) Disable Sla alert for child jobs.
boolean	enableAlert(List<String> jobId) Enable jobs sla alert.
boolean	enableChildJobAlert(List<String> parentJobIds) Enable sla alert for child jobs.
SLACalcStatus	get(String jobId)
void	init(org.apache.hadoop.conf.Configuration conf)
boolean	isEmpty()
Iterator<String>	iterator()
void	removeRegistration(String jobId)
int	size()
void	updateAllSlaStatus()
boolean	updateRegistration(String jobId, SLARegistrationBean reg)

Method Detail

init

void init(org.apache.hadoop.conf.Configuration conf)
          throws ServiceException

Throws:

ServiceException

size

int size()

iterator

Iterator<String> iterator()

isEmpty

boolean isEmpty()

addRegistration

boolean addRegistration(String jobId,
                      SLARegistrationBean reg)
                        throws JPAExecutorException

Throws:

JPAExecutorException

updateRegistration

boolean updateRegistration(String jobId,
                         SLARegistrationBean reg)
                           throws JPAExecutorException

Throws:

JPAExecutorException

removeRegistration

void removeRegistration(String jobId)

addJobStatus

boolean addJobStatus(String jobId,
                   String jobStatus,
                   JobEvent.EventStatus jobEventStatus,
                   Date startTime,
                   Date endTime)
                     throws JPAExecutorException,
                            ServiceException

Throws:

JPAExecutorException

ServiceException

updateAllSlaStatus

void updateAllSlaStatus()

clear

void clear()

get

SLACalcStatus get(String jobId)
                  throws JPAExecutorException

Throws:

JPAExecutorException

enableAlert

boolean enableAlert(List<String> jobId)
                    throws JPAExecutorException,
                           ServiceException

Enable jobs sla alert.

Parameters:

jobId - the job ids

Returns:

true, if successful

Throws:

JPAExecutorException - the JPA executor exception

ServiceException - the service exception

enableChildJobAlert

boolean enableChildJobAlert(List<String> parentJobIds)
                            throws JPAExecutorException,
                                   ServiceException

Enable sla alert for child jobs.

Parameters:

parentJobIds - the parent job ids

Returns:

Throws:

JPAExecutorException

ServiceException

disableAlert

boolean disableAlert(List<String> jobId)
                     throws JPAExecutorException,
                            ServiceException

Disable jobs Sla alert.

Parameters:

jobId - the job ids

Returns:

true, if successful

Throws:

JPAExecutorException - the JPA executor exception

ServiceException - the service exception

disableChildJobAlert

boolean disableChildJobAlert(List<String> parentJobIds)
                             throws JPAExecutorException,
                                    ServiceException

Disable Sla alert for child jobs.

Parameters:

parentJobIds - the parent job ids

Returns:

Throws:

JPAExecutorException

ServiceException

changeDefinition

boolean changeDefinition(List<Pair<String,Map<String,String>>> jobIdsSLAPair)
                         throws JPAExecutorException,
                                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:

jobIdsSLAPair - the job ids sla pair

Returns:

true, if successful

Throws:

JPAExecutorException - the JPA executor exception

ServiceException - the service exception