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

StatusTransitService.StatusTransitRunnable()

Method Summary

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)