Class NonLockingJobScheduler

  • All Implemented Interfaces:
    HeartBeatJobScheduler

    public class NonLockingJobScheduler
    extends QuartzJobScheduler
    This scheduler is responsible for the scheduling and unscheduling of non locking jobs NonLockingJob. All repository nodes in a cluster will send data for collectors which have jobs scheduled by this scheduler.
    Author:
    eknizat
    • Constructor Detail

      • NonLockingJobScheduler

        public NonLockingJobScheduler()
    • Method Detail

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