core/src/main/java/org/apache/oozie/BundleActionBean.java
return null;
JSONObject toJSONObject()
String timeZoneId
core/src/main/java/org/apache/oozie/BundleActionBean.java
return null;
JSONObject toJSONObject(String timeZoneId)
core/src/main/java/org/apache/oozie/command/bundle/BundleJobResumeXCommand.java
for (BundleActionBean action : bundleActions) {
            if (action.getStatus() == Job.Status.SUSPENDED || action.getStatus() == Job.Status.SUSPENDEDWITHERROR || action.getStatus() == Job.Status.PREPSUSPENDED) {
                // queue a CoordResumeXCommand
                if (action.getCoordId() != null) {
                    queue(new CoordResumeXCommand(action.getCoordId()));
                    updateBundleAction(action);
                    LOG.debug("Resume bundle action = [{0
void resumeChildren()
BundleActionBean action
core/src/main/java/org/apache/oozie/command/bundle/BundleJobResumeXCommand.java
updateList.add(action);
    public void updateJob() {
        updateList.add(bundleJob);
void updateBundleAction(BundleActionBean action)
core/src/main/java/org/apache/oozie/command/bundle/BundleJobSuspendXCommand.java
updateList.add(bundleJob);
        for (BundleActionBean action : this.bundleActions) {
            if (action.getStatus() == Job.Status.RUNNING || action.getStatus() == Job.Status.RUNNINGWITHERROR
                    || action.getStatus() == Job.Status.PREP || action.getStatus() == Job.Status.PAUSED
                    || action.getStatus() == Job.Status.PAUSEDWITHERROR) {
                // queue a CoordSuspendXCommand
                if (action.getCoordId() != null) {
                    queue(new CoordSuspendXCommand(action.getCoordId()));
                    updateBundleAction(action);
                    LOG.debug("Suspend bundle action = [{0
void updateJob()
BundleActionBean action
core/src/main/java/org/apache/oozie/command/bundle/BundleKillXCommand.java
updateList.add(action);
    public void updateJob() {
        updateList.add(bundleJob);
void updateBundleAction(BundleActionBean action)
BundleActionBean action
core/src/main/java/org/apache/oozie/command/bundle/BundleRerunXCommand.java
updateList.add(action);
    public void updateJob() {
        // rerun a paused bundle job will keep job status at paused and pending at previous pending
        if (getPrevStatus() != null) {
            Job.Status bundleJobStatus = getPrevStatus();
            if (bundleJobStatus.equals(Job.Status.PAUSED) || bundleJobStatus.equals(Job.Status.PAUSEDWITHERROR)) {
                bundleJob.setStatus(bundleJobStatus);
                if (prevPending) {
                    bundleJob.setPending();
void updateBundleAction(BundleActionBean action)
CoordinatorJobBean job  CoordinatorStore store
core/src/main/java/org/apache/oozie/command/coord/CoordActionMaterializeCommand.java
updateList.add(job);
                JPAService jpaService = Services.get().get(JPAService.class);
                if (jpaService != null) {
                    try {
                        jpaService.execute(new BulkUpdateInsertJPAExecutor(updateList, insertList));
void updateJobTable(CoordinatorJobBean job, CoordinatorStore store)
CoordinatorActionBean action  boolean makePending
core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java
updateList.add(action);
        if (actionList != null) {
            for (CoordinatorActionBean action : actionList) {
                // queue a WorkflowKillXCommand to delete the workflow job and actions
                if (action.getExternalId() != null) {
                    queue(new KillXCommand(action.getExternalId()));
                    // As the kill command for children is queued, set pending flag for coord action to be true
                    updateCoordAction(action, true);
                    LOG.debug(
                            "Killed coord action = [{0
void updateCoordAction(CoordinatorActionBean action, boolean makePending)
slaEvent != null
core/src/main/java/org/apache/oozie/command/coord/CoordMaterializeTransitionXCommand.java
insertList.add(slaEvent);
coordJob
        if(slaEvent != null)
core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java
if (getPrevStatus()!= null){
            Job.Status coordJobStatus = getPrevStatus();
            if(coordJobStatus.equals(Job.Status.PAUSED) || coordJobStatus.equals(Job.Status.PAUSEDWITHERROR)) {
                coordJob.setStatus(coordJobStatus);
            if (prevPending) {
                coordJob.setPending();
void updateJob()
core/src/main/java/org/apache/oozie/command/coord/CoordResumeXCommand.java
updateList.add(coordJob);
                updateList.add(coordJob);
    /* (non-Javadoc)
     * @see org.apache.oozie.command.ResumeTransitionXCommand#performWrites()
     */
    @Override
    public void performWrites() throws CommandException {
            jpaService.execute(new BulkUpdateInsertForCoordActionStatusJPAExecutor(updateList, null));
    private void updateCoordAction(CoordinatorActionBean action) {
        action.setStatus(CoordinatorActionBean.Status.RUNNING);
        action.incrementAndGetPending();
        action.setLastModifiedTime(new Date());
        updateList.add(action);
void updateJob()
core/src/main/java/org/apache/oozie/command/coord/CoordSuspendXCommand.java
updateList.add(coordJob);
void updateJob()
String name  String type  int priority  int logMask  boolean withStore
core/src/main/java/org/apache/oozie/command/coord/CoordinatorCommand.java
super(name, type, priority, logMask, withStore);
public CoordinatorCommand(String name, String type, int priority, int logMask, boolean withStore)
String bundleId
core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsDeleteForPurgeJPAExecutor.java
ParamChecker.notNull(bundleId, "bundleId");
        this.bundleId = bundleId;
public BundleActionsDeleteForPurgeJPAExecutor(String bundleId)
core/src/main/java/org/apache/oozie/executor/jpa/BundleActionsDeleteForPurgeJPAExecutor.java
return "BundleActionsDeleteForPurgeJPAExecutor";
String getName()
String bundleJobId
core/src/main/java/org/apache/oozie/executor/jpa/BundleJobDeleteJPAExecutor.java
ParamChecker.notEmpty(bundleJobId, "bundleJobId");
        this.bundleJobId = bundleJobId;
public BundleJobDeleteJPAExecutor(String bundleJobId)
core/src/main/java/org/apache/oozie/executor/jpa/BundleJobDeleteJPAExecutor.java
return "BundleJobDeleteJPAExecutor";
String getName()
CoordinatorActionBean coordAction
core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForStartJPAExecutor.java
ParamChecker.notNull(coordAction, "coordAction");
        this.coordAction = coordAction;
public CoordActionUpdateForStartJPAExecutor(CoordinatorActionBean coordAction)
core/src/main/java/org/apache/oozie/executor/jpa/CoordActionUpdateForStartJPAExecutor.java
return "CoordActionUpdateForStartJPAExecutor";
String getName()
String coordJobId
core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteForPurgeJPAExecutor.java
ParamChecker.notNull(coordJobId, "coordJobId");
        this.coordJobId = coordJobId;
public CoordActionsDeleteForPurgeJPAExecutor(String coordJobId)
core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteForPurgeJPAExecutor.java
return "CoordActionsDeleteForPurgeJPAExecutor";
String getName()
String wfId
core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsDeleteForPurgeJPAExecutor.java
ParamChecker.notNull(wfId, "wfId");
        this.wfId = wfId;
public WorkflowActionsDeleteForPurgeJPAExecutor(String wfId)
core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsDeleteForPurgeJPAExecutor.java
return "WorkflowActionsDeleteForPurgeJPAExecutor";
String getName()