CoordinatorJobBean (Apache Oozie Core 4.0.0 API)

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

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.oozie
Class CoordinatorJobBean

java.lang.Object
  org.apache.oozie.client.rest.JsonCoordinatorJob
      org.apache.oozie.CoordinatorJobBean

All Implemented Interfaces:: org.apache.hadoop.io.Writable, org.apache.oozie.client.CoordinatorJob, org.apache.oozie.client.Job, JsonBean

@Entity public class CoordinatorJobBean
extends JsonCoordinatorJob
implements org.apache.hadoop.io.Writable
extends JsonCoordinatorJob
implements org.apache.hadoop.io.Writable

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.oozie.client.CoordinatorJob

org.apache.oozie.client.CoordinatorJob.Execution, org.apache.oozie.client.CoordinatorJob.Timeunit

Nested classes/interfaces inherited from interface org.apache.oozie.client.Job

org.apache.oozie.client.Job.Status

Constructor Summary

CoordinatorJobBean()


Method Summary

String getAppNamespace()
          Get app namespce

Date getCreatedTime()
          Get created time

Timestamp getCreatedTimestamp()
          Get created timestamp

Date getEndTime()


Timestamp getEndTimestamp()
          Get end timestamp

String getExecution()
          Get execution

org.apache.oozie.client.CoordinatorJob.Execution getExecutionOrder()


String getJobXml()
          Get job xml

Date getLastActionTime()


Timestamp getLastActionTimestamp()
          Get last action timestamp

Date getLastModifiedTime()
          Get last modified time

Timestamp getLastModifiedTimestamp()
          Get last modified timestamp

Date getNextMaterializedTime()


Timestamp getNextMaterializedTimestamp()
          Get next materialized timestamp

String getOrigJobXml()
          Get original job xml

Date getPauseTime()


String getSlaXml()
          Get sla xml

Date getStartTime()


Timestamp getStartTimestamp()
          Get start timestamp

org.apache.oozie.client.Job.Status getStatus()


String getStatusStr()
          Get status

Date getSuspendedTime()
          Get suspended time

Timestamp getSuspendedTimestamp()
          Get suspended timestamp

org.apache.oozie.client.CoordinatorJob.Timeunit getTimeUnit()


String getTimeUnitStr()
          Get time unit

boolean isDoneMaterialization()
          Return if the action is done with materialization

boolean isPending()
          Return if the action is pending.

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

void resetDoneMaterialization()
          Set doneMaterialization to false

void resetPending()
          Set pending to false

void setAppNamespace(String appNamespace)
          Set app namespce

void setCreatedTime(Date createTime)
          Set created time

void setDoneMaterialization()
          Set doneMaterialization to true

void setEndTime(Date endTime)


void setEndTimestamp(Timestamp endTimestamp)
          Set end timestamp

void setExecution(org.apache.oozie.client.CoordinatorJob.Execution order)
          Set order

void setJobXml(String jobXml)
          Set job xml

void setLastActionTime(Date lastAction)


void setLastActionTimestamp(Timestamp lastActionTimestamp)
          Set last action timestamp

void setLastModifiedTime(Date lastModifiedTime)
          Set last modified time

void setLastModifiedTimestamp(Timestamp lastModifiedTimestamp)
          Set last modified timestamp

void setNextMaterializedTime(Date nextMaterializedTime)


void setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp)
          Set next materialized timestamp

void setOrigJobXml(String origJobXml)
          Set original job xml

void setPauseTime(Date pauseTime)


void setPending()
          Set pending to true

void setSlaXml(String slaXml)
          Set sla xml

void setStartTime(Date startTime)


void setStartTimestamp(Timestamp startTimestamp)
          Set start timestamp

void setStatus(org.apache.oozie.client.Job.Status val)


void setSuspendedTime(Date suspendedTime)
          Set suspended time

void setSuspendedTimestamp(Timestamp suspendedTimestamp)
          Set suspended timestamp

void setTimeUnit(org.apache.oozie.client.CoordinatorJob.Timeunit timeUnit)


void write(DataOutput dataOutput)


Methods inherited from class org.apache.oozie.client.rest.JsonCoordinatorJob

