org.apache.oozie
Class CoordinatorJobBean

java.lang.Object
  extended by org.apache.oozie.client.rest.JsonCoordinatorJob
      extended by 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, 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


Copyright © 2012 Apache Software Foundation. All Rights Reserved.