SchedulerX:JobContext parameters

Basic usage

Access JobContext parameters through getter methods in your job handler:

public class SampleJobProcessor extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        // Job and instance identifiers
        long jobId = context.getJobId();
        long instanceId = context.getJobInstanceId();

        // Scheduling metadata
        DateTime scheduledTime = context.getScheduleTime();
        DateTime dataTime = context.getDataTime();

        // Static parameters configured in the SchedulerX console
        String params = context.getJobParameters();

        // Dynamic parameters passed through API calls
        String dynamicParams = context.getInstanceParameters();

        // Retry state
        int currentAttempt = context.getAttempt();
        int maxRetries = context.getMaxAttempt();

        System.out.println("Job " + jobId + ", instance " + instanceId
            + ", attempt " + currentAttempt + "/" + maxRetries);

        return new ProcessResult(true);
    }
}

Job and instance identifiers

Scheduling times

Job parameters

Retry parameters

Sharding parameters

Available only when Execution mode is set to Broadcast run or Shard run.

Example:

public class ShardJobProcessor extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        Long shardId = context.getShardingId();
        int totalShards = context.getShardingNum();
        String shardParam = context.getShardingParameter();

        System.out.println("Processing shard " + shardId + " of " + totalShards);

        return new ProcessResult(true);
    }
}

Workflow parameters

Available when the job runs as part of a workflow.