@Entity public class WorkflowJobBean extends Object implements org.apache.hadoop.io.Writable, org.apache.oozie.client.WorkflowJob, JsonBean
| Constructor and Description |
|---|
WorkflowJobBean()
Default constructor.
|
| Modifier and Type | Method and Description |
|---|---|
String |
getAcl() |
List<org.apache.oozie.client.WorkflowAction> |
getActions() |
String |
getAppName() |
String |
getAppPath() |
String |
getConf() |
StringBlob |
getConfBlob() |
String |
getConsoleUrl()
Return the workflow job console URL.
|
Date |
getCreatedTime() |
Timestamp |
getCreatedTimestamp() |
Date |
getEndTime() |
Timestamp |
getEndTimestamp() |
String |
getExternalId() |
String |
getGroup() |
String |
getId() |
Date |
getLastModifiedTime() |
Timestamp |
getLastModifiedTimestamp() |
String |
getlogToken() |
String |
getLogToken() |
String |
getParentId()
Return the corresponding Action ID, if any.
|
String |
getProtoActionConf() |
StringBlob |
getProtoActionConfBlob() |
int |
getRun() |
String |
getSlaXml() |
StringBlob |
getSlaXmlBlob() |
Date |
getStartTime() |
Timestamp |
getStartTimestamp() |
org.apache.oozie.client.WorkflowJob.Status |
getStatus() |
String |
getStatusStr() |
String |
getUser() |
BinaryBlob |
getWfInstanceBlob() |
WorkflowInstance |
getWorkflowInstance() |
boolean |
inTerminalState() |
void |
readFields(DataInput dataInput)
Deserialize a workflow bean from a data input.
|
void |
setActions(List<WorkflowActionBean> nodes) |
void |
setAppName(String appName) |
void |
setAppPath(String appPath) |
void |
setConf(String conf) |
void |
setConfBlob(StringBlob conf) |
void |
setConsoleUrl(String consoleUrl)
Set the workflow job console URL.
|
void |
setCreatedTime(Date createdTime) |
void |
setEndTime(Date endTime) |
void |
setExternalId(String externalId) |
void |
setGroup(String group) |
void |
setId(String id) |
void |
setLastModifiedTime(Date lastModifiedTime) |
void |
setLogToken(String logToken) |
void |
setParentId(String parentId)
Set coordinator action id
|
void |
setProtoActionConf(String protoActionConf) |
void |
setProtoActionConfBlob(StringBlob protoBytes) |
void |
setRun(int run) |
void |
setSlaXml(String slaXml) |
void |
setSlaXmlBlob(StringBlob slaXml) |
void |
setStartTime(Date startTime) |
void |
setStatus(org.apache.oozie.client.WorkflowJob.Status val) |
void |
setStatusStr(String statusStr) |
void |
setUser(String user) |
void |
setWfInstanceBlob(BinaryBlob wfInstance) |
void |
setWorkflowInstance(WorkflowInstance workflowInstance) |
static org.json.simple.JSONArray |
toJSONArray(List<WorkflowJobBean> workflows,
String timeZoneId)
Convert a workflows 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 workflow bean to a data output.
|
public WorkflowJobBean()
public void write(DataOutput dataOutput) throws IOException
write in interface org.apache.hadoop.io.WritabledataOutput - data output.IOException - thrown if the workflow 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 boolean inTerminalState()
public String getLogToken()
public void setLogToken(String logToken)
public void setSlaXmlBlob(StringBlob slaXml)
public StringBlob getSlaXmlBlob()
public WorkflowInstance getWorkflowInstance()
public BinaryBlob getWfInstanceBlob()
public void setWorkflowInstance(WorkflowInstance workflowInstance)
public void setWfInstanceBlob(BinaryBlob wfInstance)
public String getProtoActionConf()
public void setProtoActionConf(String protoActionConf)
public void setProtoActionConfBlob(StringBlob protoBytes)
public StringBlob getProtoActionConfBlob()
public String getlogToken()
public Timestamp getLastModifiedTimestamp()
public Timestamp getStartTimestamp()
public Timestamp getCreatedTimestamp()
public Timestamp getEndTimestamp()
public void setStatusStr(String statusStr)
public void setStatus(org.apache.oozie.client.WorkflowJob.Status val)
public org.apache.oozie.client.WorkflowJob.Status getStatus()
getStatus in interface org.apache.oozie.client.WorkflowJobpublic String getStatusStr()
public void setExternalId(String externalId)
public String getExternalId()
getExternalId in interface org.apache.oozie.client.WorkflowJobpublic void setLastModifiedTime(Date lastModifiedTime)
public Date getLastModifiedTime()
getLastModifiedTime in interface org.apache.oozie.client.WorkflowJobpublic Date getCreatedTime()
getCreatedTime in interface org.apache.oozie.client.WorkflowJobpublic void setCreatedTime(Date createdTime)
public Date getStartTime()
getStartTime in interface org.apache.oozie.client.WorkflowJobpublic void setStartTime(Date startTime)
public Date getEndTime()
getEndTime in interface org.apache.oozie.client.WorkflowJobpublic void setEndTime(Date endTime)
public org.json.simple.JSONObject toJSONObject()
JsonBeantoJSONObject in interface JsonBeanpublic org.json.simple.JSONObject toJSONObject(String timeZoneId)
JsonBeantoJSONObject in interface JsonBeantimeZoneId - the time zone to usepublic String getAppPath()
getAppPath in interface org.apache.oozie.client.WorkflowJobpublic void setAppPath(String appPath)
public String getAppName()
getAppName in interface org.apache.oozie.client.WorkflowJobpublic void setAppName(String appName)
public String getConf()
getConf in interface org.apache.oozie.client.WorkflowJobpublic void setConfBlob(StringBlob conf)
public StringBlob getConfBlob()
public String getUser()
getUser in interface org.apache.oozie.client.WorkflowJobpublic String getGroup()
getGroup in interface org.apache.oozie.client.WorkflowJobpublic int getRun()
getRun in interface org.apache.oozie.client.WorkflowJobpublic void setRun(int run)
public String getConsoleUrl()
getConsoleUrl in interface org.apache.oozie.client.WorkflowJobpublic String getParentId()
getParentId in interface org.apache.oozie.client.WorkflowJobpublic void setParentId(String parentId)
parentId - : coordinator action idpublic void setConsoleUrl(String consoleUrl)
consoleUrl - the workflow job console URL.public List<org.apache.oozie.client.WorkflowAction> getActions()
getActions in interface org.apache.oozie.client.WorkflowJobpublic void setActions(List<WorkflowActionBean> nodes)
public static org.json.simple.JSONArray toJSONArray(List<WorkflowJobBean> workflows, String timeZoneId)
workflows - workflows list.timeZoneId - time zone to use for dates in the JSON array.Copyright © 2014 Apache Software Foundation. All Rights Reserved.