org.apache.ambari.server.scheduler

Class ExecutionSchedulerImpl

java.lang.Object

org.apache.ambari.server.scheduler.ExecutionSchedulerImpl

All Implemented Interfaces:

ExecutionScheduler

public class ExecutionSchedulerImpl
extends Object
implements ExecutionScheduler

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	DEFAULT_SCHEDULER_NAME
protected static boolean	isInitialized
protected org.quartz.Scheduler	scheduler

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ExecutionSchedulerImpl(Configuration configuration) Constructor used for unit testing
	ExecutionSchedulerImpl(com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
void	addJob(org.quartz.JobDetail jobDetail) Persist job data
void	deleteJob(org.quartz.JobKey jobKey) Delete the identified Job from the Scheduler - and any associated Triggers.
org.quartz.JobDetail	getJobDetail(org.quartz.JobKey jobKey) Get details for a job from scheduler.
protected String[]	getQuartzDbDelegateClassAndValidationQuery()
protected Properties	getQuartzSchedulerProperties()
List<? extends org.quartz.Trigger>	getTriggersForJob(org.quartz.JobKey jobKey) Get all triggers created for a job.
protected void	initializeScheduler()
protected boolean	isInitialized()
boolean	isSchedulerStarted() Check whether the scheduler is already running.
void	scheduleJob(org.quartz.Trigger trigger) Add a trigger to the execution scheduler
void	startScheduler(Integer delay) Initialize and start the scheduler to accept jobs.
void	stopScheduler() Shutdown the scheduler threads and do not accept any more jobs.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SCHEDULER_NAME

protected static final String DEFAULT_SCHEDULER_NAME

See Also:

Constant Field Values

scheduler

protected org.quartz.Scheduler scheduler

isInitialized

protected static volatile boolean isInitialized

Constructor Detail

ExecutionSchedulerImpl

@Inject
public ExecutionSchedulerImpl(com.google.inject.Injector injector)

ExecutionSchedulerImpl

protected ExecutionSchedulerImpl(Configuration configuration)

Constructor used for unit testing

Parameters:

configuration -

Method Detail

initializeScheduler

protected void initializeScheduler()

getQuartzSchedulerProperties

protected Properties getQuartzSchedulerProperties()

isInitialized

protected boolean isInitialized()

getQuartzDbDelegateClassAndValidationQuery

protected String[] getQuartzDbDelegateClassAndValidationQuery()

startScheduler

public void startScheduler(Integer delay)
                    throws org.apache.ambari.server.AmbariException

Description copied from interface: ExecutionScheduler

Initialize and start the scheduler to accept jobs.

Specified by:

startScheduler in interface ExecutionScheduler

Throws:

org.apache.ambari.server.AmbariException

stopScheduler

public void stopScheduler()
                   throws org.apache.ambari.server.AmbariException

Description copied from interface: ExecutionScheduler

Shutdown the scheduler threads and do not accept any more jobs.

Specified by:

stopScheduler in interface ExecutionScheduler

Throws:

org.apache.ambari.server.AmbariException

scheduleJob

public void scheduleJob(org.quartz.Trigger trigger)
                 throws org.quartz.SchedulerException

Description copied from interface: ExecutionScheduler

Add a trigger to the execution scheduler

Specified by:

scheduleJob in interface ExecutionScheduler

Throws:

org.quartz.SchedulerException

addJob

public void addJob(org.quartz.JobDetail jobDetail)
            throws org.quartz.SchedulerException

Description copied from interface: ExecutionScheduler

Persist job data

Specified by:

addJob in interface ExecutionScheduler

Throws:

org.quartz.SchedulerException

deleteJob

public void deleteJob(org.quartz.JobKey jobKey)
               throws org.quartz.SchedulerException

Description copied from interface: ExecutionScheduler

Delete the identified Job from the Scheduler - and any associated Triggers.

Specified by:

deleteJob in interface ExecutionScheduler

Throws:

org.quartz.SchedulerException

getJobDetail

public org.quartz.JobDetail getJobDetail(org.quartz.JobKey jobKey)
                                  throws org.quartz.SchedulerException

Description copied from interface: ExecutionScheduler

Get details for a job from scheduler.

Specified by:

getJobDetail in interface ExecutionScheduler

Returns:

Throws:

org.quartz.SchedulerException

getTriggersForJob

public List<? extends org.quartz.Trigger> getTriggersForJob(org.quartz.JobKey jobKey)
                                                     throws org.quartz.SchedulerException

Description copied from interface: ExecutionScheduler

Get all triggers created for a job.

Specified by:

getTriggersForJob in interface ExecutionScheduler

Returns:

Throws:

org.quartz.SchedulerException

isSchedulerStarted

public boolean isSchedulerStarted()
                           throws org.quartz.SchedulerException

Description copied from interface: ExecutionScheduler

Check whether the scheduler is already running.

Specified by:

isSchedulerStarted in interface ExecutionScheduler

Returns:

Throws:

org.quartz.SchedulerException