@Entity public class CoordinatorActionBean extends java.lang.Object implements org.apache.hadoop.io.Writable, org.apache.oozie.client.CoordinatorAction, JsonBean
| Constructor and Description |
|---|
CoordinatorActionBean() |
| Modifier and Type | Method and Description |
|---|---|
int |
decrementAndGetPending()
decrement pending and return it
|
boolean |
equals(java.lang.Object obj) |
int |
getActionNumber() |
java.lang.String |
getActionXml() |
StringBlob |
getActionXmlBlob() |
java.lang.String |
getConsoleUrl() |
java.lang.String |
getCreatedConf() |
StringBlob |
getCreatedConfBlob() |
java.util.Date |
getCreatedTime() |
java.sql.Timestamp |
getCreatedTimestamp() |
java.lang.String |
getErrorCode() |
java.lang.String |
getErrorMessage() |
java.lang.String |
getExternalId() |
java.lang.String |
getExternalStatus() |
java.lang.String |
getId() |
java.lang.String |
getJobId() |
java.util.Date |
getLastModifiedTime() |
java.sql.Timestamp |
getLastModifiedTimestamp() |
java.lang.String |
getMissingDependencies() |
StringBlob |
getMissingDependenciesBlob() |
java.util.Date |
getNominalTime() |
java.sql.Timestamp |
getNominalTimestamp() |
int |
getPending()
Get some actions are in progress for particular bundle action.
|
java.lang.String |
getPushMissingDependencies() |
StringBlob |
getPushMissingDependenciesBlob() |
java.util.Date |
getRerunTime() |
java.sql.Timestamp |
getRerunTimestamp() |
java.lang.String |
getRunConf() |
StringBlob |
getRunConfBlob() |
java.lang.String |
getSlaXml() |
StringBlob |
getSlaXmlBlob() |
org.apache.oozie.client.CoordinatorAction.Status |
getStatus() |
java.lang.String |
getStatusStr()
Return the status in string
|
int |
getTimeOut() |
java.lang.String |
getTrackerUri() |
java.lang.String |
getType() |
int |
hashCode() |
int |
incrementAndGetPending()
increment pending and return it
|
boolean |
isPending()
Return if the action is pending.
|
boolean |
isTerminalStatus() |
boolean |
isTerminalWithFailure()
Return if the action is complete with failure.
|
void |
readFields(java.io.DataInput dataInput)
Deserialize a coordinator bean from a data input.
|
void |
setActionNumber(int actionNumber) |
void |
setActionXml(java.lang.String actionXml) |
void |
setActionXmlBlob(StringBlob actionXml) |
void |
setConsoleUrl(java.lang.String consoleUrl) |
void |
setCreatedConf(java.lang.String createdConf) |
void |
setCreatedConfBlob(StringBlob createdConf) |
void |
setCreatedTime(java.util.Date createdTime) |
void |
setErrorCode(java.lang.String errorCode) |
void |
setErrorInfo(java.lang.String errorCode,
java.lang.String errorMessage) |
void |
setErrorMessage(java.lang.String errorMessage) |
void |
setExternalId(java.lang.String externalId) |
void |
setExternalStatus(java.lang.String externalStatus) |
void |
setId(java.lang.String id) |
void |
setJobId(java.lang.String id) |
void |
setLastModifiedTime(java.util.Date lastModifiedTime) |
void |
setMissingDependencies(java.lang.String missingDependencies) |
void |
setMissingDependenciesBlob(StringBlob missingDependencies) |
void |
setNominalTime(java.util.Date nominalTime) |
void |
setPending(int pending)
Set some actions are in progress for particular coordinator action.
|
void |
setPushMissingDependencies(java.lang.String pushMissingDependencies) |
void |
setPushMissingDependenciesBlob(StringBlob pushMissingDependencies) |
void |
setRerunTime(java.util.Date rerunTime) |
void |
setRunConf(java.lang.String runConf) |
void |
setRunConfBlob(StringBlob runConf) |
void |
setSlaXml(java.lang.String slaXml) |
void |
setSlaXmlBlob(StringBlob slaXml) |
void |
setStatus(org.apache.oozie.client.CoordinatorAction.Status status) |
void |
setStatusStr(java.lang.String statusStr) |
void |
setTimeOut(int timeOut) |
void |
setTrackerUri(java.lang.String trackerUri) |
void |
setType(java.lang.String type) |
static org.json.simple.JSONArray |
toJSONArray(java.util.List<CoordinatorActionBean> actions,
java.lang.String timeZoneId)
Convert a nodes 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)
Serialize the coordinator bean to a data output.
|
public CoordinatorActionBean()
public org.json.simple.JSONObject toJSONObject()
JsonBeantoJSONObject in interface JsonBeanpublic void write(java.io.DataOutput dataOutput) throws java.io.IOException
write in interface org.apache.hadoop.io.WritabledataOutput - data output.java.io.IOException - thrown if the coordinator bean could not be
serialized.public 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 java.lang.String getJobId()
getJobId in interface org.apache.oozie.client.CoordinatorActionpublic void setJobId(java.lang.String id)
public org.apache.oozie.client.CoordinatorAction.Status getStatus()
getStatus in interface org.apache.oozie.client.CoordinatorActionpublic java.lang.String getStatusStr()
public void setStatus(org.apache.oozie.client.CoordinatorAction.Status status)
public void setStatusStr(java.lang.String statusStr)
public void setCreatedTime(java.util.Date createdTime)
public void setRerunTime(java.util.Date rerunTime)
public void setNominalTime(java.util.Date nominalTime)
public void setLastModifiedTime(java.util.Date lastModifiedTime)
public java.util.Date getCreatedTime()
getCreatedTime in interface org.apache.oozie.client.CoordinatorActionpublic java.sql.Timestamp getCreatedTimestamp()
public java.util.Date getRerunTime()
public java.sql.Timestamp getRerunTimestamp()
public java.util.Date getLastModifiedTime()
getLastModifiedTime in interface org.apache.oozie.client.CoordinatorActionpublic java.sql.Timestamp getLastModifiedTimestamp()
public java.util.Date getNominalTime()
getNominalTime in interface org.apache.oozie.client.CoordinatorActionpublic java.sql.Timestamp getNominalTimestamp()
public java.lang.String getExternalId()
getExternalId in interface org.apache.oozie.client.CoordinatorActionpublic void setExternalId(java.lang.String externalId)
public StringBlob getSlaXmlBlob()
public void setSlaXmlBlob(StringBlob slaXml)
public java.lang.String getSlaXml()
public void setSlaXml(java.lang.String slaXml)
public boolean isTerminalStatus()
public boolean isTerminalWithFailure()
public void setPending(int pending)
pending - set pending to truepublic int incrementAndGetPending()
public int decrementAndGetPending()
public int getPending()
public boolean isPending()
public java.lang.String getId()
getId in interface org.apache.oozie.client.CoordinatorActionpublic void setId(java.lang.String id)
public java.lang.String getType()
public void setType(java.lang.String type)
public void setActionNumber(int actionNumber)
public int getActionNumber()
getActionNumber in interface org.apache.oozie.client.CoordinatorActionpublic java.lang.String getCreatedConf()
getCreatedConf in interface org.apache.oozie.client.CoordinatorActionpublic void setCreatedConf(java.lang.String createdConf)
public void setCreatedConfBlob(StringBlob createdConf)
public StringBlob getCreatedConfBlob()
public void setRunConf(java.lang.String runConf)
public java.lang.String getRunConf()
getRunConf in interface org.apache.oozie.client.CoordinatorActionpublic void setRunConfBlob(StringBlob runConf)
public StringBlob getRunConfBlob()
public void setMissingDependencies(java.lang.String missingDependencies)
public java.lang.String getMissingDependencies()
getMissingDependencies in interface org.apache.oozie.client.CoordinatorActionpublic void setMissingDependenciesBlob(StringBlob missingDependencies)
public StringBlob getMissingDependenciesBlob()
public java.lang.String getPushMissingDependencies()
getPushMissingDependencies in interface org.apache.oozie.client.CoordinatorActionpublic void setPushMissingDependencies(java.lang.String pushMissingDependencies)
public void setPushMissingDependenciesBlob(StringBlob pushMissingDependencies)
public StringBlob getPushMissingDependenciesBlob()
public java.lang.String getExternalStatus()
getExternalStatus in interface org.apache.oozie.client.CoordinatorActionpublic void setExternalStatus(java.lang.String externalStatus)
public java.lang.String getTrackerUri()
getTrackerUri in interface org.apache.oozie.client.CoordinatorActionpublic void setTrackerUri(java.lang.String trackerUri)
public java.lang.String getConsoleUrl()
getConsoleUrl in interface org.apache.oozie.client.CoordinatorActionpublic void setConsoleUrl(java.lang.String consoleUrl)
public java.lang.String getErrorCode()
getErrorCode in interface org.apache.oozie.client.CoordinatorActionpublic java.lang.String getErrorMessage()
getErrorMessage in interface org.apache.oozie.client.CoordinatorActionpublic void setErrorInfo(java.lang.String errorCode, java.lang.String errorMessage)
public java.lang.String getActionXml()
public void setActionXml(java.lang.String actionXml)
public void setActionXmlBlob(StringBlob actionXml)
public StringBlob getActionXmlBlob()
public java.lang.String toString()
toString in class java.lang.Objectpublic int getTimeOut()
public void setTimeOut(int timeOut)
public void setErrorCode(java.lang.String errorCode)
setErrorCode in interface org.apache.oozie.client.CoordinatorActionpublic void setErrorMessage(java.lang.String errorMessage)
setErrorMessage in interface org.apache.oozie.client.CoordinatorActionpublic org.json.simple.JSONObject toJSONObject(java.lang.String timeZoneId)
JsonBeantoJSONObject in interface JsonBeantimeZoneId - the time zone to usepublic static org.json.simple.JSONArray toJSONArray(java.util.List<CoordinatorActionBean> actions, java.lang.String timeZoneId)
actions - nodes list.timeZoneId - time zone to use for dates in the JSON array.public int hashCode()
hashCode in class java.lang.Objectpublic boolean equals(java.lang.Object obj)
equals in class java.lang.ObjectCopyright © 2019 Apache Software Foundation. All Rights Reserved.