This project has retired. For details please refer to its Attic page.

org.apache.oozie
Class CoordinatorActionBean

java.lang.Object
  org.apache.oozie.client.rest.JsonCoordinatorAction
      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.