org.apache.lens.regression.core.helpers

Class ScheduleResourceHelper

java.lang.Object

org.apache.lens.regression.core.helpers.ServiceManagerHelper

org.apache.lens.regression.core.helpers.ScheduleResourceHelper

public class ScheduleResourceHelper
extends ServiceManagerHelper

Field Summary

Fields

Modifier and Type	Field and Description
static String	SCHEDULER_BASE_URL
static String	SCHEDULER_INSTANCES_URL
static String	SCHEDULER_JOBS_URL

Constructor Summary

Constructors

Constructor and Description
ScheduleResourceHelper()
ScheduleResourceHelper(String envFileName)

Method Summary

Modifier and Type	Method and Description
LensAPIResult	deleteJob(String jobHandle, String sessionId)
List<SchedulerJobInstanceInfo>	getAllInstancesOfJob(String jobHandle, String numResults, String sessionId)
LensAPIResult<SchedulerJobInstanceInfo>	getInstanceDetails(String instanceHandle, String sessionId)
LensAPIResult<XJob>	getJobDefinition(String jobHandle, String sessionId)
LensAPIResult<XJob>	getJobDefinition(String jobHandle, String sessionId, javax.ws.rs.core.MediaType inputMedia, String outputMedia)
LensAPIResult<SchedulerJobInfo>	getJobDetails(String jobHandle, String sessionHandleString)
SchedulerJobState	getJobStatus(String jobHandle)
SchedulerJobState	getJobStatus(String jobHandle, String sessionHandleString)
XExecution	getXExecution(String query, String db)
XExecution	getXExecution(String query, String db, List<MapType> queryConfig, List<MapType> sessionConfig)
XJob	getXJob(String name, String query, String db, String startTime, String endTime, String cronExpression)
XJob	getXJob(String name, String query, String db, String startTime, String endTime, XFrequencyEnum frequency)
XTrigger	getXTrigger(String cronExpression)
XTrigger	getXTrigger(XFrequencyEnum frequency)
String	submitJob(String action, XJob job, String session)
String	submitJob(XJob job, String session)
javax.ws.rs.core.Response	submitJobReturnResponse(String action, XJob job, String sessionHandleString)
String	submitNScheduleJob(XJob job, String session)
LensAPIResult<Boolean>	updateInstance(String instanceHandle, String action, String sessionId)
LensAPIResult	updateJob(String jobHandle, String action, String sessionHandleString)
LensAPIResult	updateJob(XJob job, String jobHandle, String sessionHandleString)

Methods inherited from class org.apache.lens.regression.core.helpers.ServiceManagerHelper

exec, exec, exec, exec, exec, execDELETE, execGET, execPOST, execPUT, getAdminUrl, getBaseUrl, getClientDir, getCurrentDB, getJobConfUrl, getPassword, getServerDir, getServerHdfsUrl, getServerLens, getServiceURI, getSessionHandleString, getStartDate, getUserName, init, sendForm, sendQuery

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SCHEDULER_BASE_URL

public static final String SCHEDULER_BASE_URL

See Also:

Constant Field Values

SCHEDULER_JOBS_URL

public static final String SCHEDULER_JOBS_URL

See Also:

Constant Field Values

SCHEDULER_INSTANCES_URL

public static final String SCHEDULER_INSTANCES_URL

See Also:

Constant Field Values

Constructor Detail

ScheduleResourceHelper

public ScheduleResourceHelper()

ScheduleResourceHelper

public ScheduleResourceHelper(String envFileName)

Method Detail

submitJobReturnResponse

public javax.ws.rs.core.Response submitJobReturnResponse(String action,
                                                         XJob job,
                                                         String sessionHandleString)
                                                  throws JAXBException,
                                                         IOException,
                                                         ParseException,
                                                         DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

submitJob

public String submitJob(String action,
                        XJob job,
                        String session)
                 throws JAXBException,
                        IOException,
                        ParseException,
                        DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

submitJob

public String submitJob(XJob job,
                        String session)
                 throws JAXBException,
                        IOException,
                        ParseException,
                        DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

submitNScheduleJob

public String submitNScheduleJob(XJob job,
                                 String session)
                          throws JAXBException,
                                 IOException,
                                 ParseException,
                                 DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

getXJob

public XJob getXJob(String name,
                    String query,
                    String db,
                    String startTime,
                    String endTime,
                    XFrequencyEnum frequency)
             throws ParseException,
                    DatatypeConfigurationException

Throws:

ParseException

DatatypeConfigurationException

getXJob

public XJob getXJob(String name,
                    String query,
                    String db,
                    String startTime,
                    String endTime,
                    String cronExpression)
             throws ParseException,
                    DatatypeConfigurationException

Throws:

ParseException

DatatypeConfigurationException

getXTrigger

public XTrigger getXTrigger(XFrequencyEnum frequency)

getXTrigger

public XTrigger getXTrigger(String cronExpression)

getXExecution

public XExecution getXExecution(String query,
                                String db)

getXExecution

public XExecution getXExecution(String query,
                                String db,
                                List<MapType> queryConfig,
                                List<MapType> sessionConfig)

getJobDefinition

public LensAPIResult<XJob> getJobDefinition(String jobHandle,
                                            String sessionId,
                                            javax.ws.rs.core.MediaType inputMedia,
                                            String outputMedia)

getJobDefinition

public LensAPIResult<XJob> getJobDefinition(String jobHandle,
                                            String sessionId)

deleteJob

public LensAPIResult deleteJob(String jobHandle,
                               String sessionId)

updateJob

public LensAPIResult updateJob(XJob job,
                               String jobHandle,
                               String sessionHandleString)
                        throws JAXBException,
                               IOException,
                               ParseException,
                               DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

updateJob

public LensAPIResult updateJob(String jobHandle,
                               String action,
                               String sessionHandleString)
                        throws JAXBException,
                               IOException,
                               ParseException,
                               DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

getJobDetails

public LensAPIResult<SchedulerJobInfo> getJobDetails(String jobHandle,
                                                     String sessionHandleString)

getJobStatus

public SchedulerJobState getJobStatus(String jobHandle,
                                      String sessionHandleString)

getJobStatus

public SchedulerJobState getJobStatus(String jobHandle)

getAllInstancesOfJob

public List<SchedulerJobInstanceInfo> getAllInstancesOfJob(String jobHandle,
                                                           String numResults,
                                                           String sessionId)
                                                    throws JAXBException,
                                                           IOException,
                                                           ParseException,
                                                           DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

getInstanceDetails

public LensAPIResult<SchedulerJobInstanceInfo> getInstanceDetails(String instanceHandle,
                                                                  String sessionId)
                                                           throws JAXBException,
                                                                  IOException,
                                                                  ParseException,
                                                                  DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException

updateInstance

public LensAPIResult<Boolean> updateInstance(String instanceHandle,
                                             String action,
                                             String sessionId)
                                      throws JAXBException,
                                             IOException,
                                             ParseException,
                                             DatatypeConfigurationException

Throws:

JAXBException

IOException

ParseException

DatatypeConfigurationException