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