org.apache.oozie

Class BundleJobBean

java.lang.Object

org.apache.oozie.BundleJobBean

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.oozie.client.BundleJob, org.apache.oozie.client.Job, JsonBean

@Entity
public class BundleJobBean
extends java.lang.Object
implements org.apache.hadoop.io.Writable, org.apache.oozie.client.BundleJob, JsonBean

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.oozie.client.BundleJob

org.apache.oozie.client.BundleJob.Timeunit

Nested classes/interfaces inherited from interface org.apache.oozie.client.Job

org.apache.oozie.client.Job.Status

Constructor Summary

Constructors

Constructor and Description
BundleJobBean()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getAcl()
java.lang.String	getAppName()
java.lang.String	getAppPath()
java.lang.String	getConf()
StringBlob	getConfBlob()
java.lang.String	getConsoleUrl()
java.util.List<org.apache.oozie.client.CoordinatorJob>	getCoordinators()
java.util.Date	getCreatedTime()
java.sql.Timestamp	getCreatedTimestamp()
java.util.Date	getEndTime()
java.sql.Timestamp	getEndTimestamp()
java.lang.String	getExternalId() Return externalId
java.lang.String	getGroup() Deprecated.
java.lang.String	getId()
java.lang.String	getJobXml()
StringBlob	getJobXmlBlob()
java.util.Date	getKickoffTime()
java.sql.Timestamp	getKickoffTimestamp()
java.util.Date	getLastModifiedTime() Get last modified time
java.sql.Timestamp	getLastModifiedTimestamp()
java.lang.String	getOrigJobXml()
StringBlob	getOrigJobXmlBlob()
java.util.Date	getPauseTime()
java.sql.Timestamp	getPauseTimestamp()
int	getPending()
java.util.Date	getStartTime()
java.sql.Timestamp	getstartTimestamp()
org.apache.oozie.client.Job.Status	getStatus()
java.lang.String	getStatusStr()
java.sql.Timestamp	getSuspendedTimestamp()
int	getTimeout()
org.apache.oozie.client.BundleJob.Timeunit	getTimeUnit()
java.lang.String	getTimeUnitStr()
java.lang.String	getUser()
boolean	isPending() Return if the action is pending.
boolean	isTerminalStatus()
void	readFields(java.io.DataInput dataInput)
void	resetPending() Set pending to false
void	setAppName(java.lang.String bundleName) Set bundleName
void	setAppPath(java.lang.String bundlePath) Set bundlePath
void	setConf(java.lang.String conf) Set conf
void	setConfBlob(StringBlob conf)
void	setConsoleUrl(java.lang.String consoleUrl) Set consoleUrl
void	setCoordJobs(java.util.List<CoordinatorJobBean> coordJobs) Set coordJobs
void	setCreatedTime(java.util.Date createTime)
void	setEndTime(java.util.Date endTime)
void	setEndTimestamp(java.sql.Timestamp endTimestamp)
void	setExternalId(java.lang.String externalId) Set externalId
void	setGroup(java.lang.String group) Set group
void	setId(java.lang.String id) Set id
void	setJobXml(java.lang.String jobXml)
void	setJobXmlBlob(StringBlob jobXmlBlob)
void	setKickoffTime(java.util.Date kickoffTime)
void	setKickoffTimestamp(java.sql.Timestamp kickoffTimestamp)
void	setLastModifiedTime(java.util.Date lastModifiedTime)
void	setLastModifiedTimestamp(java.sql.Timestamp lastModifiedTimestamp)
void	setOrigJobXml(java.lang.String origJobXml)
void	setOrigJobXmlBlob(StringBlob origJobXml)
void	setPauseTime(java.util.Date pauseTime)
void	setPauseTimestamp(java.sql.Timestamp pauseTimestamp)
void	setPending() Set pending to true
void	setPending(int i) Set pending value
void	setStartTime(java.util.Date startTime) Set startTime
void	setStartTimestamp(java.sql.Timestamp startTimestamp)
void	setStatus(org.apache.oozie.client.Job.Status status) Set status
void	setStatus(java.lang.String statusStr) Set status
void	setSuspendedTime(java.util.Date suspendTime)
void	setSuspendedTimestamp(java.sql.Timestamp suspendedTimestamp)
void	setTimeOut(int timeOut) Set timeOut
void	setTimeUnit(org.apache.oozie.client.BundleJob.Timeunit timeUnit) Set timeUnit
void	setUser(java.lang.String user) Set user
static org.json.simple.JSONArray	toJSONArray(java.util.List<BundleJobBean> applications, java.lang.String timeZoneId) Convert a Bundle job list into a JSONArray.
org.json.simple.JSONObject	toJSONObject() Return the JSONObject for the bean with GMT time zone.
org.json.simple.JSONObject	toJSONObject(java.lang.String timeZoneId) Return the JSONObject for the bean with the given time zone.
java.lang.String	toString()
void	write(java.io.DataOutput dataOutput)

