@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()
JsonBean
toJSONObject
in interface JsonBean
public void write(DataOutput dataOutput) throws IOException
write
in interface org.apache.hadoop.io.Writable
dataOutput
- 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.Writable
dataInput
- data input.IOException
- thrown if the workflow bean could not be
deserialized.public String getJobId()
getJobId
in interface org.apache.oozie.client.CoordinatorAction
public org.apache.oozie.client.CoordinatorAction.Status getStatus()
getStatus
in interface org.apache.oozie.client.CoordinatorAction
public 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.CoordinatorAction
public Timestamp getCreatedTimestamp()
public Date getRerunTime()
public Timestamp getRerunTimestamp()
public Date getLastModifiedTime()
getLastModifiedTime
in interface org.apache.oozie.client.CoordinatorAction
public Timestamp getLastModifiedTimestamp()
public Date getNominalTime()
getNominalTime
in interface org.apache.oozie.client.CoordinatorAction
public Timestamp getNominalTimestamp()
public String getExternalId()
getExternalId
in interface org.apache.oozie.client.CoordinatorAction
public 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.CoordinatorAction
public void setActionNumber(int actionNumber)
public int getActionNumber()
getActionNumber
in interface org.apache.oozie.client.CoordinatorAction
public String getCreatedConf()
getCreatedConf
in interface org.apache.oozie.client.CoordinatorAction
public 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.CoordinatorAction
public void setRunConfBlob(StringBlob runConf)
public StringBlob getRunConfBlob()
public void setMissingDependencies(String missingDependencies)
public String getMissingDependencies()
getMissingDependencies
in interface org.apache.oozie.client.CoordinatorAction
public void setMissingDependenciesBlob(StringBlob missingDependencies)
public StringBlob getMissingDependenciesBlob()
public String getPushMissingDependencies()
getPushMissingDependencies
in interface org.apache.oozie.client.CoordinatorAction
public void setPushMissingDependencies(String pushMissingDependencies)
public void setPushMissingDependenciesBlob(StringBlob pushMissingDependencies)
public StringBlob getPushMissingDependenciesBlob()
public String getExternalStatus()
getExternalStatus
in interface org.apache.oozie.client.CoordinatorAction
public void setExternalStatus(String externalStatus)
public String getTrackerUri()
getTrackerUri
in interface org.apache.oozie.client.CoordinatorAction
public void setTrackerUri(String trackerUri)
public String getConsoleUrl()
getConsoleUrl
in interface org.apache.oozie.client.CoordinatorAction
public void setConsoleUrl(String consoleUrl)
public String getErrorCode()
getErrorCode
in interface org.apache.oozie.client.CoordinatorAction
public String getErrorMessage()
getErrorMessage
in interface org.apache.oozie.client.CoordinatorAction
public 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.CoordinatorAction
public void setErrorMessage(String errorMessage)
setErrorMessage
in interface org.apache.oozie.client.CoordinatorAction
public org.json.simple.JSONObject toJSONObject(String timeZoneId)
JsonBean
toJSONObject
in interface JsonBean
timeZoneId
- 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.