org.apache.oozie

Class BundleActionBean

java.lang.Object

org.apache.oozie.BundleActionBean

All Implemented Interfaces:

org.apache.hadoop.io.Writable, JsonBean

@Entity
public class BundleActionBean
extends Object
implements org.apache.hadoop.io.Writable, JsonBean

Constructor Summary

Constructors

Constructor and Description
BundleActionBean()

Method Summary

Modifier and Type	Method and Description
int	decrementAndGetPending() decrement pending and return it
String	getBundleActionId() Get the Bundle Action Id.
String	getBundleId() Get the BundleId
String	getCoordId() Get the coordinator Id.
String	getCoordName() Get the Coordinator name.
Date	getLastModifiedTime() Get Last modified time.
Timestamp	getLastModifiedTimestamp() Get Last modified time.
int	getPending() Get some actions are in progress for particular bundle action.
Job.Status	getStatus() Get the Status of the Bundle Action
String	getStatusStr() Get the Status of the Bundle Action
int	incrementAndGetPending() increment pending and return it
boolean	isCritical() Return if the action is critical.
boolean	isPending() Return if the action is pending.
boolean	isTerminalStatus()
void	readFields(DataInput dataInput)
void	resetCritical() Reseset that this bundle action is not critical.
void	setBundleActionId(String bundleActionId) bundleActionId to set
void	setBundleId(String bundleId) Set the Bundle Id.
void	setCoordId(String coordId) Set the coordinator Id.
void	setCoordName(String coordName) Set the Coordinator name.
void	setCritical() Set that this bundle action is critical.
void	setLastModifiedTime(Date lastModifiedTime) Set Last modified time.
void	setLastModifiedTimestamp(Timestamp lastModifiedTimestamp) Set Last modified time.
void	setPending(int pending) Set some actions are in progress for particular bundle action.
void	setStatus(Job.Status val) Set the Status of the Bundle Action
void	setStatusStr(String statusStr) Set the Status of the Bundle Action
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.
void	write(DataOutput dataOutput)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BundleActionBean

public BundleActionBean()

Method Detail

setBundleActionId

public void setBundleActionId(String bundleActionId)

bundleActionId to set

Parameters:

bundleActionId - the bundleActionId to set

getBundleActionId

public String getBundleActionId()

Get the Bundle Action Id.

Returns:

the bundleActionId

getBundleId

public String getBundleId()

Get the BundleId

Returns:

bundleId

setBundleId

public void setBundleId(String bundleId)

Set the Bundle Id.

Parameters:

bundleId - the bundle Id

getCoordName

public String getCoordName()

Get the Coordinator name.

Returns:

coordName

setCoordName

public void setCoordName(String coordName)

Set the Coordinator name.

Parameters:

coordName - the Coordinator name

getCoordId

public String getCoordId()

Get the coordinator Id.

Returns:

the coordId

setCoordId

public void setCoordId(String coordId)

Set the coordinator Id.

Parameters:

coordId - the coordinator id

getStatus

public Job.Status getStatus()

Get the Status of the Bundle Action

Returns:

status object

getStatusStr

public String getStatusStr()

Get the Status of the Bundle Action

Returns:

status string

setStatusStr

public void setStatusStr(String statusStr)

Set the Status of the Bundle Action

Parameters:

statusStr - status string

setStatus

public void setStatus(Job.Status val)

Set the Status of the Bundle Action

Parameters:

val - the status to set

setCritical

public void setCritical()

Set that this bundle action is critical.

resetCritical

public void resetCritical()

Reseset that this bundle action is not critical.

isCritical

public boolean isCritical()

Return if the action is critical.

Returns:

if the action is critical.

setPending

public void setPending(int pending)

Set some actions are in progress for particular bundle 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.

isTerminalStatus

public boolean isTerminalStatus()

Returns:

true if in terminal status

setLastModifiedTimestamp

public void setLastModifiedTimestamp(Timestamp lastModifiedTimestamp)

Set Last modified time.

Parameters:

lastModifiedTimestamp - the lastModifiedTimestamp to set

setLastModifiedTime

public void setLastModifiedTime(Date lastModifiedTime)

Set Last modified time.

Parameters:

lastModifiedTime - the lastModifiedTime to set

getLastModifiedTime

public Date getLastModifiedTime()

Get Last modified time.

Returns:

lastModifiedTime

getLastModifiedTimestamp

public Timestamp getLastModifiedTimestamp()

Get Last modified time.

Returns:

lastModifiedTimestamp

write

public void write(DataOutput dataOutput)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput dataInput)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

toJSONObject

public org.json.simple.JSONObject toJSONObject()

Description copied from interface: JsonBean

Return the JSONObject for the bean with GMT time zone.

Specified by:

toJSONObject in interface JsonBean

Returns:

the JSONObject for the bean with GMT time zone.

toJSONObject

public org.json.simple.JSONObject toJSONObject(String timeZoneId)

Description copied from interface: JsonBean

Return the JSONObject for the bean with the given time zone.

Specified by:

toJSONObject in interface JsonBean

Parameters:

timeZoneId - the time zone to use

Returns:

the JSONObject for the bean with the given time zone.