org.apache.ambari.server.scheduler

Interface ExecutionScheduler

All Known Implementing Classes:

ExecutionSchedulerImpl

public interface ExecutionScheduler

Method Summary

Modifier and Type	Method and Description
void	addJob(org.quartz.JobDetail job) 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.
List<? extends org.quartz.Trigger>	getTriggersForJob(org.quartz.JobKey jobKey) Get all triggers created for a job.
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.

Method Detail

startScheduler

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

Initialize and start the scheduler to accept jobs.

Throws:

org.apache.ambari.server.AmbariException

stopScheduler

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

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

Throws:

org.apache.ambari.server.AmbariException

scheduleJob

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

Add a trigger to the execution scheduler

Parameters:

trigger -

Throws:

org.quartz.SchedulerException

addJob

void addJob(org.quartz.JobDetail job)
     throws org.quartz.SchedulerException

Persist job data

Parameters:

job -

Throws:

org.quartz.SchedulerException

deleteJob

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

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

Parameters:

jobKey -

Throws:

org.quartz.SchedulerException

getJobDetail

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

Get details for a job from scheduler.

Parameters:

jobKey -

Returns:

Throws:

org.quartz.SchedulerException

getTriggersForJob

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

Get all triggers created for a job.

Parameters:

jobKey -

Returns:

Throws:

org.quartz.SchedulerException

isSchedulerStarted

boolean isSchedulerStarted()
                    throws org.quartz.SchedulerException

Check whether the scheduler is already running.

Returns:

Throws:

org.quartz.SchedulerException