org.apache.oozie
Class CoordinatorJobBean

java.lang.Object
  org.apache.oozie.client.rest.JsonCoordinatorJob
      org.apache.oozie.CoordinatorJobBean

All Implemented Interfaces:

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

@Entity
public class CoordinatorJobBean
extends JsonCoordinatorJob
implements org.apache.hadoop.io.Writable

Nested Class Summary

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

org.apache.oozie.client.CoordinatorJob.Execution, org.apache.oozie.client.CoordinatorJob.Timeunit

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

org.apache.oozie.client.Job.Status

Constructor Summary

CoordinatorJobBean()

Method Summary

String	getAppNamespace() Get app namespce
String	getAuthToken() Get auth token
Date	getCreatedTime() Get created time
Timestamp	getCreatedTimestamp() Get created timestamp
Date	getEndTime()
Timestamp	getEndTimestamp() Get end timestamp
String	getExecution() Get execution
org.apache.oozie.client.CoordinatorJob.Execution	getExecutionOrder()
String	getJobXml() Get job xml
Date	getLastActionTime()
Timestamp	getLastActionTimestamp() Get last action timestamp
Date	getLastModifiedTime() Get last modified time
Timestamp	getLastModifiedTimestamp() Get last modified timestamp
Date	getNextMaterializedTime()
Timestamp	getNextMaterializedTimestamp() Get next materialized timestamp
String	getOrigJobXml() Get original job xml
Date	getPauseTime()
String	getSlaXml() Get sla xml
Date	getStartTime()
Timestamp	getStartTimestamp() Get start timestamp
org.apache.oozie.client.Job.Status	getStatus()
String	getStatusStr() Get status
Date	getSuspendedTime() Get suspended time
Timestamp	getSuspendedTimestamp() Get suspended timestamp
org.apache.oozie.client.CoordinatorJob.Timeunit	getTimeUnit()
String	getTimeUnitStr() Get time unit
boolean	isDoneMaterialization() Return if the action is done with materialization
boolean	isPending() Return if the action is pending.
void	readFields(DataInput dataInput) Deserialize a coordinator bean from a data input.
void	resetDoneMaterialization() Set doneMaterialization to false
void	resetPending() Set pending to false
void	setAppNamespace(String appNamespace) Set app namespce
void	setAuthToken(String authToken) Set auth token
void	setCreatedTime(Date createTime) Set created time
void	setDoneMaterialization() Set doneMaterialization to true
void	setEndTime(Date endTime)
void	setEndTimestamp(Timestamp endTimestamp) Set end timestamp
void	setExecution(org.apache.oozie.client.CoordinatorJob.Execution order) Set order
void	setJobXml(String jobXml) Set job xml
void	setLastActionTime(Date lastAction)
void	setLastActionTimestamp(Timestamp lastActionTimestamp) Set last action timestamp
void	setLastModifiedTime(Date lastModifiedTime) Set last modified time
void	setLastModifiedTimestamp(Timestamp lastModifiedTimestamp) Set last modified timestamp
void	setNextMaterializedTime(Date nextMaterializedTime)
void	setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp) Set next materialized timestamp
void	setOrigJobXml(String origJobXml) Set original job xml
void	setPauseTime(Date pauseTime)
void	setPending() Set pending to true
void	setSlaXml(String slaXml) Set sla xml
void	setStartTime(Date startTime)
void	setStartTimestamp(Timestamp startTimestamp) Set start timestamp
void	setStatus(org.apache.oozie.client.Job.Status val)
void	setSuspendedTime(Date suspendedTime) Set suspended time
void	setSuspendedTimestamp(Timestamp suspendedTimestamp) Set suspended timestamp
void	setTimeUnit(org.apache.oozie.client.CoordinatorJob.Timeunit timeUnit)
void	write(DataOutput dataOutput)

Methods inherited from class org.apache.oozie.client.rest.JsonCoordinatorJob

