org.apache.oozie.service

Class PauseTransitService

java.lang.Object

org.apache.oozie.service.PauseTransitService

All Implemented Interfaces:

Service

public class PauseTransitService
extends Object
implements Service

PauseTransitService is the runnable which is scheduled to run at the configured interval, it checks all bundles to see if they should be paused, un-paused or started.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PauseTransitService.PauseTransitRunnable PauseTransitRunnable is the runnable which is scheduled to run at the configured interval, it checks all bundles to see if they should be paused, un-paused or started.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_BUNDLE_PAUSE_START_INTERVAL
static String	CONF_CALLABLE_BATCH_SIZE
static String	CONF_PREFIX

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

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
PauseTransitService()

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

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_BUNDLE_PAUSE_START_INTERVAL

public static final String CONF_BUNDLE_PAUSE_START_INTERVAL

See Also:

Constant Field Values

CONF_CALLABLE_BATCH_SIZE

public static final String CONF_CALLABLE_BATCH_SIZE

See Also:

Constant Field Values

Constructor Detail

PauseTransitService

public PauseTransitService()

Method Detail

init

public void init(Services services)

Initializes the PauseTransitService.

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:

PauseTransitService.