org.apache.lens.regression.core.helpers

Class QueryHelper

java.lang.Object

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

org.apache.lens.regression.core.helpers.QueryHelper

public class QueryHelper
extends ServiceManagerHelper

Constructor Summary

Constructors

Constructor and Description
QueryHelper()
QueryHelper(String envFileName)

Method Summary

Modifier and Type	Method and Description
void	destoryPreparedQueryByHandle(QueryPrepareHandle queryPreparedHandle)
void	destoryPreparedQueryByHandle(QueryPrepareHandle queryPreparedHandle, String sessionHandleString) Destroy prepared Query
void	destroyPreparedQuery()
void	destroyPreparedQuery(String queryName)
void	destroyPreparedQuery(String queryName, String user)
void	destroyPreparedQuery(String queryName, String user, String sessionHandleString)
void	destroyPreparedQuery(String queryName, String user, String sessionHandleString, String fromDate, String toDate) Destroy prepared Query
LensAPIResult<QueryCostTO>	estimateQuery(String queryString)
LensAPIResult<QueryCostTO>	estimateQuery(String queryString, String sessionHandleString)
LensAPIResult<QueryCostTO>	estimateQuery(String queryString, String sessionHandleString, String conf) Estimate the query
QueryHandle	executePreparedQuery(QueryPrepareHandle queryHandle)
QueryHandle	executePreparedQuery(QueryPrepareHandle queryHandle, String sessionHandleString)
QueryHandle	executePreparedQuery(QueryPrepareHandle queryHandle, String sessionHandleString, String conf) Execute prepared Query
QueryHandleWithResultSet	executePreparedQueryTimeout(QueryPrepareHandle queryHandle)
QueryHandleWithResultSet	executePreparedQueryTimeout(QueryPrepareHandle queryHandle, String timeout)
QueryHandleWithResultSet	executePreparedQueryTimeout(QueryPrepareHandle queryHandle, String timeout, String sessionHandleString)
QueryHandleWithResultSet	executePreparedQueryTimeout(QueryPrepareHandle queryHandle, String timeout, String sessionHandleString, String conf) Execute prepared Query with timeout
LensAPIResult	executeQuery(String queryString)
LensAPIResult	executeQuery(String queryString, String queryName)
LensAPIResult	executeQuery(String queryString, String queryName, String sessionHandleString)
LensAPIResult	executeQuery(String queryString, String queryName, String sessionHandleString, String conf)
LensAPIResult	executeQuery(String queryString, String queryName, String user, String sessionHandleString, LensConf conf) Execute the query
LensAPIResult	executeQuery(String queryString, String queryName, String sessionHandleString, String conf, String outputMediaType) Execute with conf
LensAPIResult	executeQueryTimeout(String queryString)
LensAPIResult	executeQueryTimeout(String queryString, String timeout)
LensAPIResult	executeQueryTimeout(String queryString, String timeout, String queryName)
LensAPIResult	executeQueryTimeout(String queryString, String timeout, String queryName, String sessionHandleString)
LensAPIResult	executeQueryTimeout(String queryString, String timeout, String queryName, String sessionHandleString, LensConf conf)
LensAPIResult	executeQueryTimeout(String queryString, String timeout, String queryName, String sessionHandleString, String conf) Execute with timeout
QueryPlan	explainAndPrepareQuery(String queryString)
QueryPlan	explainAndPrepareQuery(String queryString, String sessionHandleString)
QueryPlan	explainAndPrepareQuery(String queryString, String sessionHandleString, String conf) Prepare and Explain the query
LensAPIResult<QueryPlan>	explainQuery(String queryString)
LensAPIResult<QueryPlan>	explainQuery(String queryString, String sessionHandleString)
LensAPIResult<QueryPlan>	explainQuery(String queryString, String sessionHandleString, String conf) Explain the query
QueryResult	getHttpResultSet(QueryHandle queryHandle) Get the HTTP result set
String	getInmemoryResultSetJson(QueryHandle queryHandle, String fromIndex, String fetchSize, String sessionHandleString)
LensQuery	getLensQuery(String sessionHandleString, QueryHandle queryHandle)
String	getPersistentResultSetJson(QueryHandle queryHandle)
String	getPersistentResultSetJson(QueryHandle queryHandle, String fromIndex, String fetchSize)
String	getPersistentResultSetJson(QueryHandle queryHandle, String fromIndex, String fetchSize, String sessionHandleString) Get the Result set for json
javax.ws.rs.core.Response	getPreparedQuery(QueryPrepareHandle queryPrepareHandle)
javax.ws.rs.core.Response	getPreparedQuery(QueryPrepareHandle queryPrepareHandle, String sessionHandleString) Get prepared Query
List<QueryPrepareHandle>	getPreparedQueryHandleList()
List<QueryPrepareHandle>	getPreparedQueryHandleList(String queryName)
List<QueryPrepareHandle>	getPreparedQueryHandleList(String queryName, String user)
List<QueryPrepareHandle>	getPreparedQueryHandleList(String queryName, String user, String sessionHandleString)
List<QueryPrepareHandle>	getPreparedQueryHandleList(String queryName, String user, String sessionHandleString, String fromDate, String toDate) Get Prepared QueryHandle List
List<QueryHandle>	getQueryHandleList()
List<QueryHandle>	getQueryHandleList(String queryName)
List<QueryHandle>	getQueryHandleList(String queryName, String state)
List<QueryHandle>	getQueryHandleList(String queryName, String state, String user)
List<QueryHandle>	getQueryHandleList(String queryName, String state, String user, String sessionHandleString)
List<QueryHandle>	getQueryHandleList(String queryName, String state, String user, String sessionHandleString, String fromDate, String toDate)
List<QueryHandle>	getQueryHandleList(String queryName, String state, String user, String sessionHandleString, String fromDate, String toDate, String driver) List Query Handle
QueryStatus	getQueryStatus(QueryHandle queryHandle)
QueryStatus	getQueryStatus(String sessionHandleString, QueryHandle queryHandle) Get Query Status
QueryResult	getResultSet(QueryHandle queryHandle)
QueryResult	getResultSet(QueryHandle queryHandle, String fromIndex, String fetchSize)
QueryResult	getResultSet(QueryHandle queryHandle, String fromIndex, String fetchSize, String sessionHandleString)
javax.ws.rs.core.Response	getResultSetResponse(QueryHandle queryHandle, String fromIndex, String fetchSize, String sessionHandleString) Get the Result set
void	killQuery()
void	killQuery(String queryName)
void	killQuery(String queryName, String state)
void	killQuery(String queryName, String state, String user)
void	killQuery(String queryName, String state, String user, String sessionHandleString)
void	killQuery(String queryName, String state, String user, String sessionHandleString, String fromDate, String toDate) Kill Query
void	killQueryByQueryHandle(QueryHandle queryHandle)
void	killQueryByQueryHandle(String sessionHandleString, QueryHandle queryHandle) Kill Query by QueryHandle
QueryPrepareHandle	submitPreparedQuery(String queryString)
QueryPrepareHandle	submitPreparedQuery(String queryString, String queryName)
QueryPrepareHandle	submitPreparedQuery(String queryString, String queryName, String sessionHandleString)
QueryPrepareHandle	submitPreparedQuery(String queryString, String queryName, String sessionHandleString, String conf) Submit prepared Query
LensQuery	waitForCompletion(QueryHandle queryHandle)
LensQuery	waitForCompletion(String sessionHandleString, QueryHandle queryHandle)
LensQuery	waitForCompletion(String sessionHandleString, QueryHandle queryHandle, javax.ws.rs.core.MediaType inputMediaType, String outputMediaType) Wait for Completion
QueryStatus	waitForQueryToRun(QueryHandle queryHandle)
QueryStatus	waitForQueryToRun(QueryHandle queryHandle, String sessionHandleString) Wait for Query to run

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

