org.apache.lens.cube.parse

Class CubeQueryContext

java.lang.Object

org.apache.lens.cube.parse.CubeQueryContext

public class CubeQueryContext
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_TABLE
static org.apache.commons.logging.Log	LOG
static String	NOW
static String	TIME_RANGE_FUNC

Constructor Summary

Constructors

Constructor and Description
CubeQueryContext(org.apache.hadoop.hive.ql.parse.ASTNode ast, org.apache.hadoop.hive.ql.parse.QB qb, org.apache.hadoop.conf.Configuration queryConf, org.apache.hadoop.hive.conf.HiveConf metastoreConf)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAggregateExpr(String expr)
void	addColumnsQueried(AbstractCubeTable table, String column)
void	addColumnsQueried(String alias, String column)
void	addColumnsQueriedWithTimeDimCheck(String alias, String timeDimColumn)
void	addDimPruningMsgs(Dimension dim, CubeDimensionTable dimtable, CandidateTablePruneCause msg)
void	addExprToAlias(org.apache.hadoop.hive.ql.parse.ASTNode expr, org.apache.hadoop.hive.ql.parse.ASTNode alias)
void	addFactPruningMsgs(CubeFactTable fact, CandidateTablePruneCause factPruningMsg)
void	addOptionalDimTable(String alias, CandidateTable candidate, boolean isRequiredInJoin, String cubeCol, boolean isRef, String... cols)
void	addOptionalExprDimTable(String dimAlias, String queriedExpr, String srcTableAlias, CandidateTable candidate, String... cols)
void	addOptionalJoinDimTable(String alias, boolean isRequired)
void	addQueriedDimAttrs(Set<String> dimAttrs)
void	addQueriedExprs(Set<String> exprs)
void	addQueriedExprsWithMeasures(Set<String> exprs)
void	addQueriedMsrs(Set<String> msrs)
boolean	addQueriedTable(String alias)
void	addQueriedTimeDimensionCols(String timeDimColName)
void	addSelectAlias(String alias, String spacedAlias)
String	getAlias(String expr)
String	getAliasForTableName(Named named)
String	getAliasForTableName(String tableName)
Cube	getBaseCube()
Map<Dimension,Set<CandidateDim>>	getCandidateDimTables()
Set<String>	getColumnsQueried(String tblName)
AbstractCubeTable	getCubeTableForAlias(String alias)
Map<String,String>	getExprToAliasMap()
String	getGroupByTree()
String	getHavingTree()
HQLContextInterface	getHqlContext()
String	getInsertClause()
org.apache.hadoop.hive.ql.parse.ASTNode	getJoinTree()
Integer	getLimitValue()
String	getNonExistingParts()
Map<Dimension,org.apache.lens.cube.parse.CubeQueryContext.OptionalDimCtx>	getOptionalDimensionMap()
Set<Dimension>	getOptionalDimensions()
String	getOrderByTree()
static String	getPartitionColumnOfTimeDim(CubeInterface cube, String timeDimName)
String	getPartitionColumnOfTimeDim(String timeDimName)
Set<String>	getPartitionColumnsQueried()
org.apache.hadoop.hive.ql.parse.QBJoinTree	getQBJoinTree()
Set<String>	getQueriedDimAttrs()
AbstractCubeTable	getQueriedTable(String alias)
com.google.common.collect.ImmutableSet<String>	getQueriedTimeDimCols()
String	getSelectAlias(int index)
String	getSelectFinalAlias(int index)
String	getSelectTree()
Map<String,Set<String>>	getTblAliasToColumns()
static String	getTimeDimOfPartitionColumn(CubeInterface cube, String partCol)
String	getTimeDimOfPartitionColumn(String partCol)
String	getWhereTree()
boolean	hasAggregates()
boolean	hasCubeInQuery()
boolean	hasDimensionInQuery()
boolean	isAggregateExpr(String expr)
boolean	isAutoJoinResolved()
boolean	isCubeMeasure(String col)
void	print()
void	pruneCandidateFactSet(CandidateTablePruneCause.CandidateTablePruneCode pruneCause) Prune candidate fact sets with respect to available candidate facts.
void	pruneCandidateFactWithCandidateSet(CandidateTablePruneCause.CandidateTablePruneCode pruneCause) Prune candidate fact with respect to available candidate fact sets.
void	pruneCandidateFactWithCandidateSet(CandidateTablePruneCause pruneCause)
void	setJoinCond(org.apache.hadoop.hive.ql.parse.QBJoinTree qb, String cond)
boolean	shouldReplaceTimeDimWithPart()
org.apache.hadoop.hive.ql.parse.ASTNode	toAST(org.apache.hadoop.hive.ql.Context ctx)
String	toHQL()
void	updateExprColDim(String tblAlias, String col, Dimension dim)
void	updateRefColDim(String col, Dimension dim)

