org.apache.oozie
Class CoordinatorActionBean

java.lang.Object
  extended by org.apache.oozie.client.rest.JsonCoordinatorAction
      extended by org.apache.oozie.CoordinatorActionBean
All Implemented Interfaces:
org.apache.hadoop.io.Writable, org.apache.oozie.client.CoordinatorAction, JsonBean

@Entity
public class CoordinatorActionBean
extends JsonCoordinatorAction
implements org.apache.hadoop.io.Writable


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.oozie.client.CoordinatorAction
org.apache.oozie.client.CoordinatorAction.Status
 
Constructor Summary
CoordinatorActionBean()
           
 
Method Summary
 int decrementAndGetPending()
          decrement pending and return it
 Date getCreatedTime()
           
 Timestamp getCreatedTimestamp()
           
 String getExternalId()
           
 String getJobId()
           
 Date getLastModifiedTime()
           
 Timestamp getLastModifiedTimestamp()
           
 Date getNominalTime()
           
 Timestamp getNominalTimestamp()
           
 int getPending()
          Get some actions are in progress for particular bundle action.
 Date getRerunTime()
           
 Timestamp getRerunTimestamp()
           
 String getSlaXml()
           
 org.apache.oozie.client.CoordinatorAction.Status getStatus()
           
 int incrementAndGetPending()
          increment pending and return it
 boolean isPending()
          Return if the action is pending.
 boolean isTerminalStatus()
           
 void readFields(DataInput dataInput)
          Deserialize a coordinator bean from a data input.
 void setCreatedTime(Date createdTime)
           
 void setExternalId(String externalId)
           
 void setJobId(String id)
           
 void setLastModifiedTime(Date lastModifiedTime)
           
 void setNominalTime(Date nominalTime)
           
 void setPending(int pending)
          Set some actions are in progress for particular coordinator action.
 void setRerunTime(Date rerunTime)
           
 void setSlaXml(String slaXml)
           
 void setStatus(org.apache.oozie.client.CoordinatorAction.Status status)
           
 void write(DataOutput dataOutput)
          Serialize the coordinator bean to a data output.
 
Methods inherited from class org.apache.oozie.client.rest.JsonCoordinatorAction
equals, getActionNumber, getActionXml, getConsoleUrl, getCreatedConf, getErrorCode, getErrorMessage, getExternalStatus, getId, getMissingDependencies, getRunConf, getTimeOut, getTrackerUri, getType, hashCode, setActionNumber, setActionXml, setConsoleUrl, setCreatedConf, setErrorCode, setErrorInfo, setErrorMessage, setExternalStatus, setId, setMissingDependencies, setRunConf, setTimeOut, setTrackerUri, setType, toJSONArray, toJSONObject, toJSONObject, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

CoordinatorActionBean

public CoordinatorActionBean()
Method Detail

write

public void write(DataOutput dataOutput)
           throws IOException
Serialize the coordinator bean to a data output.

Specified by:
write in interface org.apache.hadoop.io.Writable
Parameters:
dataOutput - data output.
Throws:
IOException - thrown if the coordinator bean could not be serialized.

readFields

public void readFields(DataInput dataInput)
                throws IOException
Deserialize a coordinator bean from a data input.

Specified by:
readFields in interface org.apache.hadoop.io.Writable
Parameters:
dataInput - data input.
Throws:
IOException - thrown if the workflow bean could not be deserialized.

getJobId

public String getJobId()
Specified by:
getJobId in interface org.apache.oozie.client.CoordinatorAction
Overrides:
getJobId in class JsonCoordinatorAction

setJobId

public void setJobId(String id)
Overrides:
setJobId in class JsonCoordinatorAction

getStatus

public org.apache.oozie.client.CoordinatorAction.Status getStatus()
Specified by:
getStatus in interface org.apache.oozie.client.CoordinatorAction
Overrides:
getStatus in class JsonCoordinatorAction

setStatus

public void setStatus(org.apache.oozie.client.CoordinatorAction.Status status)
Overrides:
setStatus in class JsonCoordinatorAction

setCreatedTime

public void setCreatedTime(Date createdTime)
Overrides:
setCreatedTime in class JsonCoordinatorAction

setRerunTime

public void setRerunTime(Date rerunTime)

setNominalTime

public void setNominalTime(Date nominalTime)
Overrides:
setNominalTime in class JsonCoordinatorAction

setLastModifiedTime

public void setLastModifiedTime(Date lastModifiedTime)
Overrides:
setLastModifiedTime in class JsonCoordinatorAction

getCreatedTime

public Date getCreatedTime()
Specified by:
getCreatedTime in interface org.apache.oozie.client.CoordinatorAction
Overrides:
getCreatedTime in class JsonCoordinatorAction

getCreatedTimestamp

public Timestamp getCreatedTimestamp()

getRerunTime

public Date getRerunTime()

getRerunTimestamp

public Timestamp getRerunTimestamp()

getLastModifiedTime

public Date getLastModifiedTime()
Specified by:
getLastModifiedTime in interface org.apache.oozie.client.CoordinatorAction
Overrides:
getLastModifiedTime in class JsonCoordinatorAction

getLastModifiedTimestamp

public Timestamp getLastModifiedTimestamp()

getNominalTime

public Date getNominalTime()
Specified by:
getNominalTime in interface org.apache.oozie.client.CoordinatorAction
Overrides:
getNominalTime in class JsonCoordinatorAction

getNominalTimestamp

public Timestamp getNominalTimestamp()

getExternalId

public String getExternalId()
Specified by:
getExternalId in interface org.apache.oozie.client.CoordinatorAction
Overrides:
getExternalId in class JsonCoordinatorAction

setExternalId

public void setExternalId(String externalId)
Overrides:
setExternalId in class JsonCoordinatorAction

getSlaXml

public String getSlaXml()

setSlaXml

public void setSlaXml(String slaXml)

isTerminalStatus

public boolean isTerminalStatus()
Returns:
true if in terminal status

setPending

public void setPending(int pending)
Set some actions are in progress for particular coordinator action.

Parameters:
pending - set pending to true

incrementAndGetPending

public int incrementAndGetPending()
increment pending and return it

Returns:
pending

decrementAndGetPending

public int decrementAndGetPending()
decrement pending and return it

Returns:
pending

getPending

public int getPending()
Get some actions are in progress for particular bundle action.

Returns:
pending

isPending

public boolean isPending()
Return if the action is pending.

Returns:
if the action is pending.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.