Constructor Detail

QueryHelper

public QueryHelper()

QueryHelper

public QueryHelper(String envFileName)

Method Detail

executeQuery

public LensAPIResult executeQuery(String queryString,
                                  String queryName,
                                  String sessionHandleString,
                                  String conf,
                                  String outputMediaType)
                           throws LensException

Execute with conf

Parameters:

queryString -

queryName -

sessionHandleString -

conf -

Returns:

the query Handle

Throws:

LensException

executeQuery

public LensAPIResult executeQuery(String queryString,
                                  String queryName,
                                  String sessionHandleString,
                                  String conf)
                           throws LensException

Throws:

LensException

executeQuery

public LensAPIResult executeQuery(String queryString,
                                  String queryName,
                                  String sessionHandleString)
                           throws LensException

Throws:

LensException

executeQuery

public LensAPIResult executeQuery(String queryString,
                                  String queryName)
                           throws LensException

Throws:

LensException

executeQuery

public LensAPIResult executeQuery(String queryString)
                           throws LensException

Throws:

LensException

executeQueryTimeout

public LensAPIResult executeQueryTimeout(String queryString,
                                         String timeout,
                                         String queryName,
                                         String sessionHandleString,
                                         String conf)
                                  throws LensException

Execute with timeout

Parameters:

