Modifier and Type | Method and Description |
---|---|
static QueryHandle |
QueryHandle.fromString(String handle)
From string.
|
QueryHandle |
QueryHandleWithResultSet.getQueryHandle()
The query handle.
|
QueryHandle |
LensQuery.getQueryHandle()
The query handle.
|
Constructor and Description |
---|
LensQuery(QueryHandle queryHandle,
String userQuery,
String submittedUser,
Priority priority,
boolean isPersistent,
String selectedDriverClassName,
String driverQuery,
QueryStatus status,
String resultSetPath,
String driverOpHandle,
LensConf queryConf,
long submissionTime,
long launchTime,
long driverStartTime,
long driverFinishTime,
long finishTime,
long closedTime,
String queryName) |
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 |
ESDriver.cancelQuery(QueryHandle handle) |
void |
ESDriver.closeQuery(QueryHandle handle) |
void |
ESDriver.closeResultSet(QueryHandle handle)
removing the result set as soon as the fetch is done
|
void |
ESDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener) |
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
|
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.
|
QueryHandle |
QueryEvent.getQueryHandle()
The query handle.
|
QueryHandle |
QueryContext.getQueryHandle()
The query handle.
|
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.
|
void |
QueryContext.setQueryHandle(QueryHandle queryHandle)
The query handle.
|
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(QueryContext ctx,
long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user,
String cause)
Instantiates a new query cancelled.
|
QueryClosed(QueryContext ctx,
long eventTime,
QueryStatus.Status prev,
QueryStatus.Status current,
QueryHandle handle,
String user,
String cause)
Instantiates a new query closed.
|
QueryEnded(QueryContext ctx,
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(QueryContext ctx,
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(QueryContext ctx,
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) |
QueryHandle |
QueryExecutionServiceImpl.FinishedQuery.getQueryHandle() |
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) |
Constructor and Description |
---|
LensPersistentResult(QueryHandle queryHandle,
LensResultSetMetadata metadata,
String outputPath,
Integer numRows,
Long fileSize,
org.apache.hadoop.conf.Configuration conf)
Instantiates a new lens persistent result.
|
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.