public interface JobScheduleManager
Modifier and Type | Method and Description |
---|---|
void |
deleteJobSchedule(java.lang.String name,
java.lang.String group)
Delete a name/group from the scheduler
|
java.util.Date |
scheduleJob(java.lang.String name,
java.lang.String group,
java.util.Map data,
java.util.Date atTime)
Schedule a job for a certain time
|
boolean |
scheduleJobNow(java.lang.String name,
java.lang.String group,
java.util.Map data)
Schedule a job to run now
|
boolean |
updateScheduleOwner(java.lang.String name,
java.lang.String group,
java.util.Map data)
In cluster mode, return true if the scheduleOWner should change to current node.
|
void deleteJobSchedule(java.lang.String name, java.lang.String group)
name
- namegroup
- groupjava.util.Date scheduleJob(java.lang.String name, java.lang.String group, java.util.Map data, java.util.Date atTime) throws JobScheduleFailure
name
- namegroup
- groupdata
- dataatTime
- time to runJobScheduleFailure
boolean scheduleJobNow(java.lang.String name, java.lang.String group, java.util.Map data) throws JobScheduleFailure
name
- namegroup
- groupdata
- dataJobScheduleFailure
boolean updateScheduleOwner(java.lang.String name, java.lang.String group, java.util.Map data)
name
- job namegroup
- job groupdata
- map with job information, jobid and current schedule owner.