getAcl, getActions, getAppName, getAppPath, getBundleId, getConcurrency, getConf, getConsoleUrl, getExternalId, getFrequency, getGroup, getId, getLastActionNumber, getMatThrottling, getTimeout, getTimeZone, getUser, setActions, setAppName, setAppPath, setBundleId, setConcurrency, setConf, setConsoleUrl, setExecutionOrder, setExternalId, setFrequency, setGroup, setId, setLastActionNumber, setMatThrottling, setTimeout, setTimeZone, setUser, toJSONArray, toJSONObject, toJSONObject, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatorJobBean

public CoordinatorJobBean()

Method Detail

getStartTimestamp

public Timestamp getStartTimestamp()

Get start timestamp

Returns:

start timestamp

setStartTimestamp

public void setStartTimestamp(Timestamp startTimestamp)

Set start timestamp

Parameters:

startTimestamp - start timestamp

getEndTimestamp

public Timestamp getEndTimestamp()

Get end timestamp

Returns:

end timestamp

setEndTimestamp

public void setEndTimestamp(Timestamp endTimestamp)

Set end timestamp

Parameters:

endTimestamp - end timestamp

getNextMaterializedTimestamp

public Timestamp getNextMaterializedTimestamp()

Get next materialized timestamp

Returns:

next materialized timestamp

setNextMaterializedTimestamp

public void setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp)

Set next materialized timestamp

Parameters:

nextMaterializedTimestamp - next materialized timestamp

getLastModifiedTimestamp

public Timestamp getLastModifiedTimestamp()

Get last modified timestamp

Returns:

last modified timestamp

setLastModifiedTimestamp

public void setLastModifiedTimestamp(Timestamp lastModifiedTimestamp)

Set last modified timestamp

Parameters:

lastModifiedTimestamp - last modified timestamp

getSuspendedTimestamp

public Timestamp getSuspendedTimestamp()

Get suspended timestamp

Returns:

suspended timestamp

setSuspendedTimestamp

public void setSuspendedTimestamp(Timestamp suspendedTimestamp)

Set suspended timestamp

Parameters:

suspendedTimestamp - suspended timestamp

getJobXml

public String getJobXml()

Get job xml

Returns:

job xml

setJobXml

public void setJobXml(String jobXml)

Set job xml

Parameters:

jobXml - job xml

getOrigJobXml

public String getOrigJobXml()

Get original job xml

Returns:

original job xml

setOrigJobXml

public void setOrigJobXml(String origJobXml)

Set original job xml

Parameters:

origJobXml -

getSlaXml

public String getSlaXml()

Get sla xml

Returns:

sla xml

setSlaXml

public void setSlaXml(String slaXml)

Set sla xml

Parameters:

slaXml - sla xml

setTimeUnit

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

Overrides:

setTimeUnit in class JsonCoordinatorJob

setLastActionTimestamp

public void setLastActionTimestamp(Timestamp lastActionTimestamp)

Set last action timestamp

Parameters:

lastActionTimestamp - last action timestamp

setAuthToken

public void setAuthToken(String authToken)

Set auth token

Parameters:

authToken - auth token

setPending

public void setPending()

Set pending to true

Specified by:

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

Overrides:

setPending in class JsonCoordinatorJob

resetPending

public void resetPending()

Set pending to false

Specified by:

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

Overrides:

resetPending in class JsonCoordinatorJob

isPending

public boolean isPending()

Return if the action is pending.

Returns:

if the action is pending.

setDoneMaterialization

public void setDoneMaterialization()

Set doneMaterialization to true

resetDoneMaterialization

public void resetDoneMaterialization()

Set doneMaterialization to false

isDoneMaterialization

public boolean isDoneMaterialization()

Return if the action is done with materialization

Returns:

if the action is done with materialization

getAppNamespace

public String getAppNamespace()

Get app namespce

Returns:

app namespce

setAppNamespace

public void setAppNamespace(String appNamespace)