queryString -

timeout -

queryName -

sessionHandleString -

conf -

Returns:

the queryHandleWithResultSet

Throws:

LensException

executeQueryTimeout

public LensAPIResult executeQueryTimeout(String queryString,
                                         String timeout,
                                         String queryName,
                                         String sessionHandleString)
                                  throws LensException

Throws:

LensException

executeQueryTimeout

public LensAPIResult executeQueryTimeout(String queryString,
                                         String timeout,
                                         String queryName)
                                  throws LensException

Throws:

LensException

executeQueryTimeout

public LensAPIResult executeQueryTimeout(String queryString,
                                         String timeout)
                                  throws LensException

Throws:

LensException

executeQueryTimeout

public LensAPIResult executeQueryTimeout(String queryString)
                                  throws LensException

Throws:

LensException

executeQuery

public LensAPIResult executeQuery(String queryString,
                                  String queryName,
                                  String user,
                                  String sessionHandleString,
                                  LensConf conf)
                           throws LensException

Execute the query

Parameters:

queryString -

queryName -

user -

sessionHandleString -

conf -

Returns:

the query Handle

Throws:

LensException

executeQueryTimeout

public LensAPIResult executeQueryTimeout(String queryString,
                                         String timeout,
                                         String queryName,
                                         String sessionHandleString,
                                         LensConf conf)
                                  throws LensException

Throws:

LensException

explainQuery

public LensAPIResult<QueryPlan> explainQuery(String queryString,
                                             String sessionHandleString,
                                             String conf)
                                      throws LensException

Explain the query

Parameters:

queryString -

sessionHandleString -

conf -

Returns:

the query Plan

Throws:

LensException

explainQuery

public LensAPIResult<QueryPlan> explainQuery(String queryString,
                                             String sessionHandleString)
                                      throws LensException

Throws:

LensException

explainQuery

public LensAPIResult<QueryPlan> explainQuery(String queryString)
                                      throws LensException

Throws:

LensException

estimateQuery

public LensAPIResult<QueryCostTO> estimateQuery(String queryString,
                                                String sessionHandleString,
                                                String conf)
                                         throws LensException

Estimate the query

Parameters:

queryString -

sessionHandleString -

conf -

Returns:

the Estimate result

Throws:

LensException

estimateQuery

public LensAPIResult<QueryCostTO> estimateQuery(String queryString,
                                                String sessionHandleString)
                                         throws LensException

Throws:

LensException

estimateQuery

public LensAPIResult<QueryCostTO> estimateQuery(String queryString)
                                         throws LensException

Throws:

LensException

explainAndPrepareQuery

public QueryPlan explainAndPrepareQuery(String queryString,
                                        String sessionHandleString,
                                        String conf)
                                 throws LensException

