org.apache.oozie.service

Class StatusTransitService.StatusTransitRunnable

java.lang.Object

org.apache.oozie.service.StatusTransitService.StatusTransitRunnable

All Implemented Interfaces:

Runnable

Enclosing class:

StatusTransitService

public static class StatusTransitService.StatusTransitRunnable
extends Object
implements Runnable

StateTransitRunnable is the runnable which is scheduled to run at the configured interval.

It is to update job's status according to its child actions' status. If all child actions' pending flag equals 0 (job done), we reset the job's pending flag to 0. If all child actions are succeeded, we set the job's status to SUCCEEDED.

Constructor Summary

Constructors

Constructor and Description
StatusTransitService.StatusTransitRunnable()

Method Summary

Methods

Modifier and Type	Method and Description
List<BundleJobBean>	removeDuplicates(List<BundleJobBean> pendingJobList)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusTransitService.StatusTransitRunnable

public StatusTransitService.StatusTransitRunnable()

Method Detail

run

public void run()

Specified by:

run in interface Runnable

removeDuplicates

public List<BundleJobBean> removeDuplicates(List<BundleJobBean> pendingJobList)