|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of LensException in org.apache.lens.client |
---|
Methods in org.apache.lens.client that throw LensException | |
---|---|
void |
LensMLClient.deleteModel(String algorithm,
String modelID)
Permanently delete a model instance. |
void |
LensMLClient.deleteTestReport(String algorithm,
String reportID)
Permanently delete a test report instance. |
MLAlgo |
LensMLClient.getAlgoForName(String algorithm)
Get a algo object instance which could be used to generate a model of the given algorithm. |
MLModel |
LensMLClient.getModel(String algorithm,
String modelId)
Get a model instance given the algorithm name and model ID. |
List<String> |
LensMLClient.getModels(String algorithm)
Get model IDs for the given algorithm. |
MLTestReport |
LensMLClient.getTestReport(String algorithm,
String reportID)
Get a test report by ID. |
List<String> |
LensMLClient.getTestReports(String algorithm)
Get test reports for an algorithm. |
Object |
LensMLClient.predict(String algorithm,
String modelID,
Object[] features)
Online predict call given a model ID, algorithm name and sample feature values. |
MLTestReport |
LensMLClient.testModel(LensSessionHandle session,
String table,
String algorithm,
String modelID,
String outputTable)
Evaluate model by running it against test data contained in the given table. |
String |
LensMLClient.train(String table,
String algorithm,
String[] args)
Create a model using the given HCatalog table as input. |
Uses of LensException in org.apache.lens.driver.cube |
---|
Methods in org.apache.lens.driver.cube that throw LensException | |
---|---|
static Map<LensDriver,String> |
RewriteUtil.rewriteQuery(AbstractQueryContext ctx)
Rewrite query. |
Uses of LensException in org.apache.lens.driver.hive |
---|
Methods in org.apache.lens.driver.hive that throw LensException | |
---|---|
boolean |
HiveDriver.cancelQuery(QueryHandle handle)
|
void |
HiveDriver.closePreparedQuery(QueryPrepareHandle handle)
|
void |
HiveDriver.closeQuery(QueryHandle handle)
|
void |
HiveDriver.closeResultSet(QueryHandle handle)
|
void |
HiveDriver.configure(org.apache.hadoop.conf.Configuration conf)
|
QueryCost |
HiveDriver.estimate(AbstractQueryContext qctx)
|
LensResultSet |
HiveDriver.execute(QueryContext ctx)
|
void |
HiveDriver.executeAsync(QueryContext ctx)
|
HiveQueryPlan |
HiveDriver.explain(AbstractQueryContext explainCtx)
|
DriverQueryPlan |
HiveDriver.explainAndPrepare(PreparedQueryContext pContext)
|
LensResultSet |
HiveDriver.fetchResultSet(QueryContext ctx)
|
org.apache.hive.service.cli.CLIServiceClient |
ThriftConnection.getClient(org.apache.hadoop.hive.conf.HiveConf conf)
Gets the client. |
org.apache.hive.service.cli.CLIServiceClient |
RemoteThriftConnection.getClient(org.apache.hadoop.hive.conf.HiveConf conf)
|
org.apache.hive.service.cli.thrift.ThriftCLIServiceClient |
EmbeddedThriftConnection.getClient(org.apache.hadoop.hive.conf.HiveConf conf)
|
LensResultSetMetadata |
HivePersistentResultSet.getMetadata()
|
LensResultSetMetadata |
HiveInMemoryResultSet.getMetadata()
|
String |
HivePersistentResultSet.getOutputPath()
|
boolean |
HiveInMemoryResultSet.hasNext()
|
ResultRow |
HiveInMemoryResultSet.next()
|
void |
HiveDriver.prepare(PreparedQueryContext pContext)
|
void |
HiveDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener)
|
void |
HiveInMemoryResultSet.setFetchSize(int size)
|
int |
HivePersistentResultSet.size()
|
int |
HiveInMemoryResultSet.size()
|
void |
HiveDriver.updateStatus(QueryContext context)
|
Constructors in org.apache.lens.driver.hive that throw LensException | |
---|---|
HiveDriver()
Instantiates a new hive driver. |
Uses of LensException in org.apache.lens.driver.hive.priority |
---|
Methods in org.apache.lens.driver.hive.priority that throw LensException | |
---|---|
Priority |
DurationBasedQueryPriorityDecider.decidePriority(AbstractQueryContext abstractQueryContext)
The Implementation |
Uses of LensException in org.apache.lens.driver.jdbc |
---|
Methods in org.apache.lens.driver.jdbc that throw LensException | |
---|---|
boolean |
JDBCDriver.cancelQuery(QueryHandle handle)
Cancel the execution of the query, specified by the handle. |
void |
JDBCDriver.close()
Close the driver, releasing all resouces used up by the driver. |
void |
JDBCDriver.closePreparedQuery(QueryPrepareHandle handle)
Close the prepare query specified by the prepared handle, releases all the resources held by the prepared query. |
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.configure(org.apache.hadoop.conf.Configuration conf)
Configure driver with Configuration passed |
QueryCost |
JDBCDriver.estimate(AbstractQueryContext qctx)
|
LensResultSet |
JDBCDriver.execute(QueryContext context)
Blocking execute of the query. |
void |
JDBCDriver.executeAsync(QueryContext context)
Asynchronously execute the query. |
DriverQueryPlan |
JDBCDriver.explain(AbstractQueryContext explainCtx)
Explain the given query. |
DriverQueryPlan |
JDBCDriver.explainAndPrepare(PreparedQueryContext pContext)
Explain and prepare the given query. |
LensResultSet |
JDBCDriver.fetchResultSet(QueryContext context)
Fetch the results of the query, specified by the handle. |
LensResultSetMetadata |
JDBCResultSet.getMetadata()
|
boolean |
JDBCResultSet.hasNext()
|
ResultRow |
JDBCResultSet.next()
|
void |
JDBCDriver.prepare(PreparedQueryContext pContext)
Prepare the given query. |
void |
JDBCDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener)
Register for query completion notification. |
String |
JDBCDriver.DummyQueryRewriter.rewrite(String query,
org.apache.hadoop.conf.Configuration queryConf)
|
String |
ColumnarSQLRewriter.rewrite(String query,
org.apache.hadoop.conf.Configuration conf)
|
void |
JDBCResultSet.setFetchSize(int size)
|
int |
JDBCResultSet.size()
|
void |
JDBCDriver.updateStatus(QueryContext context)
Get status of the query, specified by the handle. |
void |
JDBCDriver.validate(AbstractQueryContext pContext)
Validate query using prepare |
Uses of LensException in org.apache.lens.ml |
---|
Methods in org.apache.lens.ml that throw LensException | |
---|---|
void |
LensMLImpl.deleteModel(String algorithm,
String modelID)
|
void |
LensML.deleteModel(String algorithm,
String modelID)
Permanently delete a model instance. |
void |
LensMLImpl.deleteTestReport(String algorithm,
String reportID)
|
void |
LensML.deleteTestReport(String algorithm,
String reportID)
Permanently delete a test report instance. |
MLAlgo |
LensMLImpl.getAlgoForName(String algorithm)
|
MLAlgo |
LensML.getAlgoForName(String algorithm)
Get a algo object instance which could be used to generate a model of the given algorithm. |
MLAlgo |
Algorithms.getAlgoForName(String name)
Gets the algo for name. |
MLAlgo |
MLDriver.getAlgoInstance(String algo)
Gets the algo instance. |
MLModel |
LensMLImpl.getModel(String algorithm,
String modelId)
|
MLModel |
LensML.getModel(String algorithm,
String modelId)
Get a model instance given the algorithm name and model ID. |
List<String> |
LensMLImpl.getModels(String algorithm)
|
List<String> |
LensML.getModels(String algorithm)
Get model IDs for the given algorithm. |
MLTestReport |
LensMLImpl.getTestReport(String algorithm,
String reportID)
|
MLTestReport |
LensML.getTestReport(String algorithm,
String reportID)
Get a test report by ID. |
List<String> |
LensMLImpl.getTestReports(String algorithm)
|
List<String> |
LensML.getTestReports(String algorithm)
Get test reports for an algorithm. |
void |
MLDriver.init(LensConf conf)
Inits the. |
Object |
LensMLImpl.predict(String algorithm,
String modelID,
Object[] features)
|
Object |
LensML.predict(String algorithm,
String modelID,
Object[] features)
Online predict call given a model ID, algorithm name and sample feature values. |
abstract QueryHandle |
TestQueryRunner.runQuery(String query)
Run query. |
void |
MLDriver.start()
Start. |
void |
MLDriver.stop()
Stop. |
MLTestReport |
LensMLImpl.testModel(LensSessionHandle session,
String table,
String algorithm,
String modelID,
String outputTable)
|
MLTestReport |
LensML.testModel(LensSessionHandle session,
String table,
String algorithm,
String modelID,
String outputTable)
Evaluate model by running it against test data contained in the given table. |
MLTestReport |
LensMLImpl.testModel(LensSessionHandle sessionHandle,
String table,
String algorithm,
String modelID,
TestQueryRunner queryRunner,
String outputTable)
Evaluate a model. |
MLTestReport |
LensMLImpl.testModelRemote(LensSessionHandle sessionHandle,
String table,
String algorithm,
String modelID,
String queryApiUrl,
String outputTable)
Test a model in embedded mode. |
MLModel |
MLAlgo.train(LensConf conf,
String db,
String table,
String modelId,
String... params)
Train. |
String |
LensMLImpl.train(String table,
String algorithm,
String[] args)
|
String |
LensML.train(String table,
String algorithm,
String[] args)
Create a model using the given HCatalog table as input. |
Uses of LensException in org.apache.lens.ml.spark |
---|
Methods in org.apache.lens.ml.spark that throw LensException | |
---|---|
void |
SparkMLDriver.checkStarted()
Check started. |
void |
TableTrainingSpec.createRDDs(org.apache.spark.api.java.JavaSparkContext sparkContext)
Creates the rd ds. |
MLAlgo |
SparkMLDriver.getAlgoInstance(String name)
|
void |
SparkMLDriver.init(LensConf conf)
|
void |
SparkMLDriver.start()
|
void |
SparkMLDriver.stop()
|
Uses of LensException in org.apache.lens.ml.spark.algos |
---|
Methods in org.apache.lens.ml.spark.algos that throw LensException | |
---|---|
MLModel |
KMeansAlgo.train(LensConf conf,
String db,
String table,
String modelId,
String... params)
|
MLModel<?> |
BaseSparkAlgo.train(LensConf conf,
String db,
String table,
String modelId,
String... params)
|
Uses of LensException in org.apache.lens.rdd |
---|
Methods in org.apache.lens.rdd that throw LensException | |
---|---|
void |
LensRDDClient.cancelRDD(QueryHandle queryHandle)
Allow cancelling underlying query in case of non blocking RDD creation. |
LensRDDClient.LensRDDResult |
LensRDDClient.createLensRDD(String query)
Blocking call to create an RDD from a Lens query. |
QueryHandle |
LensRDDClient.createLensRDDAsync(String query)
API for non blocking use. |
void |
LensRDDClient.LensRDDResult.deleteTempTable()
Delete temp table. |
LensRDDClient.LensRDDResult |
LensRDDClient.getRDD(QueryHandle queryHandle)
Get the RDD created for the query. |
boolean |
LensRDDClient.isReadyForRDD(QueryHandle queryHandle)
Check if the RDD is created. |
org.apache.spark.rdd.RDD<List<Object>> |
LensRDDClient.LensRDDResult.recreateRDD(org.apache.spark.api.java.JavaSparkContext sparkContext)
Recreate RDD. |
Uses of LensException in org.apache.lens.server |
---|
Methods in org.apache.lens.server that throw LensException | |
---|---|
void |
LensService.addResource(LensSessionHandle sessionHandle,
String type,
String path)
Adds the resource. |
void |
LensService.closeSession(LensSessionHandle sessionHandle)
Close session. |
void |
LensService.deleteResource(LensSessionHandle sessionHandle,
String type,
String path)
Delete resource. |
org.apache.hadoop.conf.Configuration |
LensService.getLensConf(LensConf conf)
Gets the lens conf. |
org.apache.hadoop.conf.Configuration |
LensService.getLensConf(LensSessionHandle sessionHandle,
LensConf conf)
Gets the lens conf. |
void |
EventServiceImpl.notifyEvent(LensEvent evt)
|
LensSessionHandle |
LensService.openSession(String username,
String password,
Map<String,String> configuration)
Open session. |
void |
LensService.release(String sessionHandle)
Releases a lens session specified by the public UUID. |
void |
LensService.restoreSession(LensSessionHandle sessionHandle,
String userName,
String password)
Restore session from previous instance of lens server. |
Uses of LensException in org.apache.lens.server.api.driver |
---|
Methods in org.apache.lens.server.api.driver that throw LensException | |
---|---|
boolean |
LensDriver.cancelQuery(QueryHandle handle)
Cancel the execution of the query, specified by the handle. |
void |
LensDriver.close()
Close the driver, releasing all resouces used up by the driver. |
void |
LensDriver.closePreparedQuery(QueryPrepareHandle handle)
Close the prepare query specified by the prepared handle, releases all the resources held by the prepared query. |
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 |
LensDriver.configure(org.apache.hadoop.conf.Configuration conf)
Configure driver with Configuration passed. |
QueryCost |
LensDriver.estimate(AbstractQueryContext qctx)
Estimate the cost of execution for given query. |
LensResultSet |
LensDriver.execute(QueryContext context)
Blocking execute of the query The driver would be closing the driver handle, once the results are fetched. |
void |
LensDriver.executeAsync(QueryContext context)
Asynchronously execute the query. |
DriverQueryPlan |
LensDriver.explain(AbstractQueryContext explainCtx)
Explain the given query. |
DriverQueryPlan |
LensDriver.explainAndPrepare(PreparedQueryContext pContext)
Explain and prepare the given query. |
LensResultSet |
LensDriver.fetchResultSet(QueryContext context)
Fetch the results of the query, specified by the handle. |
abstract LensResultSetMetadata |
LensResultSet.getMetadata()
Get the result set metadata |
abstract String |
PersistentResultSet.getOutputPath()
|
abstract boolean |
InMemoryResultSet.hasNext()
Whether there is another result row available. |
abstract ResultRow |
InMemoryResultSet.next()
Read the next result row. |
void |
LensDriver.prepare(PreparedQueryContext pContext)
Prepare the given query. |
void |
LensDriver.registerForCompletionNotification(QueryHandle handle,
long timeoutMillis,
QueryCompletionListener listener)
Register for query completion notification. |
abstract void |
InMemoryResultSet.setFetchSize(int size)
Set number of rows to be fetched at time |
abstract int |
LensResultSet.size()
Get the size of the result set. |
QueryResult |
PersistentResultSet.toQueryResult()
|
abstract QueryResult |
LensResultSet.toQueryResult()
Get the corresponding query result object. |
QueryResult |
InMemoryResultSet.toQueryResult()
|
void |
LensDriver.updateStatus(QueryContext context)
Update driver query status in the context object. |
Uses of LensException in org.apache.lens.server.api.events |
---|
Methods in org.apache.lens.server.api.events that throw LensException | |
---|---|
void |
LensEventService.notifyEvent(LensEvent event)
Process an event, and notify all listeners interested in this event. |
void |
LensEventListener.onEvent(T event)
On event. |
void |
AsyncEventListener.onEvent(T event)
Creates a new runnable and calls the process method in it. |
Uses of LensException in org.apache.lens.server.api.metastore |
---|
Methods in org.apache.lens.server.api.metastore that throw LensException | |
---|---|
void |
CubeMetastoreService.addDimTableStorage(LensSessionHandle sessionid,
String dimTblName,
XStorageTableElement storageTable)
Add a storage to dimension table |
void |
CubeMetastoreService.addPartitionsToDimStorage(LensSessionHandle sessionid,
String dimTblName,
String storageName,
XPartitionList partitions)
Add partitions to dimension table on a storage. |
void |
CubeMetastoreService.addPartitionsToFactStorage(LensSessionHandle sessionid,
String fact,
String storageName,
XPartitionList partitions)
Add partitions to fact on a storage |
void |
CubeMetastoreService.addPartitionToDimStorage(LensSessionHandle sessionid,
String dimTblName,
String storageName,
XPartition partition)
Add partition to dimension table on a storage. |
void |
CubeMetastoreService.addPartitionToFactStorage(LensSessionHandle sessionid,
String fact,
String storageName,
XPartition partition)
Add partition to fact on a storage |
void |
CubeMetastoreService.addStorageToFact(LensSessionHandle sessionid,
String fact,
XStorageTableElement storageTable)
Add storage to fact table |
void |
CubeMetastoreService.alterStorage(LensSessionHandle sessionid,
String storageName,
XStorage storage)
Alter storage specified by name, with new definition |
void |
CubeMetastoreService.createCube(LensSessionHandle sessionid,
XCube cube)
Create a cube based on JAXB Cube object |
void |
CubeMetastoreService.createDatabase(LensSessionHandle sessionid,
String database,
boolean ignore)
Create a database in the metastore |
void |
CubeMetastoreService.createDimension(LensSessionHandle sessionid,
XDimension dimension)
Create a dimension based on JAXB Dimension object |
void |
CubeMetastoreService.createDimensionTable(LensSessionHandle sessionid,
XDimensionTable xDimTable)
Create dimension table |
void |
CubeMetastoreService.createFactTable(LensSessionHandle sessionid,
XFactTable fact)
Create fact table |
void |
CubeMetastoreService.createStorage(LensSessionHandle sessionid,
XStorage storage)
Create a storage |
void |
CubeMetastoreService.dropAllStoragesOfDimTable(LensSessionHandle sessionid,
String dimTblName)
Drop all storages of dimension table. |
void |
CubeMetastoreService.dropAllStoragesOfFact(LensSessionHandle sessionid,
String factName)
Drop all storages of fact |
void |
CubeMetastoreService.dropCube(LensSessionHandle sessionid,
String cubeName)
Drop a cube from the metastore in the currently deleted database. |
void |
CubeMetastoreService.dropDatabase(LensSessionHandle sessionid,
String database,
boolean cascade)
Drop a database from cube metastore |
void |
CubeMetastoreService.dropDimension(LensSessionHandle sessionid,
String dimName)
Drop a dimension from the metastore in the currently deleted database. |
void |
CubeMetastoreService.dropDimensionTable(LensSessionHandle sessionid,
String dimTblName,
boolean cascade)
Drop a dimension table from the cube metastore |
void |
CubeMetastoreService.dropFactTable(LensSessionHandle sessionid,
String fact,
boolean cascade)
Drop fact table. |
void |
CubeMetastoreService.dropPartitionFromStorageByFilter(LensSessionHandle sessionid,
String cubeTableName,
String storageName,
String filter)
Drop partition from storage with spec specified by filter |
void |
CubeMetastoreService.dropPartitionFromStorageByValues(LensSessionHandle sessionid,
String cubeTableName,
String storageName,
String values)
Drop partition from storage with spec specified as comma separated string |
void |
CubeMetastoreService.dropStorage(LensSessionHandle sessionid,
String storageName)
Drop a storage specified by name |
void |
CubeMetastoreService.dropStorageOfDimTable(LensSessionHandle sessionid,
String dimTblName,
String storage)
Drop storage of dimension table specified by name. |
void |
CubeMetastoreService.dropStorageOfFact(LensSessionHandle sessionid,
String fact,
String storage)
Drop storage of fact specified by fact name, storage name |
List<String> |
CubeMetastoreService.getAllBaseCubeNames(LensSessionHandle sessionid)
Get names of all base cube names in the current database |
List<String> |
CubeMetastoreService.getAllCubeNames(LensSessionHandle sessionid)
Get names of all cubes in the current database, includes both base cubes and derived cubes |
List<String> |
CubeMetastoreService.getAllDatabases(LensSessionHandle sessionid)
Get names of all databases in this metastore |
List<String> |
CubeMetastoreService.getAllDerivedCubeNames(LensSessionHandle sessionid)
Get names of all derived cubes in the current database |
List<String> |
CubeMetastoreService.getAllDimensionNames(LensSessionHandle sessionid)
Get all dimension names in the current session |
List<String> |
CubeMetastoreService.getAllDimTableNames(LensSessionHandle sessionid)
Get all dimension tables |
List<String> |
CubeMetastoreService.getAllFactNames(LensSessionHandle sessionid)
Get all fact names |
List<XFactTable> |
CubeMetastoreService.getAllFactsOfCube(LensSessionHandle sessionid,
String cubeName)
Get all facts of cube. |
List<String> |
CubeMetastoreService.getAllNativeTableNames(LensSessionHandle sessionid,
String dboption,
String dbName)
Get names of all native tables |
List<XPartition> |
CubeMetastoreService.getAllPartitionsOfDimTableStorage(LensSessionHandle sessionid,
String dimTblName,
String storage,
String filter)
Get all partitions of a dimension table in a storage |
List<XPartition> |
CubeMetastoreService.getAllPartitionsOfFactStorage(LensSessionHandle sessionid,
String fact,
String storage,
String filter)
Get all partitions of fact on a storage |
List<String> |
CubeMetastoreService.getAllQueryableCubeNames(LensSessionHandle sessionid)
Get names of all cubes, which can be queried in the current database |
List<String> |
CubeMetastoreService.getAllStorageNames(LensSessionHandle sessionid)
Get all storage names in current database |
XCube |
CubeMetastoreService.getCube(LensSessionHandle sessionid,
String cubeName)
Get a cube from the metastore |
String |
CubeMetastoreService.getCurrentDatabase(LensSessionHandle sessionid)
Get current database used by the CubeMetastoreClient |
XDimension |
CubeMetastoreService.getDimension(LensSessionHandle sessionid,
String dimName)
Get a dimension from the metastore |
XDimensionTable |
CubeMetastoreService.getDimensionTable(LensSessionHandle sessionid,
String dimTblName)
Get the dimension table from metastore |
List<String> |
CubeMetastoreService.getDimTableStorages(LensSessionHandle sessionid,
String dimTblName)
Get all storages of dimension table |
XFactTable |
CubeMetastoreService.getFactTable(LensSessionHandle sessionid,
String fact)
Get fact table given by name |
XFlattenedColumns |
CubeMetastoreService.getFlattenedColumns(LensSessionHandle sessionHandle,
String tableName)
Get flattened columns - all columns of table + all reachable columns |
Date |
CubeMetastoreService.getLatestDateOfCube(LensSessionHandle sessionid,
String cubeName,
String timeDimension)
Get the latest available date upto which data is available for the base cubes, for the time dimension |
XNativeTable |
CubeMetastoreService.getNativeTable(LensSessionHandle sessionid,
String name)
Get native table for the given name |
XStorage |
CubeMetastoreService.getStorage(LensSessionHandle sessionid,
String storageName)
Get Storage specified by name |
XStorageTableElement |
CubeMetastoreService.getStorageOfDim(LensSessionHandle sessionid,
String dimTblName,
String storageName)
Get storage table element associated with dimension table for storage name specified |
XStorageTableElement |
CubeMetastoreService.getStorageOfFact(LensSessionHandle sessionid,
String fact,
String storageName)
Get storage table of fact specifed by fact name, storage name |
List<String> |
CubeMetastoreService.getStoragesOfFact(LensSessionHandle sessionid,
String fact)
Get all storages of fact |
void |
CubeMetastoreService.setCurrentDatabase(LensSessionHandle sessionid,
String database)
Change the current database used by the CubeMetastoreClient |
void |
CubeMetastoreService.updateCube(LensSessionHandle sessionid,
XCube cube)
Update an existing cube |
void |
CubeMetastoreService.updateDimension(LensSessionHandle sessionid,
String dimName,
XDimension dimension)
Update an existing dimension |
void |
CubeMetastoreService.updateDimensionTable(LensSessionHandle sessionid,
XDimensionTable dimensionTable)
Update/Alter the dimension table |
void |
CubeMetastoreService.updateFactTable(LensSessionHandle sessionid,
XFactTable fact)
Update/Alter fact table |
Uses of LensException in org.apache.lens.server.api.priority |
---|
Methods in org.apache.lens.server.api.priority that throw LensException | |
---|---|
Priority |
QueryPriorityDecider.decidePriority(AbstractQueryContext queryContext)
|
Uses of LensException in org.apache.lens.server.api.query |
---|
Methods in org.apache.lens.server.api.query that throw LensException | |
---|---|
String |
QueryAcceptor.accept(String query,
org.apache.hadoop.conf.Configuration conf,
SubmitOp submitOp)
Whether to accept the query or not. |
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. |
boolean |
QueryExecutionService.destroyPrepared(LensSessionHandle sessionHandle,
QueryPrepareHandle prepared)
Destroy a prepared query. |
EstimateResult |
QueryExecutionService.estimate(LensSessionHandle sessionHandle,
String query,
LensConf conf)
Estimate the cost of given query. |
void |
AbstractQueryContext.estimateCostForDrivers()
Estimate cost for each driver and set in context |
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(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. |
QueryResult |
QueryExecutionService.fetchResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
long startIndex,
int fetchSize)
Fetch the results of the query, specified by the handle. |
List<QueryPrepareHandle> |
QueryExecutionService.getAllPreparedQueries(LensSessionHandle sessionHandle,
String user,
String queryName,
long fromDate,
long toDate)
Returns all the prepared queries for the specified user. |
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. |
javax.ws.rs.core.Response |
QueryExecutionService.getHttpResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
Get the http end point for the result set. |
LensPreparedQuery |
QueryExecutionService.getPreparedQuery(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle)
Get prepared query. |
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. |
QueryCost |
DriverSelectorQueryContext.getSelectedDriverQueryCost()
Return selected driver's query plan, but check for null conditions first. |
QueryCost |
AbstractQueryContext.getSelectedDriverQueryCost()
Get selected driver's cost |
DriverQueryPlan |
DriverSelectorQueryContext.getSelectedDriverQueryPlan()
Return selected driver's query plan, but check for null conditions first. |
DriverQueryPlan |
AbstractQueryContext.getSelectedDriverQueryPlan()
Wrapper method for convenience on driver context |
QueryPrepareHandle |
QueryExecutionService.prepare(LensSessionHandle sessionHandle,
String query,
LensConf conf,
String queryName)
Prepare the query. |
String |
QueryRewriter.rewrite(String query,
org.apache.hadoop.conf.Configuration queryConf)
Rewrite. |
void |
AbstractQueryContext.setDriverQueries(Map<LensDriver,String> driverQueries)
Set driver queries |
void |
DriverSelectorQueryContext.setDriverQueryPlans(Map<LensDriver,String> driverQueries,
AbstractQueryContext qctx)
Sets driver queries, generates plans for each driver by calling explain with respective queries, Sets driverQueryPlans |
void |
QueryContext.setStatus(QueryStatus newStatus)
|
QueryContext |
FinishedLensQuery.toQueryContext(org.apache.hadoop.conf.Configuration conf,
Collection<LensDriver> drivers)
|
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. |
Uses of LensException in org.apache.lens.server.api.session |
---|
Methods in org.apache.lens.server.api.session that throw LensException | |
---|---|
void |
SessionService.closeSession(LensSessionHandle sessionHandle)
Close session. |
List<String> |
SessionService.getAllSessionParameters(LensSessionHandle sessionHandle,
boolean verbose,
String key)
Gets the all session parameters. |
LensSessionHandle |
SessionService.openSession(String username,
String password,
String database,
Map<String,String> configuration)
Open session. |
void |
SessionService.restoreSession(LensSessionHandle sessionHandle,
String userName,
String password)
Restore session from previous instance of lens server. |
Uses of LensException in org.apache.lens.server.metastore |
---|
Methods in org.apache.lens.server.metastore that throw LensException | |
---|---|
void |
CubeMetastoreServiceImpl.addDimTableStorage(LensSessionHandle sessionid,
String dimTblName,
XStorageTableElement storageTable)
|
void |
CubeMetastoreServiceImpl.addPartitionsToDimStorage(LensSessionHandle sessionid,
String dimTblName,
String storageName,
XPartitionList partitions)
|
void |
CubeMetastoreServiceImpl.addPartitionsToFactStorage(LensSessionHandle sessionid,
String fact,
String storageName,
XPartitionList partitions)
|
void |
CubeMetastoreServiceImpl.addPartitionToDimStorage(LensSessionHandle sessionid,
String dimTblName,
String storageName,
XPartition partition)
|
void |
CubeMetastoreServiceImpl.addPartitionToFactStorage(LensSessionHandle sessionid,
String fact,
String storageName,
XPartition partition)
|
void |
CubeMetastoreServiceImpl.addStorageToFact(LensSessionHandle sessionid,
String fact,
XStorageTableElement storageTable)
|
void |
CubeMetastoreServiceImpl.alterStorage(LensSessionHandle sessionid,
String storageName,
XStorage storage)
|
void |
CubeMetastoreServiceImpl.createCube(LensSessionHandle sessionid,
XCube cube)
Create cube based on the JAXB cube object |
void |
CubeMetastoreServiceImpl.createDatabase(LensSessionHandle sessionid,
String database,
boolean ignore)
Create a database in Hive metastore |
void |
CubeMetastoreServiceImpl.createDimension(LensSessionHandle sessionid,
XDimension dimension)
|
void |
CubeMetastoreServiceImpl.createDimensionTable(LensSessionHandle sessionid,
XDimensionTable xDimTable)
Create a cube dimension table based on JAXB object |
APIResult |
MetastoreResource.createFactTable(LensSessionHandle sessionid,
XFactTable fact)
Create a new fact tabble |
void |
CubeMetastoreServiceImpl.createFactTable(LensSessionHandle sessionid,
XFactTable fact)
|
void |
CubeMetastoreServiceImpl.createStorage(LensSessionHandle sessionid,
XStorage storage)
|
void |
CubeMetastoreServiceImpl.dropAllStoragesOfDimTable(LensSessionHandle sessionid,
String dimTblName)
|
void |
CubeMetastoreServiceImpl.dropAllStoragesOfFact(LensSessionHandle sessionid,
String factName)
|
void |
CubeMetastoreServiceImpl.dropCube(LensSessionHandle sessionid,
String cubeName)
Drop a cube from the metastore in the currently deleted database |
void |
CubeMetastoreServiceImpl.dropDatabase(LensSessionHandle sessionid,
String database,
boolean cascade)
Drop a database from cube metastore |
void |
CubeMetastoreServiceImpl.dropDimension(LensSessionHandle sessionid,
String dimName)
|
void |
CubeMetastoreServiceImpl.dropDimensionTable(LensSessionHandle sessionid,
String dimTblName,
boolean cascade)
|
APIResult |
MetastoreResource.dropFactTable(LensSessionHandle sessionid,
String factName,
boolean cascade)
Drop the fact table, specified by name |
void |
CubeMetastoreServiceImpl.dropFactTable(LensSessionHandle sessionid,
String fact,
boolean cascade)
|
void |
CubeMetastoreServiceImpl.dropPartitionFromStorageByFilter(LensSessionHandle sessionid,
String cubeTableName,
String storageName,
String filter)
|
void |
CubeMetastoreServiceImpl.dropPartitionFromStorageByValues(LensSessionHandle sessionid,
String cubeTableName,
String storageName,
String values)
|
void |
CubeMetastoreServiceImpl.dropStorage(LensSessionHandle sessionid,
String storageName)
|
void |
CubeMetastoreServiceImpl.dropStorageOfDimTable(LensSessionHandle sessionid,
String dimTblName,
String storage)
|
void |
CubeMetastoreServiceImpl.dropStorageOfFact(LensSessionHandle sessionid,
String fact,
String storage)
|
List<String> |
CubeMetastoreServiceImpl.getAllBaseCubeNames(LensSessionHandle sessionid)
|
List<String> |
CubeMetastoreServiceImpl.getAllCubeNames(LensSessionHandle sessionid)
Get list of all cubes names in the current database |
List<String> |
CubeMetastoreServiceImpl.getAllDatabases(LensSessionHandle sessionid)
|
List<String> |
CubeMetastoreServiceImpl.getAllDerivedCubeNames(LensSessionHandle sessionid)
|
List<String> |
CubeMetastoreServiceImpl.getAllDimensionNames(LensSessionHandle sessionid)
|
StringList |
MetastoreResource.getAllDims(LensSessionHandle sessionid)
Get all dimension tables in the metastore |
List<String> |
CubeMetastoreServiceImpl.getAllDimTableNames(LensSessionHandle sessionid)
|
List<String> |
CubeMetastoreServiceImpl.getAllFactNames(LensSessionHandle sessionid)
|
StringList |
MetastoreResource.getAllFacts(LensSessionHandle sessionid)
Get all fact tables in the metastore in the current database |
List<XFactTable> |
MetastoreResource.getAllFactsOfCube(LensSessionHandle sessionid,
String cubeName)
Get all facts that belong to a cube in the metastore |
List<XFactTable> |
CubeMetastoreServiceImpl.getAllFactsOfCube(LensSessionHandle sessionid,
String cubeName)
|
List<String> |
CubeMetastoreServiceImpl.getAllNativeTableNames(LensSessionHandle sessionid,
String dbOption,
String dbName)
|
JAXBElement<XPartitionList> |
MetastoreResource.getAllPartitionsOfDimStorage(LensSessionHandle sessionid,
String dimension,
String storage,
String filter)
Get all partition of the dimension table in the specified storage; can be filtered |
List<XPartition> |
CubeMetastoreServiceImpl.getAllPartitionsOfDimTableStorage(LensSessionHandle sessionid,
String dimension,
String storageName,
String filter)
|
List<XPartition> |
CubeMetastoreServiceImpl.getAllPartitionsOfFactStorage(LensSessionHandle sessionid,
String fact,
String storageName,
String filter)
|
JAXBElement<XPartitionList> |
MetastoreResource.getAllPartitionsOfFactStorageByFilter(LensSessionHandle sessionid,
String factName,
String storage,
String filter)
Get all partitions of the fact table in the specified storage; can be filtered as well. |
List<String> |
CubeMetastoreServiceImpl.getAllQueryableCubeNames(LensSessionHandle sessionid)
|
List<String> |
CubeMetastoreServiceImpl.getAllStorageNames(LensSessionHandle sessionid)
|
XCube |
CubeMetastoreServiceImpl.getCube(LensSessionHandle sessionid,
String cubeName)
Get a cube from the metastore |
String |
CubeMetastoreServiceImpl.getCurrentDatabase(LensSessionHandle sessionid)
Get current database used by the CubeMetastoreClient |
XDimension |
CubeMetastoreServiceImpl.getDimension(LensSessionHandle sessionid,
String dimName)
|
StringList |
MetastoreResource.getDimensionStorages(LensSessionHandle sessionid,
String dimension)
Get all storages of the dimension table in the metastore |
JAXBElement<XDimensionTable> |
MetastoreResource.getDimensionTable(LensSessionHandle sessionid,
String dimTableName)
Get the dimension table specified by name |
XDimensionTable |
CubeMetastoreServiceImpl.getDimensionTable(LensSessionHandle sessionid,
String dimTblName)
|
List<String> |
CubeMetastoreServiceImpl.getDimTableStorages(LensSessionHandle sessionid,
String dimension)
|
JAXBElement<XFactTable> |
MetastoreResource.getFactTable(LensSessionHandle sessionid,
String factName)
Get the fact table specified by name |
XFactTable |
CubeMetastoreServiceImpl.getFactTable(LensSessionHandle sessionid,
String fact)
|
XFlattenedColumns |
CubeMetastoreServiceImpl.getFlattenedColumns(LensSessionHandle sessionHandle,
String tableName)
|
DateTime |
MetastoreResource.getLatestDateOfCube(LensSessionHandle sessionid,
String cubeName,
String timeDimension)
Get the latest available date upto which data is available for the base cubes, for the time dimension. |
Date |
CubeMetastoreServiceImpl.getLatestDateOfCube(LensSessionHandle sessionid,
String cubeName,
String timeDimension)
|
XNativeTable |
CubeMetastoreServiceImpl.getNativeTable(LensSessionHandle sessionid,
String name)
|
XStorage |
CubeMetastoreServiceImpl.getStorage(LensSessionHandle sessionid,
String storageName)
|
JAXBElement<XStorageTableElement> |
MetastoreResource.getStorageOfDim(LensSessionHandle sessionid,
String dimTableName,
String storage)
Get the dim storage table |
XStorageTableElement |
CubeMetastoreServiceImpl.getStorageOfDim(LensSessionHandle sessionid,
String dimTblName,
String storageName)
|
JAXBElement<XStorageTableElement> |
MetastoreResource.getStorageOfFact(LensSessionHandle sessionid,
String factName,
String storage)
Get the fact storage table |
XStorageTableElement |
CubeMetastoreServiceImpl.getStorageOfFact(LensSessionHandle sessionid,
String fact,
String storageName)
|
StringList |
MetastoreResource.getStoragesOfFact(LensSessionHandle sessionid,
String factName)
Get all storages of the fact table in the metastore |
List<String> |
CubeMetastoreServiceImpl.getStoragesOfFact(LensSessionHandle sessionid,
String fact)
|
void |
CubeMetastoreServiceImpl.setCurrentDatabase(LensSessionHandle sessionid,
String database)
Change the current database used by the CubeMetastoreClient |
void |
CubeMetastoreServiceImpl.updateCube(LensSessionHandle sessionid,
XCube cube)
Update cube |
void |
CubeMetastoreServiceImpl.updateDimension(LensSessionHandle sessionid,
String dimName,
XDimension dimension)
|
void |
CubeMetastoreServiceImpl.updateDimensionTable(LensSessionHandle sessionid,
XDimensionTable dimensionTable)
|
APIResult |
MetastoreResource.updateFactTable(LensSessionHandle sessionid,
String factName,
XFactTable fact)
Update fact table definition |
void |
CubeMetastoreServiceImpl.updateFactTable(LensSessionHandle sessionid,
XFactTable fact)
|
Uses of LensException in org.apache.lens.server.ml |
---|
Methods in org.apache.lens.server.ml that throw LensException | |
---|---|
String |
MLServiceResource.deleteModel(String algorithm,
String modelID)
Delete a model given model ID and algorithm name. |
void |
MLServiceImpl.deleteModel(String algorithm,
String modelID)
|
String |
MLServiceResource.deleteTestReport(String algorithm,
String reportID)
DELETE a report given the algorithm name and report ID. |
void |
MLServiceImpl.deleteTestReport(String algorithm,
String reportID)
|
MLAlgo |
MLServiceImpl.getAlgoForName(String algorithm)
|
MLModel |
MLServiceImpl.getModel(String algorithm,
String modelId)
|
ModelMetadata |
MLServiceResource.getModelMetadata(String algorithm,
String modelID)
Get metadata of the model given algorithm and model ID. |
List<String> |
MLServiceImpl.getModels(String algorithm)
|
StringList |
MLServiceResource.getModelsForAlgo(String algorithm)
Get model ID list for a given algorithm. |
StringList |
MLServiceResource.getReportsForAlgorithm(String algoritm)
Get list of reports for a given algorithm. |
TestReport |
MLServiceResource.getTestReport(String algorithm,
String reportID)
Get a single test report given the algorithm name and report id. |
MLTestReport |
MLServiceImpl.getTestReport(String algorithm,
String reportID)
|
List<String> |
MLServiceImpl.getTestReports(String algorithm)
|
Object |
MLServiceImpl.predict(String algorithm,
String modelID,
Object[] features)
|
String |
MLServiceResource.predict(String algorithm,
String modelID,
javax.ws.rs.core.UriInfo uriInfo)
Predict. |
String |
MLServiceResource.test(String algorithm,
String modelID,
String table,
LensSessionHandle session,
String outputTable)
Run a test on a model for an algorithm. |
MLTestReport |
MLServiceImpl.testModel(LensSessionHandle sessionHandle,
String table,
String algorithm,
String modelID,
String outputTable)
|
String |
MLServiceResource.train(String algorithm,
javax.ws.rs.core.MultivaluedMap<String,String> form)
Train a model given an algorithm name and algorithm parameters |
String |
MLServiceImpl.train(String table,
String algorithm,
String[] args)
|
Uses of LensException in org.apache.lens.server.query |
---|
Methods in org.apache.lens.server.query that throw LensException | |
---|---|
void |
QueryExecutionServiceImpl.addResource(LensSessionHandle sessionHandle,
String type,
String path)
|
boolean |
QueryExecutionServiceImpl.cancelQuery(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
|
void |
QueryExecutionServiceImpl.closeResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
|
void |
QueryExecutionServiceImpl.closeSession(LensSessionHandle sessionHandle)
|
void |
QueryExecutionServiceImpl.deleteResource(LensSessionHandle sessionHandle,
String type,
String path)
|
boolean |
QueryExecutionServiceImpl.destroyPrepared(LensSessionHandle sessionHandle,
QueryPrepareHandle prepared)
|
EstimateResult |
QueryExecutionServiceImpl.estimate(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)
|
QueryPlan |
QueryExecutionServiceImpl.explain(LensSessionHandle sessionHandle,
String query,
LensConf lensConf)
|
QueryPlan |
QueryExecutionServiceImpl.explainAndPrepare(LensSessionHandle sessionHandle,
String query,
LensConf lensConf,
String queryName)
|
QueryResult |
QueryExecutionServiceImpl.fetchResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
long startIndex,
int fetchSize)
|
List<QueryHandle> |
LensServerDAO.findFinishedQueries(String state,
String user,
String queryName,
long fromDate,
long toDate)
Find finished queries. |
List<QueryPrepareHandle> |
QueryExecutionServiceImpl.getAllPreparedQueries(LensSessionHandle sessionHandle,
String user,
String queryName,
long fromDate,
long toDate)
|
List<QueryHandle> |
QueryExecutionServiceImpl.getAllQueries(LensSessionHandle sessionHandle,
String state,
String userName,
String queryName,
long fromDate,
long toDate)
|
javax.ws.rs.core.Response |
QueryExecutionServiceImpl.getHttpResultSet(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
|
LensResultSetMetadata |
LensPersistentResult.getMetadata()
|
String |
LensPersistentResult.getOutputPath()
|
LensPreparedQuery |
QueryExecutionServiceImpl.getPreparedQuery(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle)
|
LensQuery |
QueryExecutionServiceImpl.getQuery(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
|
QueryResultSetMetadata |
QueryExecutionServiceImpl.getResultSetMetadata(LensSessionHandle sessionHandle,
QueryHandle queryHandle)
|
void |
QueryExecutionServiceImpl.QueryStatusLogger.onEvent(StatusChange event)
|
QueryPrepareHandle |
QueryExecutionServiceImpl.prepare(LensSessionHandle sessionHandle,
String query,
LensConf lensConf,
String queryName)
|
int |
LensPersistentResult.size()
|
boolean |
QueryExecutionServiceImpl.updateQueryConf(LensSessionHandle sessionHandle,
QueryHandle queryHandle,
LensConf newconf)
|
boolean |
QueryExecutionServiceImpl.updateQueryConf(LensSessionHandle sessionHandle,
QueryPrepareHandle prepareHandle,
LensConf newconf)
|
Constructors in org.apache.lens.server.query that throw LensException | |
---|---|
QueryExecutionServiceImpl(org.apache.hive.service.cli.CLIService cliService)
Instantiates a new query execution service impl. |
|
QueryServiceResource()
Instantiates a new query service resource. |
Uses of LensException in org.apache.lens.server.session |
---|
Methods in org.apache.lens.server.session that throw LensException | |
---|---|
void |
HiveSessionService.closeSession(LensSessionHandle sessionHandle)
|
List<String> |
HiveSessionService.getAllSessionParameters(LensSessionHandle sessionid,
boolean verbose,
String key)
|
CubeMetastoreClient |
LensSessionImpl.getCubeMetastoreClient()
|
void |
DatabaseResourceService.loadResources()
Load DB specific resources |
LensSessionHandle |
HiveSessionService.openSession(String username,
String password,
String database,
Map<String,String> configuration)
|
Constructors in org.apache.lens.server.session that throw LensException | |
---|---|
SessionResource()
Instantiates a new session resource. |
Uses of LensException in org.apache.lens.server.ui |
---|
Constructors in org.apache.lens.server.ui that throw LensException | |
---|---|
SessionUIResource()
Instantiates a new session ui resource. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |