org.apache.oozie.sla

Interface SLACalculator

All Known Implementing Classes:

SLACalculatorMemory

public interface SLACalculator

Method Summary

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:

true if successful

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:

true if successful

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