org.apache.oozie.service

Class StatusTransitService

java.lang.Object

org.apache.oozie.service.StatusTransitService

All Implemented Interfaces:

Service

public class StatusTransitService
extends Object
implements Service

StateTransitService 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StatusTransitService.StatusTransitRunnable StateTransitRunnable is the runnable which is scheduled to run at the configured interval.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_BACKWARD_SUPPORT_FOR_COORD_STATUS
static String	CONF_BACKWARD_SUPPORT_FOR_STATES_WITHOUT_ERROR
static Date	lastInstanceStartTime
static int	limit
static XLog	LOG

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
StatusTransitService()

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroy the StateTransit Jobs Service.
Class<? extends Service>	getInterface() Return the public interface for the purge jobs service.
void	init(Services services) Initializes the StatusTransitService.

Methods inherited from class java.lang.Object

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

Field Detail

CONF_BACKWARD_SUPPORT_FOR_COORD_STATUS

public static final String CONF_BACKWARD_SUPPORT_FOR_COORD_STATUS

See Also:

Constant Field Values

CONF_BACKWARD_SUPPORT_FOR_STATES_WITHOUT_ERROR

public static final String CONF_BACKWARD_SUPPORT_FOR_STATES_WITHOUT_ERROR

See Also:

Constant Field Values

limit

public static int limit

lastInstanceStartTime

public static Date lastInstanceStartTime

LOG

public static final XLog LOG

Constructor Detail

StatusTransitService

public StatusTransitService()

Method Detail

init

public void init(Services services)

Initializes the StatusTransitService.

Specified by:

init in interface Service

Parameters:

services - services instance.

destroy

public void destroy()

Destroy the StateTransit Jobs Service.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Return the public interface for the purge jobs service.

Specified by:

getInterface in interface Service

Returns:

StatusTransitService.