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 that represents this query uniquely
|
Constructor and Description |
---|
LensQuery(QueryHandle queryHandle,
String userQuery,
String submittedUser,
Priority priority,
boolean isPersistent,
String selectedDriverName,
String driverQuery,
QueryStatus status,
String resultSetPath,
String driverOpHandle,
LensConf queryConf,
long submissionTime,
long launchTime,
long driverStartTime,
long driverFinishTime,
long finishTime,
long closedTime,
String queryName,
List<FailedAttempt> failedAttempts) |
QueryHandleWithResultSet(QueryHandle handle)
Instantiates a new query handle with result set.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
SchedulerJobInstanceRun.getQueryHandle() |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerJobInstanceRun.setQueryHandle(QueryHandle queryHandle) |
Constructor and Description |
---|
SchedulerJobInstanceRun(SchedulerJobInstanceHandle handle,
int runId,
LensSessionHandle sessionHandle,
long startTime,
long endTime,
String resultPath,
QueryHandle queryHandle,
SchedulerJobInstanceState instanceState) |
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
UserSessionInfo.getActiveQueries() |
Modifier and Type | Method and Description |
---|---|
void |
UserSessionInfo.setActiveQueries(List<QueryHandle> activeQueries) |
Constructor and Description |
---|
UserSessionInfo(String handle,
String userName,
List<QueryHandle> activeQueries,
long creationTime,
long lastAccessTime) |
Modifier and Type | Method and Description |
---|---|
QueryHandle |
LensClient.executePrepared(QueryPrepareHandle phandle,
String queryName)
Deprecated.
|
QueryHandle |
LensClient.executePrepared(QueryPrepareHandle phandle,
String queryName,
LensConf conf) |
QueryHandle |
LensStatement.executeQuery(QueryPrepareHandle phandle,
boolean waitForQueryToComplete,
String queryName)
Deprecated.
|
QueryHandle |
LensStatement.executeQuery(QueryPrepareHandle phandle,
boolean waitForQueryToComplete,
String queryName,
LensConf conf)
This method can be used for executing a prepared query.
|
QueryHandle |
LensStatement.executeQuery(String sql,
boolean waitForQueryToComplete,
String queryName)
Deprecated.
|
QueryHandle |
LensStatement.executeQuery(String sql,
boolean waitForQueryToComplete,
String queryName,
LensConf conf)
This method can be used for executing a query.
|
QueryHandle |
LensClient.executeQueryAsynch(String sql,
String queryName)
Deprecated.
|
QueryHandle |
LensClient.executeQueryAsynch(String sql,
String queryName,
LensConf conf) |
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
LensStatement.getAllQueries(String state,
String queryName,
String user,
String driver,
String fromDate,
String toDate)
Gets the all queries.
|
List<QueryHandle> |
LensClient.getQueries(String state,
String queryName,
String user,
String driver,
String fromDate,
String toDate) |
Modifier and Type | Method and Description |
---|---|
LensClient.LensClientResultSetWithStats |
LensClient.getAsyncResults(QueryHandle q) |
javax.ws.rs.core.Response |
LensClient.getHttpResults(QueryHandle q) |
ResultSet |
LensClient.getHttpResultSet(QueryHandle queryHandle)
Gets the ResultSet for the query represented by queryHandle.
|
ResultSet |
LensClient.getHttpResultSet(QueryHandle queryHandle,
Charset encoding,
boolean isHeaderPresent,
char delimiter,
boolean isResultZipped)
Gets the ResultSet for the query represented by queryHandle.
|
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) |
QueryStatus |
LensStatement.getStatus(QueryHandle handle)
Gets status for query represented by handle.
|
LensClient.LensClientResultSetWithStats |
LensClient.getSyncResults(QueryHandle q) |
boolean |
LensClient.killQuery(QueryHandle q) |
void |
LensStatement.waitForQueryToComplete(QueryHandle handle) |
Modifier and Type | Method and Description |
---|---|
QueryHandle |
ProxyLensQuery.getQueryHandle() |
Constructor and Description |
---|
ProxyLensQuery(LensStatement statement,
QueryHandle queryHandle) |
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
|
Modifier and Type | Method and Description |
---|---|
Map<QueryHandle,org.apache.hive.service.cli.OperationHandle> |
HiveDriver.getHiveHandles()
The hive handles.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HiveDriver.cancelQuery(QueryHandle handle) |
void |
HiveDriver.closeQuery(QueryHandle handle) |
void |
HiveDriver.closeResultSet(QueryHandle handle) |
Modifier and Type | Method and Description |
---|---|
ConcurrentHashMap<QueryHandle,org.apache.lens.driver.jdbc.JDBCDriver.JdbcQueryContext> |
JDBCDriver.getQueryContextMap()
The query context map.
|
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.
|
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 |
---|
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<QueryHandle> |
QueryHelper.getQueryHandleList(String queryName,
String state,
String user,
String sessionHandleString,
String fromDate,
String toDate,
String driver)
List Query Handle
|
LensAPIResult<QueryHandle> |
SavedQueryResourceHelper.runSavedQuery(Long queryId,
HashMap<String,String> params) |
LensAPIResult<QueryHandle> |
SavedQueryResourceHelper.runSavedQuery(Long queryId,
String sessionHandleString,
HashMap<String,String> params) |
LensAPIResult<QueryHandle> |
SavedQueryResourceHelper.runSavedQuery(Long queryId,
String sessionHandleString,
String conf,
HashMap<String,String> params) |
Modifier and Type | Method and Description |
---|---|
QueryResult |
QueryHelper.getHttpResultSet(QueryHandle queryHandle)
Get the HTTP result set
|
String |
QueryHelper.getInmemoryResultSetJson(QueryHandle queryHandle,
String fromIndex,
String fetchSize,
String sessionHandleString) |
LensQuery |
QueryHelper.getLensQuery(String sessionHandleString,
QueryHandle queryHandle) |
String |
QueryHelper.getPersistentResultSetJson(QueryHandle queryHandle) |
String |
QueryHelper.getPersistentResultSetJson(QueryHandle queryHandle,
String fromIndex,
String fetchSize) |
String |
QueryHelper.getPersistentResultSetJson(QueryHandle queryHandle,
String fromIndex,
String fetchSize,
String sessionHandleString)
Get the Result set for json
|
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) |
javax.ws.rs.core.Response |
QueryHelper.getResultSetResponse(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) |
LensQuery |
QueryHelper.waitForCompletion(String sessionHandleString,
QueryHandle queryHandle,
javax.ws.rs.core.MediaType inputMediaType,
String outputMediaType)
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.
|
abstract void |
QueryCompletionListener.onCompletion(QueryHandle handle)
On completion.
|
void |
QueryDriverStatusUpdateListener.onDriverStatusUpdated(QueryHandle handle,
DriverQueryStatus status) |
void |
QueryCompletionListener.onDriverStatusUpdated(QueryHandle handle,
DriverQueryStatus status) |
abstract void |
QueryCompletionListener.onError(QueryHandle handle,
String error)
On error.
|
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 |
QueryContext.getQueryHandle()
The query handle.
|
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
QueryExecutionService.getAllQueries(LensSessionHandle sessionHandle,
String states,
String user,
String driver,
String queryName,
String fromDate,
String 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.
|
Modifier and Type | Method and Description |
---|---|
QueryHandle |
QueryEvent.getQueryHandle()
The query handle.
|
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.
|
QueryQueuedForRetry(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(List<QueryStatus.Status> states,
String user,
String driverName,
String queryName,
long fromDate,
long toDate)
Find finished queries.
|
List<QueryHandle> |
QueryServiceResource.getAllQueries(LensSessionHandle sessionid,
String states,
String queryName,
String user,
String driver,
String fromDate,
String toDate)
Get all the queries in the query server; can be filtered with state and queryName.
|
List<QueryHandle> |
QueryExecutionServiceImpl.getAllQueries(LensSessionHandle sessionHandle,
String states,
String userName,
String driver,
String queryName,
String fromDate,
String 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) |
QueryContext |
QueryExecutionServiceImpl.getQueryContext(QueryHandle queryHandle)
Gets the query context.
|
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 |
---|---|
LensAPIResult<QueryHandle> |
SavedQueryResource.run(long id,
javax.ws.rs.core.UriInfo info,
LensSessionHandle sessionid,
LensConf conf)
Runs the saved query with the given id and returns a query handle.
|
Modifier and Type | Method and Description |
---|---|
List<QueryHandle> |
LensSessionImpl.getActiveQueries()
List of queries which are submitted in this session.
|
Modifier and Type | Method and Description |
---|---|
void |
LensSessionImpl.addToActiveQueries(QueryHandle queryHandle) |
void |
LensSessionImpl.removeFromActiveQueries(QueryHandle queryHandle) |
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.