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

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.

Field Summary

static String	CONF_BACKWARD_SUPPORT_FOR_COORD_STATUS
static String	CONF_PREFIX
static String	CONF_STATUSTRANSIT_INTERVAL

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

DEFAULT_LOCK_TIMEOUT, lockTimeout, USE_XCOMMAND

Constructor Summary

StatusTransitService()

Method Summary

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_PREFIX

public static final String CONF_PREFIX

See Also:

Constant Field Values

CONF_STATUSTRANSIT_INTERVAL

public static final String CONF_STATUSTRANSIT_INTERVAL

See Also:

Constant Field Values

CONF_BACKWARD_SUPPORT_FOR_COORD_STATUS

public static final String CONF_BACKWARD_SUPPORT_FOR_COORD_STATUS

See Also:

Constant Field Values

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.