Class LockingJobScheduler

  • All Implemented Interfaces:
    HeartBeatJobScheduler

    public class LockingJobScheduler
    extends QuartzJobScheduler
    The scheduler is responsible for the scheduling and unscheduling of locking jobs LockingJob. Only one repository node in a cluster will collect data for collectors with this type of job.
    • Constructor Detail

      • LockingJobScheduler

        public LockingJobScheduler()
    • Method Detail

      • setJobLockService

        public void setJobLockService​(JobLockService jobLockService)
      • getJobDetailMap

        protected org.quartz.JobDataMap getJobDetailMap​(HBBaseDataCollector collector)
        Description copied from class: QuartzJobScheduler
        This method is called when a job is being scheduled by this scheduler for the given collector.
        The job is scheduled using the Job returned from QuartzJobScheduler.getHeartBeatJobClass() and the job map returned from this method, therefor the job map should provide what the job needs to execute.
        Specified by:
        getJobDetailMap in class QuartzJobScheduler
        Parameters:
        collector - The collector whose job is being scheduled.
        Returns:
        The job map returned from this method will be used to build up JobDetail for the job that is being scheduled.
      • getHeartBeatJobClass

        protected java.lang.Class<? extends org.quartz.Job> getHeartBeatJobClass()
        Description copied from class: QuartzJobScheduler
        Jobs scheduled by the scheduler will use the returned implementation of Job.
        The jobs are scheduled together with a JobDataMap returned from QuartzJobScheduler.getJobDetailMap(HBBaseDataCollector)
        which will be accessible during job execution.
        Specified by:
        getHeartBeatJobClass in class QuartzJobScheduler
        Returns:
        Job implementation which this scheduler will use to schedule jobs for heartbeat collectors.