Package | Description |
---|---|
org.apache.lens.api.query | |
org.apache.lens.server.api.scheduler | |
org.apache.lens.server.scheduler |
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) |
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.
|
void |
SchedulerService.expireJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
Date expiryTime)
End a job by specifying an expiry time.
|
XJob |
SchedulerService.getJobDefinition(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
SchedulerJobInfo |
SchedulerService.getJobDetails(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Returns the details of a job.
|
List<String> |
SchedulerService.getJobInstances(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
Long numResults)
Returns handles for last
numResults instances for the job. |
SchedulerJobStats |
SchedulerService.getJobStats(LensSessionHandle sessionHandle,
SchedulerJobHandle handle,
String state,
long startTime,
long endTime)
Returns stats for a job.
|
boolean |
SchedulerService.resumeJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
Date effectiveTime)
Resume a job from a given time.
|
void |
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 |
SchedulerServiceImpl.submitJob(LensSessionHandle sessionHandle,
XJob job)
Submit a job.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SchedulerServiceImpl.deleteJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Delete a job.
|
void |
SchedulerServiceImpl.expireJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
Date expiryTime)
End a job by specifying an expiry time.
|
XJob |
SchedulerServiceImpl.getJobDefinition(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
SchedulerJobInfo |
SchedulerServiceImpl.getJobDetails(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Returns the details of a job.
|
List<String> |
SchedulerServiceImpl.getJobInstances(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
Long numResults)
Returns handles for last
numResults instances for the job. |
SchedulerJobStats |
SchedulerServiceImpl.getJobStats(LensSessionHandle sessionHandle,
SchedulerJobHandle handle,
String state,
long startTime,
long endTime)
Returns stats for a job.
|
boolean |
SchedulerServiceImpl.resumeJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
Date effectiveTime)
Resume a job from a given time.
|
void |
SchedulerServiceImpl.scheduleJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Schedule a job.
|
boolean |
SchedulerServiceImpl.suspendJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle)
Suspend a job.
|
boolean |
SchedulerServiceImpl.updateJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
XJob newJobDefinition)
Update a job with new definition.
|
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.