getAcl, getActions, getAppName, getAppPath, getBundleId, getConcurrency, getConf, getConsoleUrl, getExternalId, getFrequency, getGroup, getId, getLastActionNumber, getMatThrottling, getNumActions, getTimeout, getTimeZone, getUser, setActions, setAppName, setAppPath, setBundleId, setConcurrency, setConf, setConsoleUrl, setExecutionOrder, setExternalId, setFrequency, setGroup, setId, setLastActionNumber, setMatThrottling, setNumActions, setTimeout, setTimeZone, setUser, toJSONArray, toJSONObject, toJSONObject, toString

Methods inherited from class java.lang.Object

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

Nested classes/interfaces inherited from interface org.apache.oozie.client.CoordinatorJob
`org.apache.oozie.client.CoordinatorJob.Execution, org.apache.oozie.client.CoordinatorJob.Timeunit`

Nested classes/interfaces inherited from interface org.apache.oozie.client.Job
`org.apache.oozie.client.Job.Status`

Constructor Summary
`CoordinatorJobBean()`

Method Summary
`String`	`getAppNamespace()` Get app namespce
`Date`	`getCreatedTime()` Get created time
`Timestamp`	`getCreatedTimestamp()` Get created timestamp
`Date`	`getEndTime()`
`Timestamp`	`getEndTimestamp()` Get end timestamp
`String`	`getExecution()` Get execution
`org.apache.oozie.client.CoordinatorJob.Execution`	`getExecutionOrder()`
`String`	`getJobXml()` Get job xml
`Date`	`getLastActionTime()`
`Timestamp`	`getLastActionTimestamp()` Get last action timestamp
`Date`	`getLastModifiedTime()` Get last modified time
`Timestamp`	`getLastModifiedTimestamp()` Get last modified timestamp
`Date`	`getNextMaterializedTime()`
`Timestamp`	`getNextMaterializedTimestamp()` Get next materialized timestamp
`String`	`getOrigJobXml()` Get original job xml
`Date`	`getPauseTime()`
`String`	`getSlaXml()` Get sla xml
`Date`	`getStartTime()`
`Timestamp`	`getStartTimestamp()` Get start timestamp
`org.apache.oozie.client.Job.Status`	`getStatus()`
`String`	`getStatusStr()` Get status
`Date`	`getSuspendedTime()` Get suspended time
`Timestamp`	`getSuspendedTimestamp()` Get suspended timestamp
`org.apache.oozie.client.CoordinatorJob.Timeunit`	`getTimeUnit()`
`String`	`getTimeUnitStr()` Get time unit
`boolean`	`isDoneMaterialization()` Return if the action is done with materialization
`boolean`	`isPending()` Return if the action is pending.
`void`	`readFields(DataInput dataInput)` Deserialize a coordinator bean from a data input.
`void`	`resetDoneMaterialization()` Set doneMaterialization to false
`void`	`resetPending()` Set pending to false
`void`	`setAppNamespace(String appNamespace)` Set app namespce
`void`	`setCreatedTime(Date createTime)` Set created time
`void`	`setDoneMaterialization()` Set doneMaterialization to true
`void`	`setEndTime(Date endTime)`
`void`	`setEndTimestamp(Timestamp endTimestamp)` Set end timestamp
`void`	`setExecution(org.apache.oozie.client.CoordinatorJob.Execution order)` Set order
`void`	`setJobXml(String jobXml)` Set job xml
`void`	`setLastActionTime(Date lastAction)`
`void`	`setLastActionTimestamp(Timestamp lastActionTimestamp)` Set last action timestamp
`void`	`setLastModifiedTime(Date lastModifiedTime)` Set last modified time
`void`	`setLastModifiedTimestamp(Timestamp lastModifiedTimestamp)` Set last modified timestamp
`void`	`setNextMaterializedTime(Date nextMaterializedTime)`
`void`	`setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp)` Set next materialized timestamp
`void`	`setOrigJobXml(String origJobXml)` Set original job xml
`void`	`setPauseTime(Date pauseTime)`
`void`	`setPending()` Set pending to true
`void`	`setSlaXml(String slaXml)` Set sla xml
`void`	`setStartTime(Date startTime)`
`void`	`setStartTimestamp(Timestamp startTimestamp)` Set start timestamp
`void`	`setStatus(org.apache.oozie.client.Job.Status val)`
`void`	`setSuspendedTime(Date suspendedTime)` Set suspended time
`void`	`setSuspendedTimestamp(Timestamp suspendedTimestamp)` Set suspended timestamp
`void`	`setTimeUnit(org.apache.oozie.client.CoordinatorJob.Timeunit timeUnit)`
`void`	`write(DataOutput dataOutput)`

