org.apache.lens.server.api.query

Class DriverSelectorQueryContext

java.lang.Object

org.apache.lens.server.api.query.DriverSelectorQueryContext

public class DriverSelectorQueryContext
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DriverSelectorQueryContext.DriverQueryContext

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	blacklist(LensDriver selectedDriver)
org.apache.hadoop.conf.Configuration	getDriverConf(LensDriver driver)
Collection<String>	getDriverQueries()
String	getDriverQuery(LensDriver driver)
Map<LensDriver,DriverSelectorQueryContext.DriverQueryContext>	getDriverQueryContextMap() Map of driver to driver specific query context
QueryCost	getDriverQueryCost(LensDriver driver)
DriverQueryPlan	getDriverQueryPlan(LensDriver driver)
DriverQueryPlan	getDriverRewriterPlan(LensDriver driver)
Collection<LensDriver>	getDrivers()
Collection<LensDriver>	getDriversWithValidQueryCost()
Collection<LensDriver>	getEligibleDrivers()
String	getFinalDriverQuery(LensDriver driver)
LensDriver	getSelectedDriver() The selected driver.
org.apache.hadoop.conf.Configuration	getSelectedDriverConf()
String	getSelectedDriverQuery()
DriverQueryPlan	getSelectedDriverQueryPlan() Return selected driver's query plan, but check for null conditions first.
void	setDriverConf(LensDriver driver, org.apache.hadoop.conf.Configuration conf)
void	setDriverCost(LensDriver driver, QueryCost cost)
void	setDriverQuery(LensDriver driver, String driverQuery)
void	setDriverQueryContextMap(Map<LensDriver,DriverSelectorQueryContext.DriverQueryContext> driverQueryContextMap) Map of driver to driver specific query context
void	setDriverQueryPlan(LensDriver driver, DriverQueryPlan qp)
void	setDriverQueryPlans(Map<LensDriver,String> driverQueries, AbstractQueryContext qctx) Sets driver queries, generates plans for each driver by calling explain with respective queries, Sets driverQueryPlans
void	setDriverRewriterPlan(LensDriver driver, DriverQueryPlan rewriterPlan)
void	setSelectedDriver(LensDriver selectedDriver) The selected driver.
void	setSelectedDriverQuery(String driverQuery)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DriverSelectorQueryContext

public DriverSelectorQueryContext(String userQuery,
                                  org.apache.hadoop.conf.Configuration queryConf,
                                  Collection<LensDriver> drivers)

DriverSelectorQueryContext

public DriverSelectorQueryContext(String userQuery,
                                  org.apache.hadoop.conf.Configuration queryConf,
                                  Collection<LensDriver> drivers,
                                  boolean mergeConf)

Method Detail

blacklist

public void blacklist(LensDriver selectedDriver)

setDriverQuery

public void setDriverQuery(LensDriver driver,
                           String driverQuery)

setDriverQueryPlans

public void setDriverQueryPlans(Map<LensDriver,String> driverQueries,
                                AbstractQueryContext qctx)
                         throws LensException

Sets driver queries, generates plans for each driver by calling explain with respective queries, Sets driverQueryPlans

Parameters:

driverQueries -

Throws:

LensException

getSelectedDriverQueryPlan

public DriverQueryPlan getSelectedDriverQueryPlan()
                                           throws LensException

Return selected driver's query plan, but check for null conditions first.

Returns:

DriverQueryPlan of Selected Driver

Throws:

LensException

getSelectedDriverConf

public org.apache.hadoop.conf.Configuration getSelectedDriverConf()

getSelectedDriverQuery

public String getSelectedDriverQuery()

setDriverConf

public void setDriverConf(LensDriver driver,
                          org.apache.hadoop.conf.Configuration conf)

setDriverCost

public void setDriverCost(LensDriver driver,
                          QueryCost cost)

setSelectedDriverQuery

public void setSelectedDriverQuery(String driverQuery)

getDrivers

public Collection<LensDriver> getDrivers()

getEligibleDrivers

public Collection<LensDriver> getEligibleDrivers()

getDriversWithValidQueryCost

public Collection<LensDriver> getDriversWithValidQueryCost()

getDriverQueries

public Collection<String> getDriverQueries()

setDriverRewriterPlan

public void setDriverRewriterPlan(LensDriver driver,
                                  DriverQueryPlan rewriterPlan)

getDriverRewriterPlan

public DriverQueryPlan getDriverRewriterPlan(LensDriver driver)

getDriverQueryPlan

public DriverQueryPlan getDriverQueryPlan(LensDriver driver)

getDriverConf

public org.apache.hadoop.conf.Configuration getDriverConf(LensDriver driver)

getDriverQuery

public String getDriverQuery(LensDriver driver)

getFinalDriverQuery

public String getFinalDriverQuery(LensDriver driver)

getDriverQueryCost

public QueryCost getDriverQueryCost(LensDriver driver)

setDriverQueryPlan

public void setDriverQueryPlan(LensDriver driver,
                               DriverQueryPlan qp)

getSelectedDriver

@Generated(value="lombok")
public LensDriver getSelectedDriver()

The selected driver.

setSelectedDriver

@Generated(value="lombok")
public void setSelectedDriver(LensDriver selectedDriver)

The selected driver.

getDriverQueryContextMap

@Generated(value="lombok")
public Map<LensDriver,DriverSelectorQueryContext.DriverQueryContext> getDriverQueryContextMap()

Map of driver to driver specific query context

setDriverQueryContextMap

@Generated(value="lombok")
public void setDriverQueryContextMap(Map<LensDriver,DriverSelectorQueryContext.DriverQueryContext> driverQueryContextMap)

Map of driver to driver specific query context