org.apache.lens.server.ui

Class QueryServiceUIResource

java.lang.Object

org.apache.lens.server.ui.QueryServiceUIResource

public class QueryServiceUIResource
extends Object

The Class QueryServiceUIResource.

Constructor Summary

Constructors

Constructor and Description
QueryServiceUIResource() Instantiates a new query service ui resource.

Method Summary

Methods

Modifier and Type	Method and Description
APIResult	cancelQuery(UUID publicId, String queryHandle) Cancel the query specified by the handle.
List<QueryHandle>	getAllQueries(UUID publicId, String state, String user, String queryName, long fromDate, long toDate) Get all the queries in the query server; can be filtered with state and user.
javax.ws.rs.core.Response	getHttpResultSet(UUID publicId, String queryHandle) Get the http endpoint for result set.
ResultRow	getResultSet(UUID publicId, String queryHandle, int pageNumber, int fetchSize) Fetch the result set.
LensQuery	getStatus(UUID publicId, String queryHandle) Get lens query and its current status.
QuerySubmitResult	query(UUID publicId, String query, String queryName) Submit the query for explain or execute or execute with a timeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryServiceUIResource

public QueryServiceUIResource()

Instantiates a new query service ui resource.

Method Detail

getAllQueries

public List<QueryHandle> getAllQueries(UUID publicId,
                              String state,
                              String user,
                              String queryName,
                              long fromDate,
                              long toDate)

Get all the queries in the query server; can be filtered with state and user.

Parameters:

publicId - The public id of the session in which user is working

state - If any state is passed, all the queries in that state will be returned, otherwise all queries will be returned. Possible states are QueryStatus.Status.values()

user - return queries matching the user. If set to "all", return queries of all users. By default, returns queries of the current user.

queryName - human readable query name set by user (optional)

fromDate - the from date

toDate - the to date

Returns:

List of QueryHandle objects

query

public QuerySubmitResult query(UUID publicId,
                      String query,
                      String queryName)

Submit the query for explain or execute or execute with a timeout.

Parameters:

publicId - The public id of the session in which user is submitting the query. Any configuration set in the session will be picked up.

query - The query to run

queryName - human readable query name set by user (optional)

Returns:

QueryHandle

getStatus

public LensQuery getStatus(UUID publicId,
                  String queryHandle)

Get lens query and its current status.

Parameters:

publicId - The public id of session handle

queryHandle - The query handle

Returns:

LensQuery

getResultSet

public ResultRow getResultSet(UUID publicId,
                     String queryHandle,
                     int pageNumber,
                     int fetchSize)

Fetch the result set.

Parameters:

publicId - The public id of user's session handle

queryHandle - The query handle

pageNumber - page number of the query result set to be read

fetchSize - fetch size

Returns:

ResultRow

cancelQuery

public APIResult cancelQuery(UUID publicId,
                    String queryHandle)

Cancel the query specified by the handle.

Parameters:

publicId - The user session handle

queryHandle - The query handle

Returns:

APIResult with state APIResult.Status.SUCCEEDED in case of successful cancellation. APIResult with state APIResult.Status.FAILED in case of cancellation failure.

getHttpResultSet

public javax.ws.rs.core.Response getHttpResultSet(UUID publicId,
                                         String queryHandle)

Get the http endpoint for result set.

Parameters:

publicId - the public id

queryHandle - The query handle

Returns:

Response with result as octet stream