Set app namespce

Parameters:

appNamespace - the app namespce to set

write

public void write(DataOutput dataOutput)
           throws IOException

Specified by:

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

Throws:

IOException

readFields

public void readFields(DataInput dataInput)
                throws IOException

Deserialize a coordinator bean from a data input.

Specified by:

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

Parameters:

dataInput - data input.

Throws:

IOException - thrown if the workflow bean could not be deserialized.

getStatus

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

Specified by:

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

Specified by:

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

Overrides:

getStatus in class JsonCoordinatorJob

getStatusStr

public String getStatusStr()

Get status

Returns:

status

setStatus

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

Specified by:

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

Overrides:

setStatus in class JsonCoordinatorJob

getTimeUnitStr

public String getTimeUnitStr()

Get time unit

Returns:

time unit

getTimeUnit

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

Specified by:

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

Overrides:

getTimeUnit in class JsonCoordinatorJob

setExecution

public void setExecution(org.apache.oozie.client.CoordinatorJob.Execution order)

Set order

Parameters:

order -

getExecutionOrder

public org.apache.oozie.client.CoordinatorJob.Execution getExecutionOrder()

Specified by:

getExecutionOrder in interface org.apache.oozie.client.CoordinatorJob

Overrides:

getExecutionOrder in class JsonCoordinatorJob

getExecution

public String getExecution()

Get execution

Returns:

execution

setLastActionTime

public void setLastActionTime(Date lastAction)

Overrides:

setLastActionTime in class JsonCoordinatorJob

getLastActionTime

public Date getLastActionTime()

Specified by:

getLastActionTime in interface org.apache.oozie.client.CoordinatorJob

Overrides:

getLastActionTime in class JsonCoordinatorJob

getLastActionTimestamp

public Timestamp getLastActionTimestamp()

Get last action timestamp

Returns:

last action timestamp

setNextMaterializedTime

public void setNextMaterializedTime(Date nextMaterializedTime)

Overrides:

setNextMaterializedTime in class JsonCoordinatorJob

getNextMaterializedTime

public Date getNextMaterializedTime()

Specified by:

getNextMaterializedTime in interface org.apache.oozie.client.CoordinatorJob

Overrides:

getNextMaterializedTime in class JsonCoordinatorJob

setLastModifiedTime

public void setLastModifiedTime(Date lastModifiedTime)

Set last modified time

Parameters:

lastModifiedTime - last modified time

getLastModifiedTime

public Date getLastModifiedTime()

Get last modified time

Returns:

last modified time

setSuspendedTime

public void setSuspendedTime(Date suspendedTime)

Set suspended time

Parameters:

suspendedTime - suspended time

getSuspendedTime

public Date getSuspendedTime()

Get suspended time

Returns:

suspended time

setStartTime

public void setStartTime(Date startTime)

Overrides:

setStartTime in class JsonCoordinatorJob

getStartTime

public Date getStartTime()

Specified by:

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

Specified by:

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

Overrides:

getStartTime in class JsonCoordinatorJob

setEndTime

public void setEndTime(Date endTime)

Overrides:

setEndTime in class JsonCoordinatorJob

setPauseTime

public void setPauseTime(Date pauseTime)

Overrides:

setPauseTime in class JsonCoordinatorJob

getEndTime

public Date getEndTime()

Specified by:

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

Specified by:

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

Overrides:

getEndTime in class JsonCoordinatorJob

getPauseTime

public Date getPauseTime()

Specified by:

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

Overrides:

getPauseTime in class JsonCoordinatorJob

setCreatedTime

public void setCreatedTime(Date createTime)

Set created time

Parameters:

createTime - created time

getCreatedTime

public Date getCreatedTime()

Get created time

Returns:

created time

getCreatedTimestamp

public Timestamp getCreatedTimestamp()

Get created timestamp

Returns:

created timestamp

getAuthToken

public String getAuthToken()

Get auth token

Returns:

auth token