Package com.floragunn.searchsupport.jobs.core

Class IndexJobStateStore<JobType extends JobConfig>

java.lang.Object

com.floragunn.searchsupport.jobs.core.IndexJobStateStore<JobType>

All Implemented Interfaces:

DistributedJobStore, org.quartz.spi.JobStore

public class IndexJobStateStore<JobType extends JobConfig>
extends Object
implements DistributedJobStore

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	includeNodeIdInSchedulerToJobStoreMapKeys	For unit testing in environments where several nodes run in one JVM.

Constructor Summary

Constructors

Constructor	Description
IndexJobStateStore(String schedulerName, String statusIndexName, String statusIndexIdPrefix, String nodeId, org.elasticsearch.client.Client client, Iterable<JobType> jobConfigSource, JobConfigFactory<JobType> jobFactory, org.elasticsearch.cluster.service.ClusterService clusterService, Collection<JobConfigListener<JobType>> jobConfigListeners)

Method Summary

Modifier and Type	Method	Description
List<org.quartz.spi.OperableTrigger>	acquireNextTriggers(long noLaterThan, int maxCount, long timeWindow)
void	addJobConfigListener(JobConfigListener<JobType> jobCofigListener)
boolean	checkExists(org.quartz.JobKey jobKey)
boolean	checkExists(org.quartz.TriggerKey triggerKey)
void	clearAllSchedulingData()
void	clusterConfigChanged(org.elasticsearch.cluster.ClusterChangedEvent event)
long	getAcquireRetryDelay(int failureCount)
List<String>	getCalendarNames()
long	getEstimatedTimeToReleaseAndAcquireTrigger()
static IndexJobStateStore<?>	getInstanceBySchedulerName(String nodeId, String schedulerName)
List<String>	getJobGroupNames()
Set<org.quartz.JobKey>	getJobKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> matcher)
String	getNodeId()
int	getNumberOfCalendars()
int	getNumberOfJobs()
int	getNumberOfTriggers()
Set<String>	getPausedTriggerGroups()
List<String>	getTriggerGroupNames()
Set<org.quartz.TriggerKey>	getTriggerKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
List<org.quartz.spi.OperableTrigger>	getTriggersForJob(org.quartz.JobKey jobKey)
org.quartz.Trigger.TriggerState	getTriggerState(org.quartz.TriggerKey triggerKey)
void	initialize(org.quartz.spi.ClassLoadHelper loadHelper, org.quartz.spi.SchedulerSignaler signaler)
boolean	isClustered()
boolean	isInitialized()
void	pauseAll()
void	pauseJob(org.quartz.JobKey jobKey)
Collection<String>	pauseJobs(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> groupMatcher)
void	pauseTrigger(org.quartz.TriggerKey triggerKey)
Collection<String>	pauseTriggers(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
void	releaseAcquiredTrigger(org.quartz.spi.OperableTrigger trigger)
boolean	removeCalendar(String calName)
boolean	removeJob(org.quartz.JobKey jobKey)
boolean	removeJobs(List<org.quartz.JobKey> jobKeys)
boolean	removeTrigger(org.quartz.TriggerKey triggerKey)
boolean	removeTriggers(List<org.quartz.TriggerKey> triggerKeys)
boolean	replaceTrigger(org.quartz.TriggerKey triggerKey, org.quartz.spi.OperableTrigger newTrigger)
void	resetTriggerFromErrorState(org.quartz.TriggerKey triggerKey)
void	resumeAll()
void	resumeJob(org.quartz.JobKey jobKey)
Collection<String>	resumeJobs(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> groupMatcher)
void	resumeTrigger(org.quartz.TriggerKey triggerKey)
Collection<String>	resumeTriggers(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
org.quartz.Calendar	retrieveCalendar(String calName)
org.quartz.JobDetail	retrieveJob(org.quartz.JobKey jobKey)
org.quartz.spi.OperableTrigger	retrieveTrigger(org.quartz.TriggerKey triggerKey)
void	schedulerPaused()
void	schedulerResumed()
void	schedulerStarted()
void	setInstanceId(String schedInstId)
void	setInstanceName(String schedName)
void	setThreadPoolSize(int poolSize)
void	shutdown()
void	storeCalendar(String name, org.quartz.Calendar calendar, boolean replaceExisting, boolean updateTriggers)
void	storeJob(org.quartz.JobDetail newJob, boolean replaceExisting)
void	storeJobAndTrigger(org.quartz.JobDetail newJob, org.quartz.spi.OperableTrigger newTrigger)
void	storeJobsAndTriggers(Map<org.quartz.JobDetail,Set<? extends org.quartz.Trigger>> triggersAndJobs, boolean replace)
void	storeTrigger(org.quartz.spi.OperableTrigger newTrigger, boolean replaceExisting)
boolean	supportsPersistence()
String	toString()
void	triggeredJobComplete(org.quartz.spi.OperableTrigger trigger, org.quartz.JobDetail jobDetail, org.quartz.Trigger.CompletedExecutionInstruction triggerInstCode)
List<org.quartz.spi.TriggerFiredResult>	triggersFired(List<org.quartz.spi.OperableTrigger> firedTriggers)
String	updateJobs()

Methods inherited from class java.lang.Object

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

Field Detail

includeNodeIdInSchedulerToJobStoreMapKeys

public static boolean includeNodeIdInSchedulerToJobStoreMapKeys

For unit testing in environments where several nodes run in one JVM.

Constructor Detail

IndexJobStateStore

public IndexJobStateStore(String schedulerName,
                          String statusIndexName,
                          String statusIndexIdPrefix,
                          String nodeId,
                          org.elasticsearch.client.Client client,
                          Iterable<JobType> jobConfigSource,
                          JobConfigFactory<JobType> jobFactory,
                          org.elasticsearch.cluster.service.ClusterService clusterService,
                          Collection<JobConfigListener<JobType>> jobConfigListeners)

Method Detail

getInstanceBySchedulerName

public static IndexJobStateStore<?> getInstanceBySchedulerName(String nodeId,
                                                               String schedulerName)

clusterConfigChanged

public void clusterConfigChanged(org.elasticsearch.cluster.ClusterChangedEvent event)

Specified by:

clusterConfigChanged in interface DistributedJobStore

initialize

public void initialize(org.quartz.spi.ClassLoadHelper loadHelper,
                       org.quartz.spi.SchedulerSignaler signaler)
                throws org.quartz.SchedulerConfigException

Specified by:

initialize in interface org.quartz.spi.JobStore

Throws:

org.quartz.SchedulerConfigException

schedulerStarted

public void schedulerStarted()
                      throws org.quartz.SchedulerException

Specified by:

schedulerStarted in interface org.quartz.spi.JobStore

Throws:

org.quartz.SchedulerException

schedulerPaused

public void schedulerPaused()

Specified by:

schedulerPaused in interface org.quartz.spi.JobStore

schedulerResumed

public void schedulerResumed()

Specified by:

schedulerResumed in interface org.quartz.spi.JobStore

shutdown

public void shutdown()

Specified by:

shutdown in interface org.quartz.spi.JobStore

supportsPersistence

public boolean supportsPersistence()

Specified by:

supportsPersistence in interface org.quartz.spi.JobStore

getEstimatedTimeToReleaseAndAcquireTrigger

public long getEstimatedTimeToReleaseAndAcquireTrigger()

Specified by:

getEstimatedTimeToReleaseAndAcquireTrigger in interface org.quartz.spi.JobStore

isClustered

public boolean isClustered()

Specified by:

isClustered in interface org.quartz.spi.JobStore

storeJobAndTrigger

public void storeJobAndTrigger(org.quartz.JobDetail newJob,
                               org.quartz.spi.OperableTrigger newTrigger)
                        throws org.quartz.ObjectAlreadyExistsException,
                               org.quartz.JobPersistenceException

Specified by:

storeJobAndTrigger in interface org.quartz.spi.JobStore

Throws:

org.quartz.ObjectAlreadyExistsException

org.quartz.JobPersistenceException

storeJob

public void storeJob(org.quartz.JobDetail newJob,
                     boolean replaceExisting)
              throws org.quartz.ObjectAlreadyExistsException,
                     org.quartz.JobPersistenceException

Specified by:

storeJob in interface org.quartz.spi.JobStore

Throws:

org.quartz.ObjectAlreadyExistsException

org.quartz.JobPersistenceException

storeJobsAndTriggers

public void storeJobsAndTriggers(Map<org.quartz.JobDetail,Set<? extends org.quartz.Trigger>> triggersAndJobs,
                                 boolean replace)
                          throws org.quartz.ObjectAlreadyExistsException,
                                 org.quartz.JobPersistenceException

Specified by:

storeJobsAndTriggers in interface org.quartz.spi.JobStore

Throws:

org.quartz.ObjectAlreadyExistsException

org.quartz.JobPersistenceException

storeTrigger

public void storeTrigger(org.quartz.spi.OperableTrigger newTrigger,
                         boolean replaceExisting)
                  throws org.quartz.ObjectAlreadyExistsException,
                         org.quartz.JobPersistenceException

Specified by:

storeTrigger in interface org.quartz.spi.JobStore

Throws:

org.quartz.ObjectAlreadyExistsException

org.quartz.JobPersistenceException

removeJob

public boolean removeJob(org.quartz.JobKey jobKey)

Specified by:

removeJob in interface org.quartz.spi.JobStore

removeJobs

public boolean removeJobs(List<org.quartz.JobKey> jobKeys)
                   throws org.quartz.JobPersistenceException

Specified by:

removeJobs in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

removeTrigger

public boolean removeTrigger(org.quartz.TriggerKey triggerKey)

Specified by:

removeTrigger in interface org.quartz.spi.JobStore

removeTriggers

public boolean removeTriggers(List<org.quartz.TriggerKey> triggerKeys)
                       throws org.quartz.JobPersistenceException

Specified by:

removeTriggers in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

replaceTrigger

public boolean replaceTrigger(org.quartz.TriggerKey triggerKey,
                              org.quartz.spi.OperableTrigger newTrigger)
                       throws org.quartz.JobPersistenceException

Specified by:

replaceTrigger in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

retrieveJob

public org.quartz.JobDetail retrieveJob(org.quartz.JobKey jobKey)
                                 throws org.quartz.JobPersistenceException

Specified by:

retrieveJob in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

retrieveTrigger

public org.quartz.spi.OperableTrigger retrieveTrigger(org.quartz.TriggerKey triggerKey)
                                               throws org.quartz.JobPersistenceException

Specified by:

retrieveTrigger in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

checkExists

public boolean checkExists(org.quartz.JobKey jobKey)
                    throws org.quartz.JobPersistenceException

Specified by:

checkExists in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

checkExists

public boolean checkExists(org.quartz.TriggerKey triggerKey)
                    throws org.quartz.JobPersistenceException

Specified by:

checkExists in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

clearAllSchedulingData

public void clearAllSchedulingData()
                            throws org.quartz.JobPersistenceException

Specified by:

clearAllSchedulingData in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

storeCalendar

public void storeCalendar(String name,
                          org.quartz.Calendar calendar,
                          boolean replaceExisting,
                          boolean updateTriggers)
                   throws org.quartz.ObjectAlreadyExistsException,
                          org.quartz.JobPersistenceException

Specified by:

storeCalendar in interface org.quartz.spi.JobStore

Throws:

org.quartz.ObjectAlreadyExistsException

org.quartz.JobPersistenceException

removeCalendar

public boolean removeCalendar(String calName)
                       throws org.quartz.JobPersistenceException

Specified by:

removeCalendar in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

retrieveCalendar

public org.quartz.Calendar retrieveCalendar(String calName)

Specified by:

retrieveCalendar in interface org.quartz.spi.JobStore

getNumberOfJobs

public int getNumberOfJobs()
                    throws org.quartz.JobPersistenceException

Specified by:

getNumberOfJobs in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getNumberOfTriggers

public int getNumberOfTriggers()
                        throws org.quartz.JobPersistenceException

Specified by:

getNumberOfTriggers in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getNumberOfCalendars

public int getNumberOfCalendars()
                         throws org.quartz.JobPersistenceException

Specified by:

getNumberOfCalendars in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getJobKeys

public Set<org.quartz.JobKey> getJobKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> matcher)
                                  throws org.quartz.JobPersistenceException

Specified by:

getJobKeys in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getTriggerKeys

public Set<org.quartz.TriggerKey> getTriggerKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
                                          throws org.quartz.JobPersistenceException

Specified by:

getTriggerKeys in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getJobGroupNames

public List<String> getJobGroupNames()
                              throws org.quartz.JobPersistenceException

Specified by:

getJobGroupNames in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getTriggerGroupNames

public List<String> getTriggerGroupNames()
                                  throws org.quartz.JobPersistenceException

Specified by:

getTriggerGroupNames in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getCalendarNames

public List<String> getCalendarNames()
                              throws org.quartz.JobPersistenceException

Specified by:

getCalendarNames in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getTriggersForJob

public List<org.quartz.spi.OperableTrigger> getTriggersForJob(org.quartz.JobKey jobKey)

Specified by:

getTriggersForJob in interface org.quartz.spi.JobStore

getTriggerState

public org.quartz.Trigger.TriggerState getTriggerState(org.quartz.TriggerKey triggerKey)
                                                throws org.quartz.JobPersistenceException

Specified by:

getTriggerState in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

resetTriggerFromErrorState

public void resetTriggerFromErrorState(org.quartz.TriggerKey triggerKey)
                                throws org.quartz.JobPersistenceException

Specified by:

resetTriggerFromErrorState in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

pauseTrigger

public void pauseTrigger(org.quartz.TriggerKey triggerKey)
                  throws org.quartz.JobPersistenceException

Specified by:

pauseTrigger in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

pauseTriggers

public Collection<String> pauseTriggers(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
                                 throws org.quartz.JobPersistenceException

Specified by:

pauseTriggers in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

pauseJob

public void pauseJob(org.quartz.JobKey jobKey)
              throws org.quartz.JobPersistenceException

Specified by:

pauseJob in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

pauseJobs

public Collection<String> pauseJobs(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> groupMatcher)
                             throws org.quartz.JobPersistenceException

Specified by:

pauseJobs in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

resumeTrigger

public void resumeTrigger(org.quartz.TriggerKey triggerKey)
                   throws org.quartz.JobPersistenceException

Specified by:

resumeTrigger in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

resumeTriggers

public Collection<String> resumeTriggers(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
                                  throws org.quartz.JobPersistenceException

Specified by:

resumeTriggers in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

getPausedTriggerGroups

public Set<String> getPausedTriggerGroups()
                                   throws org.quartz.JobPersistenceException

Specified by:

getPausedTriggerGroups in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

resumeJob

public void resumeJob(org.quartz.JobKey jobKey)
               throws org.quartz.JobPersistenceException

Specified by:

resumeJob in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

resumeJobs

public Collection<String> resumeJobs(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> groupMatcher)
                              throws org.quartz.JobPersistenceException

Specified by:

resumeJobs in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

pauseAll

public void pauseAll()
              throws org.quartz.JobPersistenceException

Specified by:

pauseAll in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

resumeAll

public void resumeAll()
               throws org.quartz.JobPersistenceException

Specified by:

resumeAll in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

acquireNextTriggers

public List<org.quartz.spi.OperableTrigger> acquireNextTriggers(long noLaterThan,
                                                                int maxCount,
                                                                long timeWindow)
                                                         throws org.quartz.JobPersistenceException

Specified by:

acquireNextTriggers in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

releaseAcquiredTrigger

public void releaseAcquiredTrigger(org.quartz.spi.OperableTrigger trigger)

Specified by:

releaseAcquiredTrigger in interface org.quartz.spi.JobStore

triggersFired

public List<org.quartz.spi.TriggerFiredResult> triggersFired(List<org.quartz.spi.OperableTrigger> firedTriggers)
                                                      throws org.quartz.JobPersistenceException

Specified by:

triggersFired in interface org.quartz.spi.JobStore

Throws:

org.quartz.JobPersistenceException

triggeredJobComplete

public void triggeredJobComplete(org.quartz.spi.OperableTrigger trigger,
                                 org.quartz.JobDetail jobDetail,
                                 org.quartz.Trigger.CompletedExecutionInstruction triggerInstCode)

Specified by:

triggeredJobComplete in interface org.quartz.spi.JobStore

setInstanceId

public void setInstanceId(String schedInstId)

Specified by:

setInstanceId in interface org.quartz.spi.JobStore

setInstanceName

public void setInstanceName(String schedName)

Specified by:

setInstanceName in interface org.quartz.spi.JobStore

setThreadPoolSize

public void setThreadPoolSize(int poolSize)

Specified by:

setThreadPoolSize in interface org.quartz.spi.JobStore

getAcquireRetryDelay

public long getAcquireRetryDelay(int failureCount)

Specified by:

getAcquireRetryDelay in interface org.quartz.spi.JobStore

getNodeId

public String getNodeId()

updateJobs

public String updateJobs()

addJobConfigListener

public void addJobConfigListener(JobConfigListener<JobType> jobCofigListener)

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface DistributedJobStore

toString

public String toString()

Overrides:

toString in class Object