@Entity public class CoordinatorJobBean extends Object implements org.apache.hadoop.io.Writable, org.apache.oozie.client.CoordinatorJob, JsonBean
| Constructor and Description |
|---|
CoordinatorJobBean() |
| Modifier and Type | Method and Description |
|---|---|
String |
getAcl() |
List<org.apache.oozie.client.CoordinatorAction> |
getActions() |
String |
getAppName() |
String |
getAppNamespace()
Get app namespce
|
String |
getAppPath() |
String |
getBundleId() |
int |
getConcurrency() |
String |
getConf() |
StringBlob |
getConfBlob() |
String |
getConsoleUrl()
Return the coordinate application console URL.
|
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 |
getExternalId() |
String |
getFrequency() |
String |
getGroup() |
String |
getId() |
String |
getJobXml()
Get job xml
|
StringBlob |
getJobXmlBlob() |
int |
getLastActionNumber() |
Date |
getLastActionTime() |
Timestamp |
getLastActionTimestamp()
Get last action timestamp
|
Date |
getLastModifiedTime()
Get last modified time
|
Timestamp |
getLastModifiedTimestamp()
Get last modified timestamp
|
int |
getMatThrottling() |
Date |
getNextMaterializedTime() |
Timestamp |
getNextMaterializedTimestamp()
Get next materialized timestamp
|
int |
getNumActions() |
String |
getOrigJobXml()
Get original job xml
|
StringBlob |
getOrigJobXmlBlob() |
Date |
getPauseTime() |
Timestamp |
getPauseTimestamp() |
String |
getSlaXml()
Get sla xml
|
StringBlob |
getSlaXmlBlob() |
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
|
int |
getTimeout() |
org.apache.oozie.client.CoordinatorJob.Timeunit |
getTimeUnit() |
String |
getTimeUnitStr()
Get time unit
|
String |
getTimeZone() |
String |
getUser() |
boolean |
isDoneMaterialization()
Return if the action is done with materialization
|
boolean |
isPending()
Return if the action is pending.
|
boolean |
isTerminalStatus() |
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 |
setActions(List<CoordinatorActionBean> nodes) |
void |
setAppName(String appName) |
void |
setAppNamespace(String appNamespace)
Set app namespce
|
void |
setAppPath(String appPath) |
void |
setBundleId(String bundleId) |
void |
setConcurrency(int concurrency) |
void |
setConf(String conf) |
void |
setConfBlob(StringBlob conf) |
void |
setConsoleUrl(String consoleUrl)
Set the coordinate application console URL.
|
void |
setCreatedTime(Date createTime)
Set created time
|
void |
setDoneMaterialization()
Set doneMaterialization to true
|
void |
setDoneMaterialization(int i)
Set doneMaterialization
|
void |
setEndTime(Date endTime) |
void |
setEndTimestamp(Timestamp endTimestamp)
Set end timestamp
|
void |
setExecution(String order)
Get execution
|
void |
setExecutionOrder(org.apache.oozie.client.CoordinatorJob.Execution order)
Set order
|
void |
setExternalId(String externalId) |
void |
setFrequency(String frequency) |
void |
setGroup(String group) |
void |
setId(String id) |
void |
setJobXml(String jobXml)
Set job xml
|
void |
setJobXmlBlob(StringBlob jobXmlBlob) |
void |
setLastActionNumber(int lastActionNumber) |
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 |
setMatThrottling(int matThrottling) |
void |
setNextMaterializedTime(Date nextMaterializedTime) |
void |
setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp)
Set next materialized timestamp
|
void |
setNumActions(int numAction) |
void |
setOrigJobXml(String origJobXml)
Set original job xml
|
void |
setOrigJobXmlBlob(StringBlob origJobXml) |
void |
setPauseTime(Date pauseTime) |
void |
setPending()
Set pending to true
|
void |
setSlaXml(String slaXml)
Set sla xml
|
void |
setSlaXmlBlob(StringBlob slaXml) |
void |
setStartTime(Date startTime) |
void |
setStartTimestamp(Timestamp startTimestamp)
Set start timestamp
|
void |
setStatus(org.apache.oozie.client.Job.Status val) |
void |
setStatusStr(String status)
Get status
|
void |
setSuspendedTime(Date suspendedTime)
Set suspended time
|
void |
setSuspendedTimestamp(Timestamp suspendedTimestamp)
Set suspended timestamp
|
void |
setTimeout(int timeOut) |
void |
setTimeUnit(org.apache.oozie.client.CoordinatorJob.Timeunit timeUnit) |
void |
setTimeUnitStr(String timeunit)
Set time unit
|
void |
setTimeZone(String timeZone) |
void |
setUser(String user) |
static org.json.simple.JSONArray |
toJSONArray(List<CoordinatorJobBean> applications,
String timeZoneId)
Convert a coordinator application list into a JSONArray.
|
org.json.simple.JSONObject |
toJSONObject()
Return the JSONObject for the bean with GMT time zone.
|
org.json.simple.JSONObject |
toJSONObject(String timeZoneId)
Return the JSONObject for the bean with the given time zone.
|
String |
toString() |
void |
write(DataOutput dataOutput) |
public CoordinatorJobBean()
public Timestamp getStartTimestamp()
public void setStartTimestamp(Timestamp startTimestamp)
startTimestamp - start timestamppublic Timestamp getEndTimestamp()
public void setEndTimestamp(Timestamp endTimestamp)
endTimestamp - end timestamppublic Timestamp getNextMaterializedTimestamp()
public void setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp)
nextMaterializedTimestamp - next materialized timestamppublic Timestamp getLastModifiedTimestamp()
public void setLastModifiedTimestamp(Timestamp lastModifiedTimestamp)
lastModifiedTimestamp - last modified timestamppublic Timestamp getSuspendedTimestamp()
public void setSuspendedTimestamp(Timestamp suspendedTimestamp)
suspendedTimestamp - suspended timestamppublic void setJobXmlBlob(StringBlob jobXmlBlob)
public StringBlob getJobXmlBlob()
public String getOrigJobXml()
public void setOrigJobXml(String origJobXml)
origJobXml - public void setOrigJobXmlBlob(StringBlob origJobXml)
public StringBlob getOrigJobXmlBlob()
public void setSlaXmlBlob(StringBlob slaXml)
public StringBlob getSlaXmlBlob()
public void setLastActionTimestamp(Timestamp lastActionTimestamp)
lastActionTimestamp - last action timestamppublic boolean isPending()
public void setDoneMaterialization()
public void setDoneMaterialization(int i)
public void resetDoneMaterialization()
public boolean isDoneMaterialization()
public String getAppNamespace()
public void setAppNamespace(String appNamespace)
appNamespace - the app namespce to setpublic void write(DataOutput dataOutput) throws IOException
write in interface org.apache.hadoop.io.WritableIOExceptionpublic void readFields(DataInput dataInput) throws IOException
readFields in interface org.apache.hadoop.io.WritabledataInput - data input.IOException - thrown if the workflow bean could not be deserialized.public boolean isTerminalStatus()
public org.apache.oozie.client.Job.Status getStatus()
getStatus in interface org.apache.oozie.client.CoordinatorJobgetStatus in interface org.apache.oozie.client.Jobpublic String getStatusStr()
public void setStatusStr(String status)
public void setStatus(org.apache.oozie.client.Job.Status val)
setStatus in interface org.apache.oozie.client.Jobpublic String getTimeUnitStr()
public void setTimeUnitStr(String timeunit)
public void setTimeUnit(org.apache.oozie.client.CoordinatorJob.Timeunit timeUnit)
public org.apache.oozie.client.CoordinatorJob.Timeunit getTimeUnit()
getTimeUnit in interface org.apache.oozie.client.CoordinatorJobpublic void setExecutionOrder(org.apache.oozie.client.CoordinatorJob.Execution order)
order - public org.apache.oozie.client.CoordinatorJob.Execution getExecutionOrder()
getExecutionOrder in interface org.apache.oozie.client.CoordinatorJobpublic void setExecution(String order)
public String getExecution()
public void setLastActionTime(Date lastAction)
public Date getLastActionTime()
getLastActionTime in interface org.apache.oozie.client.CoordinatorJobpublic Timestamp getLastActionTimestamp()
public void setNextMaterializedTime(Date nextMaterializedTime)
public Date getNextMaterializedTime()
getNextMaterializedTime in interface org.apache.oozie.client.CoordinatorJobpublic void setLastModifiedTime(Date lastModifiedTime)
lastModifiedTime - last modified timepublic Date getLastModifiedTime()
public void setSuspendedTime(Date suspendedTime)
suspendedTime - suspended timepublic Date getSuspendedTime()
public void setStartTime(Date startTime)
public Date getStartTime()
getStartTime in interface org.apache.oozie.client.CoordinatorJobgetStartTime in interface org.apache.oozie.client.Jobpublic void setEndTime(Date endTime)
public void setPauseTime(Date pauseTime)
public Date getEndTime()
getEndTime in interface org.apache.oozie.client.CoordinatorJobgetEndTime in interface org.apache.oozie.client.Jobpublic Date getPauseTime()
getPauseTime in interface org.apache.oozie.client.Jobpublic Timestamp getPauseTimestamp()
public void setCreatedTime(Date createTime)
createTime - created timepublic Date getCreatedTime()
public Timestamp getCreatedTimestamp()
public String getAppPath()
getAppPath in interface org.apache.oozie.client.CoordinatorJobgetAppPath in interface org.apache.oozie.client.Jobpublic void setAppPath(String appPath)
public String getAppName()
getAppName in interface org.apache.oozie.client.CoordinatorJobgetAppName in interface org.apache.oozie.client.Jobpublic void setAppName(String appName)
public String getId()
getId in interface org.apache.oozie.client.CoordinatorJobgetId in interface org.apache.oozie.client.Jobpublic void setExternalId(String externalId)
public String getExternalId()
getExternalId in interface org.apache.oozie.client.Jobpublic String getConf()
getConf in interface org.apache.oozie.client.CoordinatorJobgetConf in interface org.apache.oozie.client.Jobpublic void setConfBlob(StringBlob conf)
public StringBlob getConfBlob()
public void setFrequency(String frequency)
public String getFrequency()
getFrequency in interface org.apache.oozie.client.CoordinatorJobpublic void setTimeZone(String timeZone)
public String getTimeZone()
getTimeZone in interface org.apache.oozie.client.CoordinatorJobpublic void setConcurrency(int concurrency)
public int getConcurrency()
getConcurrency in interface org.apache.oozie.client.CoordinatorJobpublic int getMatThrottling()
public void setMatThrottling(int matThrottling)
public void setTimeout(int timeOut)
public int getTimeout()
getTimeout in interface org.apache.oozie.client.CoordinatorJobpublic String getUser()
getUser in interface org.apache.oozie.client.CoordinatorJobgetUser in interface org.apache.oozie.client.Jobpublic String getGroup()
getGroup in interface org.apache.oozie.client.CoordinatorJobgetGroup in interface org.apache.oozie.client.Jobpublic String getAcl()
getAcl in interface org.apache.oozie.client.CoordinatorJobgetAcl in interface org.apache.oozie.client.Jobpublic String getBundleId()
getBundleId in interface org.apache.oozie.client.CoordinatorJobpublic void setBundleId(String bundleId)
public String getConsoleUrl()
getConsoleUrl in interface org.apache.oozie.client.CoordinatorJobgetConsoleUrl in interface org.apache.oozie.client.Jobpublic void setConsoleUrl(String consoleUrl)
consoleUrl - the coordinate application console URL.public void setActions(List<CoordinatorActionBean> nodes)
public List<org.apache.oozie.client.CoordinatorAction> getActions()
getActions in interface org.apache.oozie.client.CoordinatorJobpublic static org.json.simple.JSONArray toJSONArray(List<CoordinatorJobBean> applications, String timeZoneId)
applications - list.timeZoneId - time zone to use for dates in the JSON array.public int getLastActionNumber()
public void setLastActionNumber(int lastActionNumber)
public void setPending()
setPending in interface org.apache.oozie.client.Jobpublic void resetPending()
resetPending in interface org.apache.oozie.client.Jobpublic int getNumActions()
public void setNumActions(int numAction)
public org.json.simple.JSONObject toJSONObject()
JsonBeantoJSONObject in interface JsonBeanpublic org.json.simple.JSONObject toJSONObject(String timeZoneId)
JsonBeantoJSONObject in interface JsonBeantimeZoneId - the time zone to useCopyright © 2014 Apache Software Foundation. All Rights Reserved.