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