Methods inherited from class org.apache.oozie.client.rest.JsonCoordinatorJob
getAcl, getActions, getAppName, getAppPath, getBundleId, getConcurrency, getConf, getConsoleUrl, getExternalId, getFrequency, getGroup, getId, getLastActionNumber, getMatThrottling, getNumActions, getTimeout, getTimeZone, getUser, setActions, setAppName, setAppPath, setBundleId, setConcurrency, setConf, setConsoleUrl, setExecutionOrder, setExternalId, setFrequency, setGroup, setId, setLastActionNumber, setMatThrottling, setNumActions, setTimeout, setTimeZone, setUser, toJSONArray, toJSONObject, toJSONObject, toString

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

Constructor Detail

CoordinatorJobBean

public CoordinatorJobBean()

Method Detail

getStartTimestamp

public Timestamp getStartTimestamp()

Get start timestamp

Returns:: start timestamp

setStartTimestamp

public void setStartTimestamp(Timestamp startTimestamp)

Set start timestamp

Parameters:: startTimestamp - start timestamp

getEndTimestamp

public Timestamp getEndTimestamp()

Get end timestamp

Returns:: end timestamp

setEndTimestamp

public void setEndTimestamp(Timestamp endTimestamp)

Set end timestamp

Parameters:: endTimestamp - end timestamp

getNextMaterializedTimestamp

public Timestamp getNextMaterializedTimestamp()

Get next materialized timestamp

Returns:: next materialized timestamp

setNextMaterializedTimestamp

public void setNextMaterializedTimestamp(Timestamp nextMaterializedTimestamp)

Set next materialized timestamp

Parameters:: nextMaterializedTimestamp - next materialized timestamp

getLastModifiedTimestamp

public Timestamp getLastModifiedTimestamp()

Get last modified timestamp

Returns:: last modified timestamp

setLastModifiedTimestamp

public void setLastModifiedTimestamp(Timestamp lastModifiedTimestamp)

Set last modified timestamp

Parameters:: lastModifiedTimestamp - last modified timestamp

getSuspendedTimestamp

public Timestamp getSuspendedTimestamp()

Get suspended timestamp

Returns:: suspended timestamp

setSuspendedTimestamp

public void setSuspendedTimestamp(Timestamp suspendedTimestamp)

Set suspended timestamp

Parameters:: suspendedTimestamp - suspended timestamp

getJobXml

public String getJobXml()

Get job xml

Returns:: job xml

setJobXml

public void setJobXml(String jobXml)

Set job xml

Parameters:: jobXml - job xml

getOrigJobXml

public String getOrigJobXml()

Get original job xml

Returns:: original job xml

setOrigJobXml

public void setOrigJobXml(String origJobXml)

Set original job xml

Parameters:: origJobXml -

getSlaXml

public String getSlaXml()

Get sla xml

Returns:: sla xml

setSlaXml

public void setSlaXml(String slaXml)

Set sla xml

Parameters:: slaXml - sla xml

setTimeUnit

public void setTimeUnit(org.apache.oozie.client.CoordinatorJob.Timeunit timeUnit)

Overrides:: setTimeUnit in class JsonCoordinatorJob

setLastActionTimestamp

public void setLastActionTimestamp(Timestamp lastActionTimestamp)

Set last action timestamp

Parameters:: lastActionTimestamp - last action timestamp

setPending

public void setPending()

Set pending to true

Specified by:: setPending in interface org.apache.oozie.client.Job
Overrides:: setPending in class JsonCoordinatorJob

resetPending

public void resetPending()

Set pending to false

Specified by:: resetPending in interface org.apache.oozie.client.Job
Overrides:: resetPending in class JsonCoordinatorJob

isPending

public boolean isPending()

Return if the action is pending.

Returns:: if the action is pending.

setDoneMaterialization

public void setDoneMaterialization()

Set doneMaterialization to true

resetDoneMaterialization

public void resetDoneMaterialization()

Set doneMaterialization to false

isDoneMaterialization

public boolean isDoneMaterialization()

Return if the action is done with materialization

Returns:: if the action is done with materialization

getAppNamespace

public String getAppNamespace()

