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 |
---|---|
List<SchedulerJobHandle> |
SchedulerService.getAllJobs(String user,
SchedulerJobState state,
Long start,
Long end)
Get all jobs matching the filter parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulerService.deleteJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Delete a job.
|
void |
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.
|
void |
SchedulerService.resumeJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Resume a job from a given time.
|
void |
SchedulerService.scheduleJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Schedule a job.
|
void |
SchedulerService.suspendJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Suspend a job.
|
void |
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 |
SchedulerServiceImpl.submitJob(LensSessionHandle sessionHandle,
XJob job)
Submit a job.
|
Modifier and Type | Method and Description |
---|---|
List<SchedulerJobHandle> |
ScheduleResource.getAllJobs(LensSessionHandle sessionHandle,
String user,
SchedulerJobState state,
Long start,
Long end)
Get all job handles matching user, state and end_time >job_submission_time >=start time.
|
List<SchedulerJobHandle> |
SchedulerServiceImpl.getAllJobs(String user,
SchedulerJobState state,
Long start,
Long end) |
List<SchedulerJobHandle> |
SchedulerDAO.getJob(String jobName)
Get the handle given the job name.
|
List<SchedulerJobHandle> |
SchedulerDAO.getJobs(String username,
Long startTime,
Long endTime,
SchedulerJobState... jobStates)
Gets all jobs which match the filter requirements.
|
List<SchedulerJobHandle> |
SchedulerDAO.SchedulerDBStore.getJobs(String username,
SchedulerJobState[] states,
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
|
LensAPIResult<SchedulerJobHandle> |
ScheduleResource.submitJob(LensSessionHandle sessionId,
String action,
XJob job)
Submits a job to be scheduled at later point of time or submit and schedule simultaneously.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AlarmService.checkExists(SchedulerJobHandle handle) |
void |
SchedulerServiceImpl.deleteJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Delete a job.
|
LensAPIResult |
ScheduleResource.deleteJob(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle)
Marks the job for deletion.
|
void |
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
|
LensAPIResult<XJob> |
ScheduleResource.getJobDefinition(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle)
Get XJob definition for a given job handle.
|
XJob |
SchedulerServiceImpl.getJobDefinition(SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
LensAPIResult<SchedulerJobInfo> |
ScheduleResource.getJobDetails(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle)
Returns the SchedulerJobInfo of a given job handle.
|
SchedulerJobInfo |
SchedulerServiceImpl.getJobDetails(SchedulerJobHandle jobHandle)
Returns the details of a job.
|
List<SchedulerJobInstanceInfo> |
ScheduleResource.getJobInstances(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle,
Long numResults)
Returns all the instances of a job.
|
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) |
void |
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) |
void |
SchedulerServiceImpl.scheduleJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Schedule a job.
|
void |
SchedulerServiceImpl.suspendJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Suspend a job.
|
boolean |
AlarmService.unSchedule(SchedulerJobHandle jobHandle) |
LensAPIResult |
ScheduleResource.updateJob(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle,
String action)
Changes the job state
|
void |
SchedulerServiceImpl.updateJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
XJob newJobDefinition)
Update a job with new definition.
|
LensAPIResult |
ScheduleResource.updateJob(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle,
XJob job)
Updates job definition of an existing job.
|
Modifier and Type | Method and Description |
---|---|
static SchedulerJobHandle |
UtilityMethods.generateSchedulerJobHandle() |
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.