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 org.apache.oozie.client.event.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

org.apache.oozie.client.event.SLAEvent.EventStatus, org.apache.oozie.client.event.SLAEvent.SLAStatus

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

org.apache.oozie.client.event.Event.MessageType

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.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()
java.util.Date	getActualEnd()
java.util.Date	getActualStart()
java.lang.String	getAlertContact()
java.lang.String	getAlertEvents()
java.lang.String	getAppName()
org.apache.oozie.AppType	getAppType()
java.lang.String	getEntityKey()
byte	getEventProcessed() Get which type of sla event has been processed needed when calculator periodically loops to update all jobs' sla
org.apache.oozie.client.event.SLAEvent.EventStatus	getEventStatus()
long	getExpectedDuration()
java.util.Date	getExpectedEnd()
java.util.Date	getExpectedStart()
java.lang.String	getId()
java.lang.String	getJobData()
java.lang.String	getJobStatus()
java.util.Date	getLastModifiedTime()
long	getLockTimeOut()
org.apache.oozie.client.event.Event.MessageType	getMsgType()
java.util.Date	getNominalTime()
java.lang.String	getNotificationMsg()
java.lang.String	getParentId()
java.lang.String	getSlaConfig()
SLARegistrationBean	getSLARegistrationBean()
org.apache.oozie.client.event.SLAEvent.SLAStatus	getSLAStatus()
java.lang.String	getUpstreamApps()
java.lang.String	getUser()
boolean	isLocked()
void	releaseLock()
void	setActualDuration(long actualDuration)
void	setActualEnd(java.util.Date actualEnd)
void	setActualStart(java.util.Date actualStart)
void	setEventProcessed(int eventProcessed)
void	setEventStatus(org.apache.oozie.client.event.SLAEvent.EventStatus es)
void	setId(java.lang.String id)
void	setJobStatus(java.lang.String status)
void	setLastModifiedTime(java.util.Date lastModifiedTime)
void	setSLARegistrationBean(SLARegistrationBean slaBean)
void	setSLAStatus(org.apache.oozie.client.event.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 java.lang.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 java.lang.String getId()

Specified by:

getId in class org.apache.oozie.client.event.SLAEvent

setId

public void setId(java.lang.String id)

getActualStart

public java.util.Date getActualStart()

Specified by:

getActualStart in class org.apache.oozie.client.event.SLAEvent

setActualStart

public void setActualStart(java.util.Date actualStart)

getActualEnd

public java.util.Date getActualEnd()

Specified by:

getActualEnd in class org.apache.oozie.client.event.SLAEvent

setActualEnd

public void setActualEnd(java.util.Date actualEnd)

getActualDuration

public long getActualDuration()

Specified by:

getActualDuration in class org.apache.oozie.client.event.SLAEvent

setActualDuration

public void setActualDuration(long actualDuration)

getJobStatus

public java.lang.String getJobStatus()

Specified by:

getJobStatus in class org.apache.oozie.client.event.SLAEvent

setJobStatus

public void setJobStatus(java.lang.String status)

getSLAStatus

public org.apache.oozie.client.event.SLAEvent.SLAStatus getSLAStatus()

Specified by:

getSLAStatus in class org.apache.oozie.client.event.SLAEvent

setSLAStatus

public void setSLAStatus(org.apache.oozie.client.event.SLAEvent.SLAStatus slaStatus)

getEventStatus

public org.apache.oozie.client.event.SLAEvent.EventStatus getEventStatus()

Specified by:

getEventStatus in class org.apache.oozie.client.event.SLAEvent

setEventStatus

public void setEventStatus(org.apache.oozie.client.event.SLAEvent.EventStatus es)

setLastModifiedTime

public void setLastModifiedTime(java.util.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 java.lang.String getParentId()

Specified by:

getParentId in class org.apache.oozie.client.event.SLAEvent

getAppType

public org.apache.oozie.AppType getAppType()

Specified by:

getAppType in class org.apache.oozie.client.event.SLAEvent

getAppName

public java.lang.String getAppName()

Specified by:

getAppName in class org.apache.oozie.client.event.SLAEvent

getNominalTime

public java.util.Date getNominalTime()

Specified by:

getNominalTime in class org.apache.oozie.client.event.SLAEvent

getExpectedStart

public java.util.Date getExpectedStart()

Specified by:

getExpectedStart in class org.apache.oozie.client.event.SLAEvent

getExpectedEnd

public java.util.Date getExpectedEnd()

Specified by:

getExpectedEnd in class org.apache.oozie.client.event.SLAEvent

getExpectedDuration

public long getExpectedDuration()

Specified by:

getExpectedDuration in class org.apache.oozie.client.event.SLAEvent

getNotificationMsg

public java.lang.String getNotificationMsg()

Specified by:

getNotificationMsg in class org.apache.oozie.client.event.SLAEvent

getAlertEvents

public java.lang.String getAlertEvents()

Specified by:

getAlertEvents in class org.apache.oozie.client.event.SLAEvent

getAlertContact

public java.lang.String getAlertContact()

Specified by:

getAlertContact in class org.apache.oozie.client.event.SLAEvent

getUpstreamApps

public java.lang.String getUpstreamApps()

Specified by:

getUpstreamApps in class org.apache.oozie.client.event.SLAEvent

getJobData

public java.lang.String getJobData()

Specified by:

getJobData in class org.apache.oozie.client.event.SLAEvent

getUser

public java.lang.String getUser()

Specified by:

getUser in class org.apache.oozie.client.event.SLAEvent

getSlaConfig

public java.lang.String getSlaConfig()

Specified by:

getSlaConfig in class org.apache.oozie.client.event.SLAEvent

getMsgType

public org.apache.oozie.client.event.Event.MessageType getMsgType()

Overrides:

getMsgType in class org.apache.oozie.client.event.SLAEvent

getLastModifiedTime

public java.util.Date getLastModifiedTime()

Specified by:

getLastModifiedTime in class org.apache.oozie.client.event.SLAEvent

getEntityKey

public java.lang.String getEntityKey()

acquireLock

public void acquireLock()
                 throws java.lang.InterruptedException

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

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

Throws:

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

isLocked

public boolean isLocked()

releaseLock

public void releaseLock()

getLockTimeOut

public long getLockTimeOut()