LocalityTrigger.java

scheduler.scheduleJob(
    localTrigger(
        newTrigger()
            .forJob("importantJob"))
        .where(node()
            .has(atLeastAvailable(512, MemoryConstraint.Unit.MB)
            .is(OsConstraint.LINUX)))
        .build());

LoclityJob.java

LocalityJobDetail jobDetail =
    localJob(
        newJob(ImportantJob.class)
            .withIdentity("importantJob")
            .build())
        .where(
            node()
                .is(partOfNodeGroup("fastNodes")))
        .build();

quartz.properties

org.quartz.scheduler.instanceName = QuartzWhereScheduler
 
org.quartz.scheduler.instanceId = AUTO
org.quartz.scheduler.instanceIdGenerator.class = org.terracotta.quartz.demo.locality.SystemPropertyIdGenerator
 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
 
org.quartz.jobStore.class = org.terracotta.quartz.EnterpriseTerracottaJobStore
org.quartz.jobStore.tcConfigUrl = localhost:9510

quartzLocality1.properties

org.quartz.locality.nodeGroup.slowNodes = tortoise, snail
org.quartz.locality.nodeGroup.fastNodes = hare, leopard
org.quartz.locality.nodeGroup.linuxNodes = tortoise

quartzLocality2.properties

org.quartz.locality.nodeGroup.fastNodes.triggerGroups = bigJobGroup
org.quartz.locality.nodeGroup.linuxNodes.triggerGroups = reporting