org.apache.lens.driver.jdbc

Class DruidSQLRewriter

java.lang.Object

org.apache.lens.driver.jdbc.ColumnarSQLRewriter

org.apache.lens.driver.jdbc.DruidSQLRewriter

All Implemented Interfaces:

QueryRewriter

public class DruidSQLRewriter
extends ColumnarSQLRewriter

Constructor Summary

Constructors

Constructor and Description
DruidSQLRewriter()

Method Summary

Modifier and Type	Method and Description
void	analyzeInternal(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hive.conf.HiveConf hconf) Analyze internal.
void	buildDruidQuery(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hive.conf.HiveConf hconf) Builds the query.
boolean	isHavingSupported() Is Having supported.
boolean	isOrderBySupported() Is OrderBy supported.
String	rewrite(org.apache.hadoop.hive.ql.parse.ASTNode currNode, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hive.conf.HiveConf metastoreConf, boolean resolveNativeTables)
String	rewrite(String query, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hive.conf.HiveConf metastoreConf) Rewrite.

Methods inherited from class org.apache.lens.driver.jdbc.ColumnarSQLRewriter

buildDimSubqueries, buildQuery, buildSubqueries, constructJoinChain, factFilterPushDown, getAggregateColumns, getAllDimColumns, getAllFactKeys, getAllFilters, getClause, getColumnCount, getFactAlias, getFactKeysFromNode, getFactNameAlias, getFilterInJoinCond, getFromAST, getGroupByAST, getHavingAST, getJoinAST, getJoinCond, getLimitClause, getOrderByAST, getSelectAST, getTableFromTabRefNode, getTableOrAlias, getTablesAndColumns, getWhereAST, init, isExpressionsAnswerableFromFact, replaceAliasInAST, replaceUDFForDB, reset

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidSQLRewriter

public DruidSQLRewriter()

Method Detail

analyzeInternal

public void analyzeInternal(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.hive.conf.HiveConf hconf)
                     throws org.apache.hadoop.hive.ql.parse.SemanticException

Analyze internal.

Overrides:

analyzeInternal in class ColumnarSQLRewriter

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException - the semantic exception

buildDruidQuery

public void buildDruidQuery(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.hive.conf.HiveConf hconf)
                     throws org.apache.hadoop.hive.ql.parse.SemanticException,
                            LensException

Builds the query.

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

LensException

rewrite

public String rewrite(String query,
                      org.apache.hadoop.conf.Configuration conf,
                      org.apache.hadoop.hive.conf.HiveConf metastoreConf)
               throws LensException

Description copied from interface: QueryRewriter

Rewrite.

Specified by:

rewrite in interface QueryRewriter

Overrides:

rewrite in class ColumnarSQLRewriter

Parameters:

query - the query

conf - the query configuration

metastoreConf - The metastore configuration. If rewriters requires to access metastore, this configuration needs to passed

Returns:

the string

Throws:

LensException - the lens exception

rewrite

public String rewrite(org.apache.hadoop.hive.ql.parse.ASTNode currNode,
                      org.apache.hadoop.conf.Configuration conf,
                      org.apache.hadoop.hive.conf.HiveConf metastoreConf,
                      boolean resolveNativeTables)
               throws LensException

Throws:

LensException

isHavingSupported

@Generated(value="lombok")
public boolean isHavingSupported()

Is Having supported.

isOrderBySupported

@Generated(value="lombok")
public boolean isOrderBySupported()

Is OrderBy supported.