org.apache.oozie.sla

Class SLACalcStatus

java.lang.Object

org.apache.oozie.client.event.Event

org.apache.oozie.client.event.SLAEvent

org.apache.oozie.sla.SLACalcStatus

public class SLACalcStatus
extends SLAEvent

Class used by SLAService to store SLA objects and perform calculations and sla decisions

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.client.event.SLAEvent

SLAEvent.EventStatus, SLAEvent.SLAStatus

Nested classes/interfaces inherited from class org.apache.oozie.client.event.Event

Event.MessageType

Field Summary

Fields

Modifier and Type	Field and Description
static String	SLA_ENTITYKEY_PREFIX

Fields inherited from class org.apache.oozie.client.event.Event

msgType

Constructor Summary

Constructors

Constructor and Description
SLACalcStatus()
SLACalcStatus(SLACalcStatus a) copy constructor
SLACalcStatus(SLARegistrationBean reg)
SLACalcStatus(SLASummaryBean summary, SLARegistrationBean regBean)

Method Summary

Methods

Modifier and Type	Method and Description
void	acquireLock() Obtain an exclusive lock on the {link #getEntityKey}.
long	getActualDuration()
Date	getActualEnd()
Date	getActualStart()
String	getAlertContact()
String	getAlertEvents()
String	getAppName()
AppType	getAppType()
String	getEntityKey()
byte	getEventProcessed() Get which type of sla event has been processed needed when calculator periodically loops to update all jobs' sla
SLAEvent.EventStatus	getEventStatus()
long	getExpectedDuration()
Date	getExpectedEnd()
Date	getExpectedStart()
String	getId()
String	getJobData()
String	getJobStatus()
Date	getLastModifiedTime()
long	getLockTimeOut()
Event.MessageType	getMsgType()
Date	getNominalTime()
String	getNotificationMsg()
String	getParentId()
String	getSLAConfig()
Map<String,String>	getSLAConfigMap()
SLARegistrationBean	getSLARegistrationBean()
SLAEvent.SLAStatus	getSLAStatus()
String	getUpstreamApps()
String	getUser()
boolean	isLocked()
void	releaseLock()
void	setActualDuration(long actualDuration)
void	setActualEnd(Date actualEnd)
void	setActualStart(Date actualStart)
void	setEventProcessed(int eventProcessed)
void	setEventStatus(SLAEvent.EventStatus es)
void	setId(String id)
void	setJobStatus(String status)
void	setLastModifiedTime(Date lastModifiedTime)
void	setSLARegistrationBean(SLARegistrationBean slaBean)
void	setSLAStatus(SLAEvent.SLAStatus slaStatus)

Methods inherited from class org.apache.oozie.client.event.SLAEvent

toString

Methods inherited from class org.apache.oozie.client.event.Event

setMsgType

Methods inherited from class java.lang.Object

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

Field Detail

SLA_ENTITYKEY_PREFIX

public static String SLA_ENTITYKEY_PREFIX

Constructor Detail

SLACalcStatus

public SLACalcStatus(SLARegistrationBean reg)

SLACalcStatus

public SLACalcStatus(SLASummaryBean summary,
             SLARegistrationBean regBean)

SLACalcStatus

public SLACalcStatus(SLACalcStatus a)

copy constructor

SLACalcStatus

public SLACalcStatus()

Method Detail

getSLARegistrationBean

public SLARegistrationBean getSLARegistrationBean()

setSLARegistrationBean

public void setSLARegistrationBean(SLARegistrationBean slaBean)

getId

public String getId()

Specified by:

getId in class SLAEvent

setId

public void setId(String id)

getActualStart

public Date getActualStart()

Specified by:

getActualStart in class SLAEvent

setActualStart

public void setActualStart(Date actualStart)

getActualEnd

public Date getActualEnd()

Specified by:

getActualEnd in class SLAEvent

setActualEnd

public void setActualEnd(Date actualEnd)

getActualDuration

public long getActualDuration()

Specified by:

getActualDuration in class SLAEvent

setActualDuration

public void setActualDuration(long actualDuration)

getJobStatus

public String getJobStatus()

Specified by:

getJobStatus in class SLAEvent

setJobStatus

public void setJobStatus(String status)

getSLAStatus

public SLAEvent.SLAStatus getSLAStatus()

Specified by:

getSLAStatus in class SLAEvent

setSLAStatus

public void setSLAStatus(SLAEvent.SLAStatus slaStatus)

getEventStatus

public SLAEvent.EventStatus getEventStatus()

Specified by:

getEventStatus in class SLAEvent

setEventStatus

public void setEventStatus(SLAEvent.EventStatus es)

setLastModifiedTime

public void setLastModifiedTime(Date lastModifiedTime)

getEventProcessed

public byte getEventProcessed()

Get which type of sla event has been processed needed when calculator periodically loops to update all jobs' sla

Returns:

byte 1st bit set (from LSB) = start processed 2nd bit set = duration processed 3rd bit set = end processed only 4th bit set = everything processed

setEventProcessed

public void setEventProcessed(int eventProcessed)

getParentId

public String getParentId()

Specified by:

getParentId in class SLAEvent

getAppType

public AppType getAppType()

Specified by:

getAppType in class SLAEvent

getAppName

public String getAppName()

Specified by:

getAppName in class SLAEvent

getNominalTime

public Date getNominalTime()

Specified by:

getNominalTime in class SLAEvent

getExpectedStart

public Date getExpectedStart()

Specified by:

getExpectedStart in class SLAEvent

getExpectedEnd

public Date getExpectedEnd()

Specified by:

getExpectedEnd in class SLAEvent

getExpectedDuration

public long getExpectedDuration()

Specified by:

getExpectedDuration in class SLAEvent

getNotificationMsg

public String getNotificationMsg()

Specified by:

getNotificationMsg in class SLAEvent

getAlertEvents

public String getAlertEvents()

Specified by:

getAlertEvents in class SLAEvent

getAlertContact

public String getAlertContact()

Specified by:

getAlertContact in class SLAEvent

getUpstreamApps

public String getUpstreamApps()

Specified by:

getUpstreamApps in class SLAEvent

getJobData

public String getJobData()

Specified by:

getJobData in class SLAEvent

getUser

public String getUser()

Specified by:

getUser in class SLAEvent

getSLAConfig

public String getSLAConfig()

Specified by:

getSLAConfig in class SLAEvent

getSLAConfigMap

public Map<String,String> getSLAConfigMap()

getMsgType

public Event.MessageType getMsgType()

Overrides:

getMsgType in class SLAEvent

getLastModifiedTime

public Date getLastModifiedTime()

Specified by:

getLastModifiedTime in class SLAEvent

getEntityKey

public String getEntityKey()

acquireLock

public void acquireLock()
                 throws InterruptedException

Obtain an exclusive lock on the {link #getEntityKey}.

A timeout of {link #getLockTimeOut} is used when trying to obtain the lock.

Throws:

InterruptedException - thrown if an interruption happened while trying to obtain the lock

isLocked

public boolean isLocked()

releaseLock

public void releaseLock()

getLockTimeOut

public long getLockTimeOut()