Package | Description |
---|---|
org.apache.lens.api.scheduler | |
org.apache.lens.regression.core.helpers | |
org.apache.lens.server.api.scheduler | |
org.apache.lens.server.scheduler |
Modifier and Type | Method and Description |
---|---|
XJob |
ObjectFactory.createXJob()
Create an instance of
XJob |
XJob |
SchedulerJobInfo.getJob()
Definition of the job scheduled.
|
XJob |
XJob.withEndTime(XMLGregorianCalendar value) |
XJob |
XJob.withExecution(XExecution value) |
XJob |
XJob.withJobConf(Collection<MapType> values) |
XJob |
XJob.withJobConf(MapType... values) |
XJob |
XJob.withName(String value) |
XJob |
XJob.withStartTime(XMLGregorianCalendar value) |
XJob |
XJob.withTrigger(XTrigger value) |
Modifier and Type | Method and Description |
---|---|
JAXBElement<XJob> |
ObjectFactory.createJob(XJob value)
|
Modifier and Type | Method and Description |
---|---|
JAXBElement<XJob> |
ObjectFactory.createJob(XJob value)
|
void |
SchedulerJobInfo.setJob(XJob job)
Definition of the job scheduled.
|
Constructor and Description |
---|
SchedulerJobInfo(SchedulerJobHandle id,
XJob job,
String userName,
SchedulerJobState jobState,
long createdOn,
long modifiedOn) |
Modifier and Type | Method and Description |
---|---|
XJob |
ScheduleResourceHelper.getXJob(String name,
String query,
String db,
String startTime,
String endTime,
String cronExpression) |
XJob |
ScheduleResourceHelper.getXJob(String name,
String query,
String db,
String startTime,
String endTime,
XFrequencyEnum frequency) |
Modifier and Type | Method and Description |
---|---|
LensAPIResult<XJob> |
ScheduleResourceHelper.getJobDefinition(String jobHandle,
String sessionId) |
LensAPIResult<XJob> |
ScheduleResourceHelper.getJobDefinition(String jobHandle,
String sessionId,
javax.ws.rs.core.MediaType inputMedia,
String outputMedia) |
Modifier and Type | Method and Description |
---|---|
String |
ScheduleResourceHelper.submitJob(String action,
XJob job,
String session) |
String |
ScheduleResourceHelper.submitJob(XJob job,
String session) |
javax.ws.rs.core.Response |
ScheduleResourceHelper.submitJobReturnResponse(String action,
XJob job,
String sessionHandleString) |
String |
ScheduleResourceHelper.submitNScheduleJob(XJob job,
String session) |
LensAPIResult |
ScheduleResourceHelper.updateJob(XJob job,
String jobHandle,
String sessionHandleString) |
Modifier and Type | Method and Description |
---|---|
XJob |
SchedulerService.getJobDefinition(SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
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.
|
void |
SchedulerService.updateJob(LensSessionHandle sessionHandle,
SchedulerJobHandle jobHandle,
XJob newJobDefinition)
Update a job with new definition.
|
Modifier and Type | Method and Description |
---|---|
XJob |
SchedulerDAO.getJob(SchedulerJobHandle id)
Gets the job definition from the store
|
XJob |
SchedulerDAO.SchedulerDBStore.getJob(String id)
Gets the job definition
|
XJob |
SchedulerServiceImpl.getJobDefinition(SchedulerJobHandle jobHandle)
Returns the definition of a job.
|
Modifier and Type | Method and Description |
---|---|
LensAPIResult<XJob> |
ScheduleResource.getJobDefinition(LensSessionHandle sessionId,
SchedulerJobHandle jobHandle)
Get XJob definition for a given job handle.
|
Modifier and Type | Method and Description |
---|---|
void |
LensScheduler.schedule(SchedulerJobHandle handle,
XJob job) |
SchedulerJobHandle |
SchedulerServiceImpl.submitAndScheduleJob(LensSessionHandle sessionHandle,
XJob job) |
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.
|
SchedulerJobHandle |
SchedulerServiceImpl.submitJob(LensSessionHandle sessionHandle,
XJob job)
Submit a job.
|
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.
|
int |
SchedulerDAO.SchedulerDBStore.updateJob(String id,
XJob job,
long modifiedOn)
Update the XJob into the job table
|
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.