Uses of Class
org.apache.lens.api.LensException

Packages that use LensException
org.apache.lens.client   
org.apache.lens.driver.cube   
org.apache.lens.driver.hive   
org.apache.lens.driver.hive.priority   
org.apache.lens.driver.jdbc   
org.apache.lens.ml   
org.apache.lens.ml.spark   
org.apache.lens.ml.spark.algos   
org.apache.lens.rdd   
org.apache.lens.server   
org.apache.lens.server.api.driver   
org.apache.lens.server.api.events   
org.apache.lens.server.api.metastore   
org.apache.lens.server.api.priority   
org.apache.lens.server.api.query   
org.apache.lens.server.api.session   
org.apache.lens.server.metastore   
org.apache.lens.server.ml   
org.apache.lens.server.query   
org.apache.lens.server.session   
org.apache.lens.server.ui   
 

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.
 



Copyright © 2014–2015 Apache Software Foundation. All rights reserved.