@Entity public class CoordinatorActionBean extends Object implements org.apache.hadoop.io.Writable, CoordinatorAction, JsonBean
CoordinatorAction.Status| Constructor and Description |
|---|
CoordinatorActionBean() |
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 CoordinatorActionpublic CoordinatorAction.Status getStatus()
getStatus in interface CoordinatorActionpublic String getStatusStr()
public void setStatus(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 CoordinatorActionpublic Timestamp getCreatedTimestamp()
public Date getRerunTime()
public Timestamp getRerunTimestamp()
public Date getLastModifiedTime()
getLastModifiedTime in interface CoordinatorActionpublic Timestamp getLastModifiedTimestamp()
public Date getNominalTime()
getNominalTime in interface CoordinatorActionpublic Timestamp getNominalTimestamp()
public String getExternalId()
getExternalId in interface 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 CoordinatorActionpublic void setActionNumber(int actionNumber)
public int getActionNumber()
getActionNumber in interface CoordinatorActionpublic String getCreatedConf()
getCreatedConf in interface CoordinatorActionpublic void setCreatedConf(String createdConf)
public void setCreatedConfBlob(StringBlob createdConf)
public StringBlob getCreatedConfBlob()
public void setRunConf(String runConf)
public String getRunConf()
getRunConf in interface CoordinatorActionpublic void setRunConfBlob(StringBlob runConf)
public StringBlob getRunConfBlob()
public void setMissingDependencies(String missingDependencies)
public String getMissingDependencies()
getMissingDependencies in interface CoordinatorActionpublic void setMissingDependenciesBlob(StringBlob missingDependencies)
public StringBlob getMissingDependenciesBlob()
public String getPushMissingDependencies()
getPushMissingDependencies in interface CoordinatorActionpublic void setPushMissingDependencies(String pushMissingDependencies)
public void setPushMissingDependenciesBlob(StringBlob pushMissingDependencies)
public StringBlob getPushMissingDependenciesBlob()
public String getExternalStatus()
getExternalStatus in interface CoordinatorActionpublic void setExternalStatus(String externalStatus)
public String getTrackerUri()
getTrackerUri in interface CoordinatorActionpublic void setTrackerUri(String trackerUri)
public String getConsoleUrl()
getConsoleUrl in interface CoordinatorActionpublic void setConsoleUrl(String consoleUrl)
public String getErrorCode()
getErrorCode in interface CoordinatorActionpublic String getErrorMessage()
getErrorMessage in interface 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 CoordinatorActionpublic void setErrorMessage(String errorMessage)
setErrorMessage in interface 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 © 2015 Apache Software Foundation. All Rights Reserved.