Modifier and Type | Method and Description |
---|---|
QueryCost |
FactPartitionBasedQueryCostCalculator.calculateCost(AbstractQueryContext queryContext,
LensDriver driver) |
Map<String,Set<?>> |
FactPartitionBasedQueryCostCalculator.getAllPartitions(AbstractQueryContext queryContext,
LensDriver driver) |
Modifier and Type | Class and Description |
---|---|
class |
ESDriver
Driver for elastic search
|
Modifier and Type | Class and Description |
---|---|
class |
HiveDriver
The Class HiveDriver.
|
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 | Class and Description |
---|---|
class |
AbstractLensDriver
Abstract class for Lens Driver Implementations.
|
Modifier and Type | Method and Description |
---|---|
LensDriver |
DriverEvent.getDriver() |
LensDriver |
WeightedQueryCostDriverSelector.select(AbstractQueryContext ctx,
org.apache.hadoop.conf.Configuration conf)
Returns the driver that has the minimum query cost according to predefined driver allocation ratios.
|
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 |
NoOpDriverQueryHook.getDriver() |
Modifier and Type | Method and Description |
---|---|
void |
UserBasedQueryHook.setDriver(LensDriver driver) |
void |
QueryCostBasedQueryHook.setDriver(LensDriver driver) |
void |
NoOpDriverQueryHook.setDriver(LensDriver driver) |
void |
DriverQueryHook.setDriver(LensDriver driver)
This setter method is called by the driver once hook instance is created.
|
void |
ChainedDriverQueryHook.setDriver(LensDriver driver) |
Modifier and Type | Method and Description |
---|---|
LensDriver |
DriverSelectorQueryContext.DriverQueryContext.getDriver() |
LensDriver |
FinishedLensQuery.getSelectedDriver() |
LensDriver |
DriverSelectorQueryContext.getSelectedDriver()
The selected driver.
|
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
|
Map<LensDriver,DriverSelectorQueryContext.DriverQueryContext> |
DriverSelectorQueryContext.getDriverQueryContextMap()
Map of driver to driver specific query context
|
Collection<LensDriver> |
DriverSelectorQueryContext.getDrivers() |
Collection<LensDriver> |
DriverSelectorQueryContext.getDriversWithValidQueryCost() |
Collection<LensDriver> |
DriverSelectorQueryContext.getEligibleDrivers() |
Modifier and Type | Method and Description |
---|---|
void |
DriverSelectorQueryContext.blacklist(LensDriver selectedDriver) |
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.
|
void |
QueryContext.extractFailedAttempt(LensDriver selectedDriver) |
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) |
DriverQueryPlan |
AbstractQueryContext.getDriverRewriterPlan(LensDriver driver) |
String |
DriverSelectorQueryContext.getFinalDriverQuery(LensDriver driver) |
String |
AbstractQueryContext.getFinalDriverQuery(LensDriver driver) |
Map<String,Double> |
AbstractQueryContext.getTableWeights(LensDriver driver) |
void |
DriverSelectorQueryContext.setDriverConf(LensDriver driver,
org.apache.hadoop.conf.Configuration conf) |
void |
DriverSelectorQueryContext.setDriverCost(LensDriver driver,
QueryCost cost) |
void |
AbstractQueryContext.setDriverCost(LensDriver driver,
QueryCost cost) |
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 |
DriverSelectorQueryContext.setSelectedDriver(LensDriver selectedDriver)
The selected 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.setDriverQueryContextMap(Map<LensDriver,DriverSelectorQueryContext.DriverQueryContext> driverQueryContextMap)
Map of driver to driver specific query context
|
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 |
---|
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
|
Modifier and Type | Method and Description |
---|---|
Set<QueryContext> |
EstimatedImmutableQueryCollection.getQueries(LensDriver driver) |
int |
EstimatedImmutableQueryCollection.getQueriesCount(LensDriver driver) |
Modifier and Type | Method and Description |
---|---|
QueryCost |
QueryCostCalculator.calculateCost(AbstractQueryContext queryContext,
LensDriver driver) |
Modifier and Type | Method and Description |
---|---|
LensDriver |
QueryExecutionServiceImpl.RewriteEstimateRunnable.getDriver() |
Constructor and Description |
---|
RewriteEstimateRunnable(LensDriver driver,
RewriteUtil.DriverRewriterRunnable rewriterRunnable,
AbstractQueryContext.DriverEstimateRunnable estimateRunnable,
AbstractQueryContext ctx,
CountDownLatch estimateCompletionLatch) |
Modifier and Type | Method and Description |
---|---|
Set<QueryContext> |
ThreadSafeEstimatedQueryCollection.getQueries(LensDriver driver) |
Set<QueryContext> |
DefaultEstimatedQueryCollection.getQueries(LensDriver driver) |
int |
ThreadSafeEstimatedQueryCollection.getQueriesCount(LensDriver driver) |
int |
DefaultEstimatedQueryCollection.getQueriesCount(LensDriver driver) |
Modifier and Type | Method and Description |
---|---|
LensDriver |
RewriteUtil.DriverRewriterRunnable.getDriver() |
Modifier and Type | Method and Description |
---|---|
static Map<LensDriver,RewriteUtil.DriverRewriterRunnable> |
RewriteUtil.rewriteQuery(AbstractQueryContext ctx)
Rewrite query.
|
Constructor and Description |
---|
DriverRewriterRunnable(LensDriver driver,
AbstractQueryContext ctx,
List<org.apache.lens.server.rewrite.RewriteUtil.CubeQueryInfo> cubeQueries,
String replacedQuery) |
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.