Methods inherited from class java.lang.Object

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

Field Detail

TIME_RANGE_FUNC

public static final String TIME_RANGE_FUNC

See Also:

Constant Field Values

NOW

public static final String NOW

See Also:

Constant Field Values

DEFAULT_TABLE

public static final String DEFAULT_TABLE

See Also:

Constant Field Values

LOG

public static final org.apache.commons.logging.Log LOG

Constructor Detail

CubeQueryContext

public CubeQueryContext(org.apache.hadoop.hive.ql.parse.ASTNode ast,
                org.apache.hadoop.hive.ql.parse.QB qb,
                org.apache.hadoop.conf.Configuration queryConf,
                org.apache.hadoop.hive.conf.HiveConf metastoreConf)
                 throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

Method Detail

hasCubeInQuery

public boolean hasCubeInQuery()

hasDimensionInQuery

public boolean hasDimensionInQuery()

addQueriedTable

public boolean addQueriedTable(String alias)
                        throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

isAutoJoinResolved

public boolean isAutoJoinResolved()

getBaseCube

public Cube getBaseCube()

getPartitionColumnsQueried

public Set<String> getPartitionColumnsQueried()

updateRefColDim

public void updateRefColDim(String col,
                   Dimension dim)

updateExprColDim

public void updateExprColDim(String tblAlias,
                    String col,
                    Dimension dim)

addOptionalJoinDimTable

public void addOptionalJoinDimTable(String alias,
                           boolean isRequired)
                             throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

addOptionalExprDimTable

public void addOptionalExprDimTable(String dimAlias,
                           String queriedExpr,
                           String srcTableAlias,
                           CandidateTable candidate,
                           String... cols)
                             throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

addOptionalDimTable

public void addOptionalDimTable(String alias,
                       CandidateTable candidate,
                       boolean isRequiredInJoin,
                       String cubeCol,
                       boolean isRef,
                       String... cols)
                         throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

getCubeTableForAlias

public AbstractCubeTable getCubeTableForAlias(String alias)

getCandidateDimTables

public Map<Dimension,Set<CandidateDim>> getCandidateDimTables()

addFactPruningMsgs

public void addFactPruningMsgs(CubeFactTable fact,
                      CandidateTablePruneCause factPruningMsg)

addDimPruningMsgs

public void addDimPruningMsgs(Dimension dim,
                     CubeDimensionTable dimtable,
                     CandidateTablePruneCause msg)

getAliasForTableName

public String getAliasForTableName(Named named)

getAliasForTableName

public String getAliasForTableName(String tableName)

print

public void print()

getSelectTree

public String getSelectTree()

getWhereTree

public String getWhereTree()

getGroupByTree

public String getGroupByTree()

getHavingTree

public String getHavingTree()

getJoinTree

public org.apache.hadoop.hive.ql.parse.ASTNode getJoinTree()

getQBJoinTree

public org.apache.hadoop.hive.ql.parse.QBJoinTree getQBJoinTree()

getOrderByTree

public String getOrderByTree()

getLimitValue

public Integer getLimitValue()

getNonExistingParts

public String getNonExistingParts()

toHQL

public String toHQL()
             throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

toAST

