Modifier and Type | Method and Description |
---|---|
LensConf |
LensPreparedQuery.getConf()
The conf.
|
LensConf |
LensQuery.getQueryConf()
The query conf.
|
Constructor and Description |
---|
LensPreparedQuery(QueryPrepareHandle prepareHandle,
String userQuery,
Date preparedTime,
String preparedUser,
String selectedDriverClassName,
String driverQuery,
LensConf conf) |
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) |
Constructor and Description |
---|
PathValidator(LensConf config) |
Modifier and Type | Method and Description |
---|---|
LensConf |
LensConnectionParams.getSessionConf() |
Modifier and Type | Method and Description |
---|---|
LensConf |
MLAlgo.getConf() |
Modifier and Type | Method and Description |
---|---|
void |
MLAlgo.configure(LensConf configuration)
Configure.
|
void |
MLDriver.init(LensConf conf)
Inits the.
|
MLModel |
MLAlgo.train(LensConf conf,
String db,
String table,
String modelId,
String... params)
Train.
|
Modifier and Type | Method and Description |
---|---|
LensConf |
BaseSparkAlgo.getConf() |
Modifier and Type | Method and Description |
---|---|
void |
BaseSparkAlgo.configure(LensConf configuration) |
void |
SparkMLDriver.init(LensConf conf) |
MLModel<?> |
BaseSparkAlgo.train(LensConf conf,
String db,
String table,
String modelId,
String... params) |
Modifier and Type | Method and Description |
---|---|
LensConf |
KMeansAlgo.getConf() |
Modifier and Type | Method and Description |
---|---|
void |
KMeansAlgo.configure(LensConf configuration) |
MLModel |
KMeansAlgo.train(LensConf conf,
String db,
String table,
String modelId,
String... params) |
Modifier and Type | Method and Description |
---|---|
LensAPIResult |
QueryHelper.executeQuery(String queryString,
String queryName,
String user,
String sessionHandleString,
LensConf conf)
Execute the query
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
BaseLensService.getLensConf(LensConf conf)
Gets the lens conf.
|
org.apache.hadoop.conf.Configuration |
BaseLensService.getLensConf(LensSessionHandle sessionHandle,
LensConf conf)
Gets the lens conf.
|
Modifier and Type | Method and Description |
---|---|
LensConf |
AbstractQueryContext.getLensConf()
The query conf.
|
Modifier and Type | Method and Description |
---|---|
static QueryContext |
QueryContext.createContextWithSingleDriver(String query,
String user,
LensConf qconf,
org.apache.hadoop.conf.Configuration conf,
LensDriver driver,
String lensSessionPublicId,
boolean mergeDriverConf)
Utility create method to create context with single driver.
|
QueryCost |
QueryExecutionService.estimate(String requestId,
LensSessionHandle sessionHandle,
String query,
LensConf conf)
Estimate the cost of given query.
|
QueryHandleWithResultSet |
QueryExecutionService.execute(LensSessionHandle sessionHandle,
String query,
long timeoutmillis,
LensConf conf,
String queryName)
Execute the query with a timeout.
|
QueryHandle |
QueryExecutionService.executeAsync(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName)
Asynchronously execute the query.
|
QueryHandleWithResultSet |
QueryExecutionService.executePrepare(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
long timeoutmillis,
LensConf conf,
String queryName)
Execute already prepared query with timeout.
|
QueryHandle |
QueryExecutionService.executePrepareAsync(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf conf,
String queryName)
Execute already prepared query asynchronously.
|
QueryPlan |
QueryExecutionService.explain(String requestId,
LensSessionHandle sessionHandle,
String query,
LensConf conf)
Explain the given query.
|
QueryPlan |
QueryExecutionService.explainAndPrepare(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName)
Explain the given query and prepare it as well.
|
QueryPrepareHandle |
QueryExecutionService.prepare(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName)
Prepare the query.
|
boolean |
QueryExecutionService.updateQueryConf(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
LensConf newconf)
Update the query conf.
|
boolean |
QueryExecutionService.updateQueryConf(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf newconf)
Update configuration for prepared query.
|
Constructor and Description |
---|
ExplainQueryContext(String requestId,
String query,
String user,
LensConf conf,
org.apache.hadoop.conf.Configuration qconf,
Collection<LensDriver> drivers)
Constructor.
|
PreparedQueryContext(String query,
String user,
org.apache.hadoop.conf.Configuration conf,
LensConf qconf,
Collection<LensDriver> drivers)
Instantiates a new prepared query context.
|
QueryContext(PreparedQueryContext prepared,
String user,
LensConf qconf,
org.apache.hadoop.conf.Configuration conf)
Creates context from PreparedQueryContext
|
QueryContext(String query,
String user,
LensConf qconf,
org.apache.hadoop.conf.Configuration conf,
Collection<LensDriver> drivers)
Creates context from query
|
Modifier and Type | Method and Description |
---|---|
QueryCost |
QueryExecutionServiceImpl.estimate(String requestId,
LensSessionHandle sessionHandle,
String query,
LensConf lensConf) |
QueryHandleWithResultSet |
QueryExecutionServiceImpl.execute(LensSessionHandle sessionHandle,
String query,
long timeoutMillis,
LensConf conf,
String queryName) |
QueryHandle |
QueryExecutionServiceImpl.executeAsync(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName) |
QueryHandleWithResultSet |
QueryExecutionServiceImpl.executePrepare(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
long timeoutMillis,
LensConf conf,
String queryName) |
QueryHandle |
QueryExecutionServiceImpl.executePrepareAsync(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf conf,
String queryName) |
QuerySubmitResult |
QueryServiceResource.executePrepared(LensSessionHandle sessionid,
String prepareHandle,
String operation,
LensConf conf,
Long timeoutmillis,
String queryName)
Submit prepared query for execution.
|
QueryPlan |
QueryExecutionServiceImpl.explain(String requestId,
LensSessionHandle sessionHandle,
String query,
LensConf lensConf) |
QueryPlan |
QueryExecutionServiceImpl.explainAndPrepare(LensSessionHandle sessionHandle,
String query,
LensConf lensConf,
String queryName) |
QueryPrepareHandle |
QueryExecutionServiceImpl.prepare(LensSessionHandle sessionHandle,
String query,
LensConf lensConf,
String queryName) |
LensAPIResult<? extends QuerySubmitResult> |
QueryServiceResource.prepareQuery(LensSessionHandle sessionid,
String query,
String operation,
LensConf conf,
String queryName)
Prepare a query or 'explain and prepare' the query.
|
LensAPIResult<? extends QuerySubmitResult> |
QueryServiceResource.query(LensSessionHandle sessionid,
String query,
String operation,
LensConf conf,
Long timeoutmillis,
String queryName)
Submit the query for explain or execute or execute with a timeout.
|
APIResult |
QueryServiceResource.updateConf(LensSessionHandle sessionid,
String queryHandle,
LensConf conf)
Modify query configuration if it is not running yet.
|
APIResult |
QueryServiceResource.updatePreparedConf(LensSessionHandle sessionid,
String prepareHandle,
LensConf conf)
Modify prepared query's configuration.
|
boolean |
QueryExecutionServiceImpl.updateQueryConf(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
LensConf newconf) |
boolean |
QueryExecutionServiceImpl.updateQueryConf(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf newconf) |
Modifier and Type | Method and Description |
---|---|
LensAPIResult<? extends QuerySubmitResult> |
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 |
---|---|
LensSessionHandle |
SessionResource.openSession(String username,
String password,
String database,
LensConf sessionconf)
Create a new session with Lens server.
|
Modifier and Type | Method and Description |
---|---|
LensSessionHandle |
SessionUIResource.openSession(String username,
String password,
String database,
LensConf sessionconf)
Create a new session with Lens server.
|
Copyright © 2014–2015 Apache Software Foundation. All rights reserved.