Modifier and Type | Method and Description |
---|---|
static Map<LensDriver,RewriteUtil.DriverRewriterRunnable> |
RewriteUtil.rewriteQuery(AbstractQueryContext ctx)
Rewrite query.
|
Constructor and Description |
---|
RewriteUtil.DriverRewriterRunnable(LensDriver driver,
AbstractQueryContext ctx,
List<org.apache.lens.driver.cube.RewriteUtil.CubeQueryInfo> cubeQueries,
String replacedQuery) |
Modifier and Type | Class and Description |
---|---|
class |
HiveDriver
The Class HiveDriver.
|
Constructor and Description |
---|
DurationBasedQueryPriorityDecider(LensDriver driver,
String ranges,
float monthlyPartitoinWeight,
float dailyPartitionWeight,
float hourlyPartitionWeight)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
JDBCDriver
This driver is responsible for running queries against databases which can be queried using the JDBC API.
|
Modifier and Type | Method and Description |
---|---|
LensDriver |
DriverEvent.getDriver() |
LensDriver |
MinQueryCostSelector.select(AbstractQueryContext ctx,
org.apache.hadoop.conf.Configuration conf)
Returns the driver that has the minimum query cost.
|
LensDriver |
DriverSelector.select(AbstractQueryContext ctx,
org.apache.hadoop.conf.Configuration conf)
Select.
|
Constructor and Description |
---|
DriverEvent(long eventTime,
LensDriver driver)
Instantiates a new driver event.
|
DriverSessionStarted(long eventTime,
LensDriver driver,
String lensSessionID,
String driverSessionID)
Instantiates a new driver session started.
|
Modifier and Type | Method and Description |
---|---|
LensDriver |
AbstractQueryContext.getSelectedDriver()
Wrapper method for convenience on driver context
|
Modifier and Type | Method and Description |
---|---|
Map<LensDriver,AbstractQueryContext.DriverEstimateRunnable> |
AbstractQueryContext.getDriverEstimateRunnables()
Get runnables wrapping estimate computation, which could be processed offline
|
Collection<LensDriver> |
DriverSelectorQueryContext.getDrivers() |
Modifier and Type | Method and Description |
---|---|
static QueryContext |
QueryContext.createContextWithSingleDriver(String query,
String user,
LensConf qconf,
org.apache.hadoop.conf.Configuration conf,
LensDriver driver,
String lensSessionPublicId,
boolean mergeDriverConf)
Utility create method to create context with single driver.
|
org.apache.hadoop.conf.Configuration |
DriverSelectorQueryContext.getDriverConf(LensDriver driver) |
org.apache.hadoop.conf.Configuration |
AbstractQueryContext.getDriverConf(LensDriver driver)
Get driver conf
|
String |
DriverSelectorQueryContext.getDriverQuery(LensDriver driver) |
String |
AbstractQueryContext.getDriverQuery(LensDriver driver)
Get driver query
|
QueryCost |
DriverSelectorQueryContext.getDriverQueryCost(LensDriver driver) |
QueryCost |
AbstractQueryContext.getDriverQueryCost(LensDriver driver)
Get query cost for the driver
|
DriverQueryPlan |
DriverSelectorQueryContext.getDriverQueryPlan(LensDriver driver) |
Exception |
AbstractQueryContext.getDriverRewriteError(LensDriver driver)
Get exception during rewrite.
|
DriverQueryPlan |
DriverSelectorQueryContext.getDriverRewriterPlan(LensDriver driver) |
String |
DriverSelectorQueryContext.getFinalDriverQuery(LensDriver driver) |
String |
AbstractQueryContext.getFinalDriverQuery(LensDriver driver) |
void |
DriverSelectorQueryContext.setDriverConf(LensDriver driver,
org.apache.hadoop.conf.Configuration conf) |
void |
DriverSelectorQueryContext.setDriverQuery(LensDriver driver,
String driverQuery) |
void |
AbstractQueryContext.setDriverQuery(LensDriver driver,
String query)
Set query for a given driver
|
void |
DriverSelectorQueryContext.setDriverQueryPlan(LensDriver driver,
DriverQueryPlan qp) |
void |
AbstractQueryContext.setDriverRewriteError(LensDriver driver,
Exception exp)
Set exception during rewrite.
|
void |
DriverSelectorQueryContext.setDriverRewriterPlan(LensDriver driver,
DriverQueryPlan rewriterPlan) |
void |
AbstractQueryContext.setFinalDriverQuery(LensDriver driver,
String rewrittenQuery)
Set final driver rewritten query for the driver.
|
void |
AbstractQueryContext.setSelectedDriver(LensDriver driver)
Wrapper method for convenience on driver context
|
Modifier and Type | Method and Description |
---|---|
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
|
QueryContext |
FinishedLensQuery.toQueryContext(org.apache.hadoop.conf.Configuration conf,
Collection<LensDriver> drivers) |
Constructor and Description |
---|
AbstractQueryContext.DriverEstimateRunnable(AbstractQueryContext queryContext,
LensDriver driver) |
Constructor and Description |
---|
DriverSelectorQueryContext(String userQuery,
org.apache.hadoop.conf.Configuration queryConf,
Collection<LensDriver> drivers) |
DriverSelectorQueryContext(String userQuery,
org.apache.hadoop.conf.Configuration queryConf,
Collection<LensDriver> drivers,
boolean mergeConf) |
ExplainQueryContext(String requestId,
String query,
String user,
LensConf conf,
org.apache.hadoop.conf.Configuration qconf,
Collection<LensDriver> drivers)
Constructor.
|
PreparedQueryContext(String query,
String user,
org.apache.hadoop.conf.Configuration conf,
Collection<LensDriver> drivers)
Instantiates a new prepared query context.
|
PreparedQueryContext(String query,
String user,
org.apache.hadoop.conf.Configuration conf,
LensConf qconf,
Collection<LensDriver> drivers)
Instantiates a new prepared query context.
|
QueryContext(String query,
String user,
LensConf qconf,
org.apache.hadoop.conf.Configuration conf,
Collection<LensDriver> drivers)
Creates context from query
|
Constructor and Description |
---|
QueryExecutionServiceImpl.RewriteEstimateRunnable(LensDriver driver,
RewriteUtil.DriverRewriterRunnable rewriterRunnable,
AbstractQueryContext.DriverEstimateRunnable estimateRunnable,
AbstractQueryContext ctx,
CountDownLatch estimateCompletionLatch) |
Copyright © 2014–2015 Apache Software Foundation. All rights reserved.