public org.apache.hadoop.hive.ql.parse.ASTNode toAST(org.apache.hadoop.hive.ql.Context ctx)
                                              throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

getColumnsQueried

public Set<String> getColumnsQueried(String tblName)

addColumnsQueried

public void addColumnsQueried(AbstractCubeTable table,
                     String column)

addColumnsQueriedWithTimeDimCheck

public void addColumnsQueriedWithTimeDimCheck(String alias,
                                     String timeDimColumn)

addColumnsQueried

public void addColumnsQueried(String alias,
                     String column)

isCubeMeasure

public boolean isCubeMeasure(String col)

isAggregateExpr

public boolean isAggregateExpr(String expr)

hasAggregates

public boolean hasAggregates()

getAlias

public String getAlias(String expr)

getSelectAlias

public String getSelectAlias(int index)

getSelectFinalAlias

public String getSelectFinalAlias(int index)

getExprToAliasMap

public Map<String,String> getExprToAliasMap()

addAggregateExpr

public void addAggregateExpr(String expr)

setJoinCond

public void setJoinCond(org.apache.hadoop.hive.ql.parse.QBJoinTree qb,
               String cond)

getQueriedTable

public AbstractCubeTable getQueriedTable(String alias)

getInsertClause

public String getInsertClause()

addExprToAlias

public void addExprToAlias(org.apache.hadoop.hive.ql.parse.ASTNode expr,
                  org.apache.hadoop.hive.ql.parse.ASTNode alias)

addSelectAlias

public void addSelectAlias(String alias,
                  String spacedAlias)

getOptionalDimensions

public Set<Dimension> getOptionalDimensions()

getOptionalDimensionMap

public Map<Dimension,org.apache.lens.cube.parse.CubeQueryContext.OptionalDimCtx> getOptionalDimensionMap()

getHqlContext

public HQLContextInterface getHqlContext()

Returns:

the hqlContext

shouldReplaceTimeDimWithPart

public boolean shouldReplaceTimeDimWithPart()

getPartitionColumnOfTimeDim

public String getPartitionColumnOfTimeDim(String timeDimName)

getPartitionColumnOfTimeDim

public static String getPartitionColumnOfTimeDim(CubeInterface cube,
                                 String timeDimName)

getTimeDimOfPartitionColumn

public String getTimeDimOfPartitionColumn(String partCol)

getTimeDimOfPartitionColumn

public static String getTimeDimOfPartitionColumn(CubeInterface cube,
                                 String partCol)

getQueriedDimAttrs

public Set<String> getQueriedDimAttrs()

Returns:

the queriedDimAttrs

addQueriedDimAttrs

public void addQueriedDimAttrs(Set<String> dimAttrs)

addQueriedMsrs

public void addQueriedMsrs(Set<String> msrs)

addQueriedExprs

public void addQueriedExprs(Set<String> exprs)

addQueriedExprsWithMeasures

public void addQueriedExprsWithMeasures(Set<String> exprs)

pruneCandidateFactSet

public void pruneCandidateFactSet(CandidateTablePruneCause.CandidateTablePruneCode pruneCause)

Prune candidate fact sets with respect to available candidate facts.

Prune a candidate set, if any of the fact is missing.

Parameters:

pruneCause -

pruneCandidateFactWithCandidateSet

public void pruneCandidateFactWithCandidateSet(CandidateTablePruneCause.CandidateTablePruneCode pruneCause)

Prune candidate fact with respect to available candidate fact sets.

If candidate fact is not present in any of the candidate fact sets, remove it.

Parameters:

pruneCause -

pruneCandidateFactWithCandidateSet

public void pruneCandidateFactWithCandidateSet(CandidateTablePruneCause pruneCause)

addQueriedTimeDimensionCols

public void addQueriedTimeDimensionCols(String timeDimColName)

getQueriedTimeDimCols

public com.google.common.collect.ImmutableSet<String> getQueriedTimeDimCols()

getTblAliasToColumns

public Map<String,Set<String>> getTblAliasToColumns()