Modifier and Type | Method and Description |
---|---|
static QueryHandle |
QueryHandle.fromString(String handle)
From string.
|
Constructor and Description |
---|
QueryHandleWithResultSet(QueryHandle handle)
Instantiates a new query handle with result set.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
LensClient.executePrepared(QueryPrepareHandle phandle,
String queryName) |
QueryHandle |
LensStatement.executeQuery(QueryPrepareHandle phandle,
boolean waitForQueryToComplete,
String queryName)
Execute query.
|
QueryHandle |
LensStatement.executeQuery(QueryPrepareHandle phandle,
String queryName)
Execute query.
|
Modifier and Type | Method and Description |
---|---|
LensAPIResult<QueryHandle> |
LensStatement.execute(String sql,
boolean waitForQueryToComplete,
String queryName)
Execute.
|
LensAPIResult<QueryHandle> |
LensStatement.executeQuery(String sql,
boolean waitForQueryToComplete,
String queryName)
Execute query.
|
LensAPIResult<QueryHandle> |
LensClient.executeQueryAsynch(String sql,
String queryName) |
List<QueryHandle> |
LensStatement.getAllQueries(String state,
String queryName,
String user,
long fromDate,
long toDate)
Gets the all queries.
|
List<QueryHandle> |
LensClient.getQueries(String state,
String queryName,
String user,
long fromDate,
long toDate) |
Modifier and Type | Method and Description |
---|---|
LensClient.LensClientResultSetWithStats |
LensClient.getAsyncResults(QueryHandle q) |
javax.ws.rs.core.Response |
LensClient.getHttpResults(QueryHandle q) |
LensStatement |
LensClient.getLensStatement(QueryHandle query) |
LensQuery |
LensStatement.getQuery(QueryHandle handle)
Gets the query.
|
LensQuery |
LensClient.getQueryDetails(QueryHandle handle) |
QueryStatus |
LensClient.getQueryStatus(QueryHandle query) |
QueryResult |
LensClient.getResults(QueryHandle query) |
LensClient.LensClientResultSetWithStats |
LensClient.getSyncResults(QueryHandle q) |
boolean |
LensClient.killQuery(QueryHandle q) |
void |
LensStatement.waitForQueryToComplete(QueryHandle handle)
Wait for query to complete.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HiveDriver.cancelQuery(QueryHandle handle) |
void |
HiveDriver.closeQuery(QueryHandle handle) |
void |
HiveDriver.closeResultSet(QueryHandle handle) |
void |
HiveDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener) |
Modifier and Type | Method and Description |
---|---|
boolean |
JDBCDriver.cancelQuery(QueryHandle handle)
Cancel the execution of the query, specified by the handle.
|
void |
JDBCDriver.closeQuery(QueryHandle handle)
Close the query specified by the handle, releases all the resources held by the query.
|
void |
JDBCDriver.closeResultSet(QueryHandle handle)
Close the resultset for the query.
|
void |
JDBCDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener)
Register for query completion notification.
|
Modifier and Type | Method and Description |
---|---|
abstract QueryHandle |
QueryRunner.runQuery(String query)
Run query.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
LensRDDClient.createLensRDDAsync(String query)
API for non blocking use.
|
QueryHandle |
LensRDDClient.LensRDDResult.getLensQuery() |
Modifier and Type | Method and Description |
---|---|
void |
LensRDDClient.cancelRDD(QueryHandle queryHandle)
Allow cancelling underlying query in case of non blocking RDD creation.
|
LensRDDClient.LensRDDResult |
LensRDDClient.getRDD(QueryHandle queryHandle)
Get the RDD created for the query.
|
boolean |
LensRDDClient.isReadyForRDD(QueryHandle queryHandle)
Check if the RDD is created.
|
Constructor and Description |
---|
LensRDDClient.LensRDDResult(org.apache.spark.rdd.RDD<List<Object>> rdd,
QueryHandle lensQuery,
String tempTableName)
Instantiates a new lens rdd result.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
QueryHelper.executePreparedQuery(QueryPrepareHandle queryHandle) |
QueryHandle |
QueryHelper.executePreparedQuery(QueryPrepareHandle queryHandle,
String sessionHandleString) |
QueryHandle |
QueryHelper.executePreparedQuery(QueryPrepareHandle queryHandle,
String sessionHandleString,
String conf)
Execute prepared Query
|
QueryHandle |
QueryHelper.executeQuery(String queryString) |
QueryHandle |
QueryHelper.executeQuery(String queryString,
String queryName) |
QueryHandle |
QueryHelper.executeQuery(String queryString,
String queryName,
String sessionHandleString) |
QueryHandle |
QueryHelper.executeQuery(String queryString,
String queryName,
String sessionHandleString,
String conf)
Execute with conf
|
QueryHandle |
QueryHelper.executeQuery(String queryString,
String queryName,
String user,
String sessionHandleString,
LensConf conf)
Execute the query
|
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
QueryHelper.getQueryHandleList() |
List<QueryHandle> |
QueryHelper.getQueryHandleList(String queryName) |
List<QueryHandle> |
QueryHelper.getQueryHandleList(String queryName,
String state) |
List<QueryHandle> |
QueryHelper.getQueryHandleList(String queryName,
String state,
String user) |
List<QueryHandle> |
QueryHelper.getQueryHandleList(String queryName,
String state,
String user,
String sessionHandleString) |
List<QueryHandle> |
QueryHelper.getQueryHandleList(String queryName,
String state,
String user,
String sessionHandleString,
String fromDate,
String toDate)
List Query Handle
|
Modifier and Type | Method and Description |
---|---|
QueryResult |
QueryHelper.getHttpResultSet(QueryHandle queryHandle)
Get the HTTP result set
|
QueryStatus |
QueryHelper.getQueryStatus(QueryHandle queryHandle) |
QueryStatus |
QueryHelper.getQueryStatus(String sessionHandleString,
QueryHandle queryHandle)
Get Query Status
|
QueryResult |
QueryHelper.getResultSet(QueryHandle queryHandle) |
QueryResult |
QueryHelper.getResultSet(QueryHandle queryHandle,
String fromIndex,
String fetchSize) |
QueryResult |
QueryHelper.getResultSet(QueryHandle queryHandle,
String fromIndex,
String fetchSize,
String sessionHandleString)
Get the Result set
|
void |
QueryHelper.killQueryByQueryHandle(QueryHandle queryHandle) |
void |
QueryHelper.killQueryByQueryHandle(String sessionHandleString,
QueryHandle queryHandle)
Kill Query by QueryHandle
|
LensQuery |
QueryHelper.waitForCompletion(QueryHandle queryHandle) |
LensQuery |
QueryHelper.waitForCompletion(String sessionHandleString,
QueryHandle queryHandle)
Wait for Completion
|
QueryStatus |
QueryHelper.waitForQueryToRun(QueryHandle queryHandle) |
QueryStatus |
QueryHelper.waitForQueryToRun(QueryHandle queryHandle,
String sessionHandleString)
Wait for Query to run
|
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
QueryHandles.getQueryHandles() |
Modifier and Type | Method and Description |
---|---|
void |
QueryHandles.setQueryHandles(List<QueryHandle> queryHandles) |
Modifier and Type | Method and Description |
---|---|
QueryHandle |
DriverQueryPlan.getHandle()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
LensDriver.cancelQuery(QueryHandle handle)
Cancel the execution of the query, specified by the handle.
|
void |
LensDriver.closeQuery(QueryHandle handle)
Close the query specified by the handle, releases all the resources held by the query.
|
void |
LensDriver.closeResultSet(QueryHandle handle)
Close the resultset for the query.
|
void |
QueryCompletionListener.onCompletion(QueryHandle handle)
On completion.
|
void |
QueryCompletionListener.onError(QueryHandle handle,
String error)
On error.
|
void |
LensDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener)
Register for query completion notification.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
QueryExecutionService.executeAsync(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName)
Asynchronously execute the query.
|
QueryHandle |
QueryExecutionService.executePrepareAsync(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf conf,
String queryName)
Execute already prepared query asynchronously.
|
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
QueryExecutionService.getAllQueries(LensSessionHandle sessionHandle,
String state,
String user,
String queryName,
long fromDate,
long toDate)
Returns all the queries in the specified state, for the given user and matching query name.
|
Modifier and Type | Method and Description |
---|---|
boolean |
QueryExecutionService.cancelQuery(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
Cancel the execution of the query, specified by the handle.
|
void |
QueryExecutionService.closeResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
Closes result set by releasing any resources used in serving the resultset.
|
QueryResult |
QueryExecutionService.fetchResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
long startIndex,
int fetchSize)
Fetch the results of the query, specified by the handle.
|
javax.ws.rs.core.Response |
QueryExecutionService.getHttpResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
Get the http end point for the result set.
|
LensQuery |
QueryExecutionService.getQuery(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
Get the query, specified by the handle.
|
QueryResultSetMetadata |
QueryExecutionService.getResultSetMetadata(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
Get the result set metadata - list of columns(names and types) and result size.
|
boolean |
QueryExecutionService.updateQueryConf(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
LensConf newconf)
Update the query conf.
|
Constructor and Description |
---|
PriorityChange(long eventTime,
Priority prev,
Priority current,
QueryHandle handle)
Instantiates a new priority change.
|
QueryAccepted(long eventTime,
String prev,
String current,
QueryHandle handle)
Instantiates a new query accepted.
|
QueryCancelled(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user,
String cause)
Instantiates a new query cancelled.
|
QueryClosed(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user,
String cause)
Instantiates a new query closed.
|
QueryEnded(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user,
String cause)
Instantiates a new query ended.
|
QueryEvent(long eventTime,
T prev,
T current,
QueryHandle handle)
Instantiates a new query event.
|
QueryExecuted(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle)
Instantiates a new query executed.
|
QueryFailed(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user,
String cause)
Instantiates a new query failed.
|
QueryLaunched(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle)
Instantiates a new query launched.
|
QueryQueued(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user)
Instantiates a new query queued.
|
QueryRejected(long eventTime,
String prev,
String current,
QueryHandle handle)
Instantiates a new query rejected.
|
QueryRunning(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle)
Instantiates a new query running.
|
QuerySuccess(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle)
Instantiates a new query success.
|
QueuePositionChange(long eventTime,
Integer prev,
Integer current,
QueryHandle handle)
Instantiates a new queue position change.
|
StatusChange(long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle)
Instantiates a new status change.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
QueryExecutionServiceImpl.executeAsync(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName) |
QueryHandle |
QueryExecutionServiceImpl.executePrepareAsync(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf conf,
String queryName) |
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
LensServerDAO.findFinishedQueries(String state,
String user,
String queryName,
long fromDate,
long toDate)
Find finished queries.
|
List<QueryHandle> |
QueryServiceResource.getAllQueries(LensSessionHandle sessionid,
String state,
String queryName,
String user,
long fromDate,
long toDate)
Get all the queries in the query server; can be filtered with state and queryName.
|
List<QueryHandle> |
QueryExecutionServiceImpl.getAllQueries(LensSessionHandle sessionHandle,
String state,
String userName,
String queryName,
long fromDate,
long toDate) |
Modifier and Type | Method and Description |
---|---|
boolean |
QueryExecutionServiceImpl.cancelQuery(LensSessionHandle sessionHandle,
QueryHandle queryHandle) |
void |
QueryExecutionServiceImpl.closeResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle) |
QueryResult |
QueryExecutionServiceImpl.fetchResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
long startIndex,
int fetchSize) |
javax.ws.rs.core.Response |
QueryExecutionServiceImpl.getHttpResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle) |
LensQuery |
QueryExecutionServiceImpl.getQuery(LensSessionHandle sessionHandle,
QueryHandle queryHandle) |
QueryResultSetMetadata |
QueryExecutionServiceImpl.getResultSetMetadata(LensSessionHandle sessionHandle,
QueryHandle queryHandle) |
boolean |
QueryExecutionServiceImpl.updateQueryConf(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
LensConf newconf) |
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
QueryServiceUIResource.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.
|
Copyright © 2014–2015 Apache Software Foundation. All rights reserved.