Prepare and Explain the query

Parameters:

queryString -

sessionHandleString -

conf -

Returns:

the query Plan

Throws:

LensException

explainAndPrepareQuery

public QueryPlan explainAndPrepareQuery(String queryString,
                                        String sessionHandleString)
                                 throws LensException

Throws:

LensException

explainAndPrepareQuery

public QueryPlan explainAndPrepareQuery(String queryString)
                                 throws LensException

Throws:

LensException

getResultSetResponse

public javax.ws.rs.core.Response getResultSetResponse(QueryHandle queryHandle,
                                                      String fromIndex,
                                                      String fetchSize,
                                                      String sessionHandleString)
                                               throws LensException

Get the Result set

Parameters:

queryHandle -

fromIndex -

fetchSize -

sessionHandleString -

Returns:

the query Result

Throws:

LensException

getResultSet

public QueryResult getResultSet(QueryHandle queryHandle,
                                String fromIndex,
                                String fetchSize,
                                String sessionHandleString)
                         throws LensException

Throws:

LensException

getResultSet

public QueryResult getResultSet(QueryHandle queryHandle,
                                String fromIndex,
                                String fetchSize)
                         throws LensException

Throws:

LensException

getResultSet

public QueryResult getResultSet(QueryHandle queryHandle)
                         throws LensException

Throws:

LensException

getPersistentResultSetJson

public String getPersistentResultSetJson(QueryHandle queryHandle,
                                         String fromIndex,
                                         String fetchSize,
                                         String sessionHandleString)
                                  throws LensException

Get the Result set for json

Parameters:

queryHandle -

fromIndex -

fetchSize -

sessionHandleString -

Returns:

the query Result

Throws:

LensException

getInmemoryResultSetJson

public String getInmemoryResultSetJson(QueryHandle queryHandle,
                                       String fromIndex,
                                       String fetchSize,
                                       String sessionHandleString)
                                throws LensException

Throws:

LensException

getPersistentResultSetJson

public String getPersistentResultSetJson(QueryHandle queryHandle,
                                         String fromIndex,
                                         String fetchSize)
                                  throws LensException

Throws:

LensException

getPersistentResultSetJson

public String getPersistentResultSetJson(QueryHandle queryHandle)
                                  throws LensException

Throws:

LensException

getHttpResultSet

public QueryResult getHttpResultSet(QueryHandle queryHandle)
                             throws LensException

Get the HTTP result set

Parameters:

queryHandle -

Returns:

the query Result

Throws:

LensException

executePreparedQuery

public QueryHandle executePreparedQuery(QueryPrepareHandle queryHandle,
                                        String sessionHandleString,
                                        String conf)
                                 throws LensException

Execute prepared Query

Parameters:

queryHandle -

sessionHandleString -

conf -

Returns:

the query Handle

Throws:

LensException

executePreparedQuery

public QueryHandle executePreparedQuery(QueryPrepareHandle queryHandle,
                                        String sessionHandleString)
                                 throws LensException

Throws:

LensException

executePreparedQuery

public QueryHandle executePreparedQuery(QueryPrepareHandle queryHandle)
                                 throws LensException

Throws:

LensException

executePreparedQueryTimeout

public QueryHandleWithResultSet executePreparedQueryTimeout(QueryPrepareHandle queryHandle,
                                                            String timeout,
                                                            String sessionHandleString,
                                                            String conf)
                                                     throws LensException

Execute prepared Query with timeout

Parameters:

queryHandle -

timeout -

sessionHandleString -

conf -

Returns:

the query Handle with result set

Throws:

LensException

executePreparedQueryTimeout

public QueryHandleWithResultSet executePreparedQueryTimeout(QueryPrepareHandle queryHandle,
                                                            String timeout,
                                                            String sessionHandleString)
                                                     throws LensException

Throws:

LensException

executePreparedQueryTimeout