Methods inherited from class java.lang.Object

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

Constructor Detail

BundleJobBean

public BundleJobBean()

Method Detail

getKickoffTimestamp

public java.sql.Timestamp getKickoffTimestamp()

Returns:

the kickoffTimestamp

getstartTimestamp

public java.sql.Timestamp getstartTimestamp()

Returns:

the startTimestamp

setKickoffTimestamp

public void setKickoffTimestamp(java.sql.Timestamp kickoffTimestamp)

Parameters:

kickoffTimestamp - the kickoffTimestamp to set

setStartTimestamp

public void setStartTimestamp(java.sql.Timestamp startTimestamp)

Parameters:

startTimestamp - the startTimestamp to set

setStartTime

public void setStartTime(java.util.Date startTime)

Set startTime

Parameters:

startTime - the startTime to set

getEndTimestamp

public java.sql.Timestamp getEndTimestamp()

Returns:

the endTimestamp

setEndTimestamp

public void setEndTimestamp(java.sql.Timestamp endTimestamp)

Parameters:

endTimestamp - the endTimestamp to set

getPauseTimestamp

public java.sql.Timestamp getPauseTimestamp()

Returns:

the pauseTimestamp

setPauseTimestamp

public void setPauseTimestamp(java.sql.Timestamp pauseTimestamp)

Parameters:

pauseTimestamp - the pauseTimestamp to set

getCreatedTimestamp

public java.sql.Timestamp getCreatedTimestamp()

Returns:

the createdTimestamp

getCreatedTime

public java.util.Date getCreatedTime()

Specified by:

getCreatedTime in interface org.apache.oozie.client.BundleJob

Returns:

the createdTime

getTimeUnitStr

public java.lang.String getTimeUnitStr()

Returns:

the timeUnitStr

getPending

public int getPending()

Returns:

the pending

setPending

public void setPending()

Set pending to true

Specified by:

setPending in interface org.apache.oozie.client.Job

Parameters:

pending - set pending to true

setPending

public void setPending(int i)

Set pending value

Parameters:

pending - set pending value

resetPending

public void resetPending()

Set pending to false

Specified by:

resetPending in interface org.apache.oozie.client.Job

Parameters:

pending - set pending to false

isPending

public boolean isPending()

Return if the action is pending.

Returns:

if the action is pending.

getLastModifiedTimestamp

public java.sql.Timestamp getLastModifiedTimestamp()

Returns:

the lastModifiedTimestamp

setLastModifiedTimestamp

public void setLastModifiedTimestamp(java.sql.Timestamp lastModifiedTimestamp)

Parameters:

lastModifiedTimestamp - the lastModifiedTimestamp to set

getSuspendedTimestamp

public java.sql.Timestamp getSuspendedTimestamp()

Returns:

the suspendedTimestamp

setSuspendedTimestamp

public void setSuspendedTimestamp(java.sql.Timestamp suspendedTimestamp)

Parameters:

suspendedTimestamp - the suspendedTimestamp to set

getJobXml

public java.lang.String getJobXml()

Returns:

the jobXml

setJobXml

public void setJobXml(java.lang.String jobXml)

Parameters:

jobXml - the jobXml to set

setJobXmlBlob

public void setJobXmlBlob(StringBlob jobXmlBlob)

getJobXmlBlob

public StringBlob getJobXmlBlob()

getOrigJobXml

public java.lang.String getOrigJobXml()

Returns:

the origJobXml

setOrigJobXml

public void setOrigJobXml(java.lang.String origJobXml)

Parameters:

origJobXml - the origJobXml to set

setOrigJobXmlBlob

public void setOrigJobXmlBlob(StringBlob origJobXml)

getOrigJobXmlBlob

public StringBlob getOrigJobXmlBlob()

setCreatedTime

public void setCreatedTime(java.util.Date createTime)

Parameters:

createTime - the createdTime to set

setLastModifiedTime

public void setLastModifiedTime(java.util.Date lastModifiedTime)

Parameters:

lastModifiedTime -

getLastModifiedTime

public java.util.Date getLastModifiedTime()

Get last modified time

Returns:

last modified time

write

public void write(java.io.DataOutput dataOutput)
           throws java.io.IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

readFields

public void readFields(java.io.DataInput dataInput)
                throws java.io.IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

getEndTime

public java.util.Date getEndTime()

Specified by:

getEndTime in interface org.apache.oozie.client.Job

getKickoffTime

public java.util.Date getKickoffTime()

Specified by:

getKickoffTime in interface org.apache.oozie.client.BundleJob

getTimeUnit

public org.apache.oozie.client.BundleJob.Timeunit getTimeUnit()

Specified by:

getTimeUnit in interface org.apache.oozie.client.BundleJob

setEndTime

public void setEndTime(java.util.Date endTime)

setKickoffTime

public void setKickoffTime(java.util.Date kickoffTime)

getPauseTime

