Modifier and Type | Method and Description |
---|---|
static SchedulerJobHandle |
SchedulerJobHandle.fromString(String handle)
From string.
|
SchedulerJobHandle |
SchedulerJobInfo.getId()
ID of the job.
|
SchedulerJobHandle |
SchedulerJobInstanceInfo.getJobId() |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerJobInfo.setId(SchedulerJobHandle id)
ID of the job.
|
void |
SchedulerJobInstanceInfo.setJobId(SchedulerJobHandle jobId) |
Constructor and Description |
---|
SchedulerJobInfo(SchedulerJobHandle id,
XJob job,
String userName,
SchedulerJobState jobState,
long createdOn,
long modifiedOn) |
SchedulerJobInstanceInfo(SchedulerJobInstanceHandle id,
SchedulerJobHandle jobId,
long scheduleTime,
List<SchedulerJobInstanceRun> instanceRunList) |
Modifier and Type | Method and Description |
---|---|
SchedulerJobHandle |
SchedulerAlarmEvent.getJobHandle()
jobHandle for which the alarm needs to be triggered.
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulerAlarmEvent.setJobHandle(SchedulerJobHandle jobHandle)
jobHandle for which the alarm needs to be triggered.
|
Constructor and Description |
---|
SchedulerAlarmEvent(SchedulerJobHandle jobHandle,
org.joda.time.DateTime nominalTime,
SchedulerAlarmEvent.EventType type,
SchedulerJobInstanceHandle previousInstance) |
Modifier and Type | Method and Description |
---|---|
SchedulerJobHandle |
SchedulerService.submitAndScheduleJob(LensSessionHandle sessionHandle,
XJob job)
Submit a job and also schedule it.
|
SchedulerJobHandle |
SchedulerService.submitJob(LensSessionHandle sessionHandle,
XJob job)
Submit a job.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SchedulerService.deleteJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Delete a job.
|
boolean |
SchedulerService.expireJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
End a job by specifying an expiry time.
|
XJob |
SchedulerService.getJobDefinition(SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
SchedulerJobInfo |
SchedulerService.getJobDetails(SchedulerJobHandle jobHandle)
Returns the details of a job.
|
List<SchedulerJobInstanceInfo> |
SchedulerService.getJobInstances(SchedulerJobHandle jobHandle,
Long numResults)
Returns handles for last
numResults instances for the job. |
SchedulerJobStats |
SchedulerService.getJobStats(SchedulerJobHandle handle,
String state,
long startTime,
long endTime)
Returns stats for a job.
|
boolean |
SchedulerService.resumeJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Resume a job from a given time.
|
boolean |
SchedulerService.scheduleJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Schedule a job.
|
boolean |
SchedulerService.suspendJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Suspend a job.
|
boolean |
SchedulerService.updateJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
XJob newJobDefinition)
Update a job with new definition.
|
Modifier and Type | Method and Description |
---|---|
SchedulerJobHandle |
SchedulerServiceImpl.submitAndScheduleJob(LensSessionHandle sessionHandle,
XJob job) |
SchedulerJobHandle |
ScheduleResource.submitJob(LensSessionHandle sessionId,
String action,
XJob job) |
SchedulerJobHandle |
SchedulerServiceImpl.submitJob(LensSessionHandle sessionHandle,
XJob job)
Submit a job.
|
Modifier and Type | Method and Description |
---|---|
List<SchedulerJobHandle> |
SchedulerDAO.getJob(String jobName)
Get the handle given the job name.
|
List<SchedulerJobHandle> |
SchedulerDAO.getJobs(String username,
SchedulerJobState jobState,
Long startTime,
Long endTime)
Gets all jobs which match the filter requirements.
|
List<SchedulerJobHandle> |
SchedulerDAO.SchedulerDBStore.getJobs(String username,
String status,
Long starttime,
Long endtime)
Gets all the jobs which match the filter requirements.
|
List<SchedulerJobHandle> |
SchedulerDAO.SchedulerDBStore.getJobsByName(String jobname)
Get the job handles given the job name
|
Modifier and Type | Method and Description |
---|---|
boolean |
AlarmService.checkExists(SchedulerJobHandle handle) |
boolean |
SchedulerServiceImpl.deleteJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Delete a job.
|
APIResult |
ScheduleResource.deleteJob(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle) |
boolean |
SchedulerServiceImpl.expireJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
End a job by specifying an expiry time.
|
XJob |
SchedulerDAO.getJob(SchedulerJobHandle id)
Gets the job definition from the store
|
JAXBElement<XJob> |
ScheduleResource.getJobDefinition(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle) |
XJob |
SchedulerServiceImpl.getJobDefinition(SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
SchedulerJobInfo |
ScheduleResource.getJobDetails(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle) |
SchedulerJobInfo |
SchedulerServiceImpl.getJobDetails(SchedulerJobHandle jobHandle)
Returns the details of a job.
|
List<SchedulerJobInstanceInfo> |
ScheduleResource.getJobInstances(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle,
Long numResults) |
List<SchedulerJobInstanceInfo> |
SchedulerDAO.getJobInstances(SchedulerJobHandle id)
Gets all the instance handle id for a job.
|
List<SchedulerJobInstanceInfo> |
SchedulerServiceImpl.getJobInstances(SchedulerJobHandle jobHandle,
Long numResults)
Returns handles for last
numResults instances for the job. |
SchedulerJobState |
SchedulerDAO.getJobState(SchedulerJobHandle id)
Gets the Job status
|
SchedulerJobStats |
SchedulerServiceImpl.getJobStats(SchedulerJobHandle handle,
String state,
long startTime,
long endTime)
Returns stats for a job.
|
SchedulerJobInfo |
SchedulerDAO.getSchedulerJobInfo(SchedulerJobHandle id)
Fetches the SchedulerJobInfo object corresponding to handle id.
|
String |
SchedulerDAO.getUser(SchedulerJobHandle id)
Get the user of the job who submitted the job.
|
void |
AlarmService.pauseJob(SchedulerJobHandle jobHandle) |
boolean |
SchedulerServiceImpl.resumeJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Resume a job from a given time.
|
void |
AlarmService.resumeJob(SchedulerJobHandle jobHandle) |
void |
LensScheduler.schedule(SchedulerJobHandle handle,
XJob job) |
boolean |
SchedulerServiceImpl.scheduleJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Schedule a job.
|
boolean |
SchedulerServiceImpl.suspendJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Suspend a job.
|
boolean |
AlarmService.unSchedule(SchedulerJobHandle jobHandle) |
APIResult |
ScheduleResource.updateJob(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle,
ScheduleResource.JOB_ACTIONS action) |
boolean |
SchedulerServiceImpl.updateJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
XJob newJobDefinition)
Update a job with new definition.
|
APIResult |
ScheduleResource.updateJob(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle,
XJob job) |
Modifier and Type | Method and Description |
---|---|
static SchedulerJobHandle |
UtilityMethods.generateSchedulerJobHandle() |
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.