org.apache.oozie.sla

Class SLACalculatorMemory

java.lang.Object

org.apache.oozie.sla.SLACalculatorMemory

All Implemented Interfaces:

SLACalculator

public class SLACalculatorMemory
extends Object
implements SLACalculator

Implementation class for SLACalculator that calculates SLA related to start/end/duration of jobs using a memory-based map

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SLACalculatorMemory.HistoryPurgeWorker

Field Summary

Fields

Modifier and Type	Field and Description
protected EventHandlerService	eventHandler
protected Set<String>	historySet
protected Map<String,SLACalcStatus>	slaMap

Constructor Summary

Constructors

Constructor and Description
SLACalculatorMemory()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addJobStatus(String jobId, String jobStatus, JobEvent.EventStatus jobEventStatus, Date startTime, Date endTime) Triggered after receiving Job status change event, update SLA status accordingly
boolean	addRegistration(String jobId, SLARegistrationBean reg) Register a new job into the map for SLA tracking
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> jobIds) Disable jobs Sla alert.
boolean	disableChildJobAlert(List<String> parentJobIds) Disable Sla alert for child jobs.
boolean	enableAlert(List<String> jobIds) Enable jobs sla alert.
boolean	enableChildJobAlert(List<String> parentJobIds) Enable sla alert for child jobs.
SLACalcStatus	get(String jobId)
Set<String>	getHistorySet()
void	init(org.apache.hadoop.conf.Configuration conf)
boolean	isEmpty()
boolean	isJobIdInHistorySet(String jobId)
boolean	isJobIdInSLAMap(String jobId)
Iterator<String>	iterator()
void	reloadExpectedTimeAndConfig(SLACalcStatus slaCalc)
void	removeRegistration(String jobId) Remove job from being tracked in map
int	size()
void	updateAllSlaStatus() Periodically run by the SLAService worker threads to update SLA status by iterating through all the jobs in the map
protected void	updateJobSla(String jobId) Invoked via periodic run, update the SLA for registered jobs
boolean	updateRegistration(String jobId, SLARegistrationBean reg) Update job into the map for SLA tracking
boolean	updateSLARegistartion(SLACalcStatus slaCalc)

Methods inherited from class java.lang.Object

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

Field Detail

slaMap

protected Map<String,SLACalcStatus> slaMap

historySet

protected Set<String> historySet

eventHandler

protected EventHandlerService eventHandler

Constructor Detail

SLACalculatorMemory

public SLACalculatorMemory()

Method Detail

init

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

Specified by:

init in interface SLACalculator

Throws:

ServiceException

size

public int size()

Specified by:

size in interface SLACalculator

getHistorySet

public Set<String> getHistorySet()

get

public SLACalcStatus get(String jobId)
                  throws JPAExecutorException

Specified by:

get in interface SLACalculator

Throws:

JPAExecutorException

iterator

public Iterator<String> iterator()

Specified by:

iterator in interface SLACalculator

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface SLACalculator

clear

public void clear()

Specified by:

clear in interface SLACalculator

updateJobSla

protected void updateJobSla(String jobId)
                     throws Exception

Invoked via periodic run, update the SLA for registered jobs

Throws:

Exception

updateAllSlaStatus

public void updateAllSlaStatus()

Periodically run by the SLAService worker threads to update SLA status by iterating through all the jobs in the map

Specified by:

updateAllSlaStatus in interface SLACalculator

addRegistration

public boolean addRegistration(String jobId,
                      SLARegistrationBean reg)
                        throws JPAExecutorException

Register a new job into the map for SLA tracking

Specified by:

addRegistration in interface SLACalculator

Throws:

JPAExecutorException

updateRegistration

public boolean updateRegistration(String jobId,
                         SLARegistrationBean reg)
                           throws JPAExecutorException

Update job into the map for SLA tracking

Specified by:

updateRegistration in interface SLACalculator

Throws:

JPAExecutorException

removeRegistration

public void removeRegistration(String jobId)

Remove job from being tracked in map

Specified by:

removeRegistration in interface SLACalculator

addJobStatus

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

Triggered after receiving Job status change event, update SLA status accordingly

Specified by:

addJobStatus in interface SLACalculator

Throws:

JPAExecutorException

ServiceException

reloadExpectedTimeAndConfig

public void reloadExpectedTimeAndConfig(SLACalcStatus slaCalc)
                                 throws JPAExecutorException

Throws:

JPAExecutorException

isJobIdInSLAMap

public boolean isJobIdInSLAMap(String jobId)

isJobIdInHistorySet

public boolean isJobIdInHistorySet(String jobId)

enableAlert

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

Description copied from interface: SLACalculator

Enable jobs sla alert.

Specified by:

enableAlert in interface SLACalculator

Parameters:

jobIds - the job ids

Returns:

true, if successful

Throws:

JPAExecutorException - the JPA executor exception

ServiceException - the service exception

enableChildJobAlert

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

Description copied from interface: SLACalculator

Enable sla alert for child jobs.

Specified by:

enableChildJobAlert in interface SLACalculator

Parameters:

parentJobIds - the parent job ids

Returns:

Throws:

JPAExecutorException

ServiceException

disableAlert

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

Description copied from interface: SLACalculator

Disable jobs Sla alert.

Specified by:

disableAlert in interface SLACalculator

Parameters:

jobIds - the job ids

Returns:

true, if successful

Throws:

JPAExecutorException - the JPA executor exception

ServiceException - the service exception

disableChildJobAlert

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

Description copied from interface: SLACalculator

Disable Sla alert for child jobs.

Specified by:

disableChildJobAlert in interface SLACalculator

Parameters:

parentJobIds - the parent job ids

Returns:

Throws:

JPAExecutorException

ServiceException

changeDefinition

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

Description copied from interface: SLACalculator

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.

Specified by:

changeDefinition in interface SLACalculator

Parameters:

jobIdsSLAPair - the job ids sla pair

Returns:

true, if successful

Throws:

JPAExecutorException - the JPA executor exception

ServiceException - the service exception

updateSLARegistartion

public boolean updateSLARegistartion(SLACalcStatus slaCalc)
                              throws JPAExecutorException

Throws:

JPAExecutorException