public java.util.Date getPauseTime()

Specified by:

getPauseTime in interface org.apache.oozie.client.Job

setPauseTime

public void setPauseTime(java.util.Date pauseTime)

setSuspendedTime

public void setSuspendedTime(java.util.Date suspendTime)

Parameters:

return - the suspendTime

toJSONObject

public org.json.simple.JSONObject toJSONObject()

Description copied from interface: JsonBean

Return the JSONObject for the bean with GMT time zone.

Specified by:

toJSONObject in interface JsonBean

Returns:

the JSONObject for the bean with GMT time zone.

toJSONObject

public org.json.simple.JSONObject toJSONObject(java.lang.String timeZoneId)

Description copied from interface: JsonBean

Return the JSONObject for the bean with the given time zone.

Specified by:

toJSONObject in interface JsonBean

Parameters:

timeZoneId - the time zone to use

Returns:

the JSONObject for the bean with the given time zone.

getAppName

public java.lang.String getAppName()

Specified by:

getAppName in interface org.apache.oozie.client.Job

getAppPath

public java.lang.String getAppPath()

Specified by:

getAppPath in interface org.apache.oozie.client.Job

getConf

public java.lang.String getConf()

Specified by:

getConf in interface org.apache.oozie.client.Job

getConsoleUrl

public java.lang.String getConsoleUrl()

Specified by:

getConsoleUrl in interface org.apache.oozie.client.Job

getCoordinators

public java.util.List<org.apache.oozie.client.CoordinatorJob> getCoordinators()

Specified by:

getCoordinators in interface org.apache.oozie.client.BundleJob

getGroup

@Deprecated
public java.lang.String getGroup()

Deprecated.

Specified by:

getGroup in interface org.apache.oozie.client.Job

getAcl

public java.lang.String getAcl()

Specified by:

getAcl in interface org.apache.oozie.client.Job

getId

public java.lang.String getId()

Specified by:

getId in interface org.apache.oozie.client.Job

getTimeout

public int getTimeout()

Specified by:

getTimeout in interface org.apache.oozie.client.BundleJob

getUser

public java.lang.String getUser()

Specified by:

getUser in interface org.apache.oozie.client.Job

setId

public void setId(java.lang.String id)

Set id

Parameters:

id - the id to set

setAppPath

public void setAppPath(java.lang.String bundlePath)

Set bundlePath

Parameters:

bundlePath - the bundlePath to set

setAppName

public void setAppName(java.lang.String bundleName)

Set bundleName

Parameters:

bundleName - the bundleName to set

getExternalId

public java.lang.String getExternalId()

Return externalId

Specified by:

getExternalId in interface org.apache.oozie.client.Job

Returns:

externalId

setExternalId

public void setExternalId(java.lang.String externalId)

Set externalId

Parameters:

externalId - the externalId to set

setConf

public void setConf(java.lang.String conf)

Set conf

Parameters:

conf - the conf to set

setConfBlob

public void setConfBlob(StringBlob conf)

getConfBlob

public StringBlob getConfBlob()

setStatus

public void setStatus(org.apache.oozie.client.Job.Status status)

Set status

Specified by:

setStatus in interface org.apache.oozie.client.Job

Parameters:

status - the status to set

getStatus

public org.apache.oozie.client.Job.Status getStatus()

Specified by:

getStatus in interface org.apache.oozie.client.Job

setStatus

public void setStatus(java.lang.String statusStr)

Set status

Parameters:

status - the status to set

getStatusStr

public java.lang.String getStatusStr()

Returns:

status string

setTimeUnit

public void setTimeUnit(org.apache.oozie.client.BundleJob.Timeunit timeUnit)

Set timeUnit

Parameters:

timeUnit - the timeUnit to set

setTimeOut

public void setTimeOut(int timeOut)

Set timeOut

Parameters:

timeOut - the timeOut to set

setUser

public void setUser(java.lang.String user)

Set user

Parameters:

user - the user to set

setGroup

public void setGroup(java.lang.String group)

Set group

Parameters:

group - the group to set

setConsoleUrl

public void setConsoleUrl(java.lang.String consoleUrl)

Set consoleUrl

Parameters:

consoleUrl - the consoleUrl to set

setCoordJobs

public void setCoordJobs(java.util.List<CoordinatorJobBean> coordJobs)

Set coordJobs

Parameters:

coordJobs - the coordJobs to set

toJSONArray

public static org.json.simple.JSONArray toJSONArray(java.util.List<BundleJobBean> applications,
                                    java.lang.String timeZoneId)

Convert a Bundle job list into a JSONArray.

Parameters:

application - list.

timeZoneId - time zone to use for dates in the JSON array.

Returns:

the corresponding JSON array.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getStartTime

public java.util.Date getStartTime()

Specified by:

getStartTime in interface org.apache.oozie.client.Job

isTerminalStatus

public boolean isTerminalStatus()

Returns:

true if in terminal status