public QueryHandleWithResultSet executePreparedQueryTimeout(QueryPrepareHandle queryHandle,
                                                            String timeout)
                                                     throws LensException

Throws:

LensException

executePreparedQueryTimeout

public QueryHandleWithResultSet executePreparedQueryTimeout(QueryPrepareHandle queryHandle)
                                                     throws LensException

Throws:

LensException

submitPreparedQuery

public QueryPrepareHandle submitPreparedQuery(String queryString,
                                              String queryName,
                                              String sessionHandleString,
                                              String conf)
                                       throws LensException

Submit prepared Query

Parameters:

queryString -

sessionHandleString -

conf -

Returns:

the query Prepare Handle

Throws:

LensException

submitPreparedQuery

public QueryPrepareHandle submitPreparedQuery(String queryString,
                                              String queryName,
                                              String sessionHandleString)
                                       throws LensException

Throws:

LensException

submitPreparedQuery

public QueryPrepareHandle submitPreparedQuery(String queryString,
                                              String queryName)
                                       throws LensException

Throws:

LensException

submitPreparedQuery

public QueryPrepareHandle submitPreparedQuery(String queryString)
                                       throws LensException

Throws:

LensException

destoryPreparedQueryByHandle

public void destoryPreparedQueryByHandle(QueryPrepareHandle queryPreparedHandle,
                                         String sessionHandleString)
                                  throws LensException

Destroy prepared Query

Parameters:

queryPreparedHandle -

sessionHandleString -

Throws:

LensException

destoryPreparedQueryByHandle

public void destoryPreparedQueryByHandle(QueryPrepareHandle queryPreparedHandle)
                                  throws LensException

Throws:

LensException

getPreparedQueryHandleList

public List<QueryPrepareHandle> getPreparedQueryHandleList(String queryName,
                                                           String user,
                                                           String sessionHandleString,
                                                           String fromDate,
                                                           String toDate)

Get Prepared QueryHandle List

Parameters:

queryName -

user -

sessionHandleString -

fromDate -

toDate -

Returns:

the query Handle

getPreparedQueryHandleList

public List<QueryPrepareHandle> getPreparedQueryHandleList(String queryName,
                                                           String user,
                                                           String sessionHandleString)

getPreparedQueryHandleList

public List<QueryPrepareHandle> getPreparedQueryHandleList(String queryName,
                                                           String user)

getPreparedQueryHandleList

public List<QueryPrepareHandle> getPreparedQueryHandleList(String queryName)

getPreparedQueryHandleList

public List<QueryPrepareHandle> getPreparedQueryHandleList()

destroyPreparedQuery

public void destroyPreparedQuery(String queryName,
                                 String user,
                                 String sessionHandleString,
                                 String fromDate,
                                 String toDate)
                          throws LensException

Destroy prepared Query

Parameters:

queryName -

sessionHandleString -

fromDate -

toDate -

Throws:

LensException

destroyPreparedQuery

public void destroyPreparedQuery(String queryName,
                                 String user,
                                 String sessionHandleString)
                          throws LensException

Throws:

LensException

destroyPreparedQuery

public void destroyPreparedQuery(String queryName,
                                 String user)
                          throws LensException

Throws:

LensException

destroyPreparedQuery

public void destroyPreparedQuery(String queryName)
                          throws LensException

Throws:

LensException

destroyPreparedQuery

public void destroyPreparedQuery()
                          throws LensException

Throws:

LensException

getPreparedQuery

public javax.ws.rs.core.Response getPreparedQuery(QueryPrepareHandle queryPrepareHandle,
                                                  String sessionHandleString)

Get prepared Query

Parameters:

queryPrepareHandle -

sessionHandleString -

Returns:

the client response

getPreparedQuery

public javax.ws.rs.core.Response getPreparedQuery(QueryPrepareHandle queryPrepareHandle)

getQueryHandleList

public List<QueryHandle> getQueryHandleList(String queryName,
                                            String state,
                                            String user,
                                            String sessionHandleString,
                                            String fromDate,
                                            String toDate,
                                            String driver)

List Query Handle

Parameters:

queryName -

state -

user -

sessionHandleString -

fromDate -

toDate -

Returns:

the query Handle list

getQueryHandleList

public List<QueryHandle> getQueryHandleList(String queryName,
                                            String state,
                                            String user,
                                            String sessionHandleString,
                                            String fromDate,
                                            String toDate)

getQueryHandleList

public List<QueryHandle> getQueryHandleList(String queryName,
                                            String state,
                                            String user,
                                            String sessionHandleString)

getQueryHandleList

public List<QueryHandle> getQueryHandleList(String queryName,
                                            String state,
                                            String user)

getQueryHandleList

public List<QueryHandle> getQueryHandleList(String queryName,
                                            String state)

getQueryHandleList

public List<QueryHandle> getQueryHandleList(String queryName)

getQueryHandleList

public List<QueryHandle> getQueryHandleList()

waitForCompletion

public LensQuery waitForCompletion(String sessionHandleString,
                                   QueryHandle queryHandle,
                                   javax.ws.rs.core.MediaType inputMediaType,
                                   String outputMediaType)
                            throws InterruptedException,
                                   LensException

Wait for Completion

Parameters:

sessionHandleString -

queryHandle -

Returns:

the lens query

Throws:

InterruptedException

LensException

waitForCompletion

public LensQuery waitForCompletion(String sessionHandleString,
                                   QueryHandle queryHandle)
                            throws InterruptedException,
                                   LensException

Throws:

InterruptedException

LensException

waitForCompletion

public LensQuery waitForCompletion(QueryHandle queryHandle)
                            throws InterruptedException,
                                   LensException

Throws:

InterruptedException

LensException

waitForQueryToRun

public QueryStatus waitForQueryToRun(QueryHandle queryHandle,
                                     String sessionHandleString)
                              throws InterruptedException,
                                     LensException

Wait for Query to run

Parameters:

queryHandle -

sessionHandleString -

Returns:

the query status

Throws:

InterruptedException

LensException

waitForQueryToRun

public QueryStatus waitForQueryToRun(QueryHandle queryHandle)
                              throws InterruptedException,
                                     LensException

Throws:

InterruptedException

LensException

getQueryStatus

public QueryStatus getQueryStatus(String sessionHandleString,
                                  QueryHandle queryHandle)
                           throws LensException

Get Query Status

Parameters:

sessionHandleString -

queryHandle -

Returns:

the query Status

Throws:

LensException

getLensQuery

public LensQuery getLensQuery(String sessionHandleString,
                              QueryHandle queryHandle)
                       throws LensException

Throws:

LensException

getQueryStatus

public QueryStatus getQueryStatus(QueryHandle queryHandle)
                           throws LensException

Throws:

LensException

killQueryByQueryHandle

public void killQueryByQueryHandle(String sessionHandleString,
                                   QueryHandle queryHandle)
                            throws LensException

Kill Query by QueryHandle

Parameters:

sessionHandleString -

queryHandle -

Throws:

LensException

killQueryByQueryHandle

public void killQueryByQueryHandle(QueryHandle queryHandle)
                            throws LensException

Throws:

LensException

killQuery

public void killQuery(String queryName,
                      String state,
                      String user,
                      String sessionHandleString,
                      String fromDate,
                      String toDate)
               throws LensException

Kill Query

Parameters:

queryName -

state -

user -

sessionHandleString -

fromDate -

toDate -

Throws:

LensException

killQuery

public void killQuery(String queryName,
                      String state,
                      String user,
                      String sessionHandleString)
               throws LensException

Throws:

LensException

killQuery

public void killQuery(String queryName,
                      String state,
                      String user)
               throws LensException

Throws:

LensException

killQuery

public void killQuery(String queryName,
                      String state)
               throws LensException

Throws:

LensException

killQuery

public void killQuery(String queryName)
               throws LensException

Throws:

LensException

killQuery

public void killQuery()
               throws LensException

Throws:

LensException