| 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.