Get app namespce

Returns:: app namespce

setAppNamespace

public void setAppNamespace(String appNamespace)

Set app namespce

Parameters:: appNamespace - the app namespce to set

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

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.

getStatus

public org.apache.oozie.client.Job.Status getStatus()

Specified by:: getStatus in interface org.apache.oozie.client.CoordinatorJob
Specified by:: getStatus in interface org.apache.oozie.client.Job
Overrides:: getStatus in class JsonCoordinatorJob

getStatusStr

public String getStatusStr()

Get status

Returns:: status

setStatus

public void setStatus(org.apache.oozie.client.Job.Status val)

Specified by:: setStatus in interface org.apache.oozie.client.Job
Overrides:: setStatus in class JsonCoordinatorJob

getTimeUnitStr

public String getTimeUnitStr()

Get time unit

Returns:: time unit

getTimeUnit

public org.apache.oozie.client.CoordinatorJob.Timeunit getTimeUnit()

Specified by:: getTimeUnit in interface org.apache.oozie.client.CoordinatorJob
Overrides:: getTimeUnit in class JsonCoordinatorJob

setExecution

public void setExecution(org.apache.oozie.client.CoordinatorJob.Execution order)

Set order

Parameters:: order -

getExecutionOrder

public org.apache.oozie.client.CoordinatorJob.Execution getExecutionOrder()

Specified by:: getExecutionOrder in interface org.apache.oozie.client.CoordinatorJob
Overrides:: getExecutionOrder in class JsonCoordinatorJob

getExecution

public String getExecution()

Get execution

Returns:: execution

setLastActionTime

public void setLastActionTime(Date lastAction)

Overrides:: setLastActionTime in class JsonCoordinatorJob

getLastActionTime

public Date getLastActionTime()

Specified by:: getLastActionTime in interface org.apache.oozie.client.CoordinatorJob
Overrides:: getLastActionTime in class JsonCoordinatorJob

getLastActionTimestamp

public Timestamp getLastActionTimestamp()

Get last action timestamp

Returns:: last action timestamp

setNextMaterializedTime

public void setNextMaterializedTime(Date nextMaterializedTime)

Overrides:: setNextMaterializedTime in class JsonCoordinatorJob

getNextMaterializedTime

public Date getNextMaterializedTime()

Specified by:: getNextMaterializedTime in interface org.apache.oozie.client.CoordinatorJob
Overrides:: getNextMaterializedTime in class JsonCoordinatorJob

setLastModifiedTime

public void setLastModifiedTime(Date lastModifiedTime)

Set last modified time

Parameters:: lastModifiedTime - last modified time

getLastModifiedTime

public Date getLastModifiedTime()

Get last modified time

Returns:: last modified time

setSuspendedTime

public void setSuspendedTime(Date suspendedTime)

Set suspended time

Parameters:: suspendedTime - suspended time

getSuspendedTime

public Date getSuspendedTime()

Get suspended time

Returns:: suspended time

setStartTime

public void setStartTime(Date startTime)

Overrides:: setStartTime in class JsonCoordinatorJob

getStartTime

public Date getStartTime()

Specified by:: getStartTime in interface org.apache.oozie.client.CoordinatorJob
Specified by:: getStartTime in interface org.apache.oozie.client.Job
Overrides:: getStartTime in class JsonCoordinatorJob

setEndTime

public void setEndTime(Date endTime)

Overrides:: setEndTime in class JsonCoordinatorJob

setPauseTime

public void setPauseTime(Date pauseTime)

Overrides:: setPauseTime in class JsonCoordinatorJob

getEndTime

public Date getEndTime()

Specified by:: getEndTime in interface org.apache.oozie.client.CoordinatorJob
Specified by:: getEndTime in interface org.apache.oozie.client.Job
Overrides:: getEndTime in class JsonCoordinatorJob

getPauseTime

public Date getPauseTime()

Specified by:: getPauseTime in interface org.apache.oozie.client.Job
Overrides:: getPauseTime in class JsonCoordinatorJob

setCreatedTime

public void setCreatedTime(Date createTime)

Set created time

Parameters:: createTime - created time

getCreatedTime

public Date getCreatedTime()

Get created time

Returns:: created time

getCreatedTimestamp

public Timestamp getCreatedTimestamp()

Get created timestamp

Returns:: created timestamp