org.apache.lens.cube.parse

Class CubeQueryContext

java.lang.Object

org.apache.lens.cube.parse.CubeQueryContext

public class CubeQueryContext
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CubeQueryContext.OptionalDimCtx

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_TABLE
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(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)
Set<String>	getAggregateExprs()
String	getAlias(String expr)
String	getAliasForTableName(Named named)
String	getAliasForTableName(String tableName)
AutoJoinContext	getAutoJoinCtx()
Cube	getBaseCube()
Map<Dimension,Set<CandidateDim>>	getCandidateDims()
Map<Dimension,Set<CandidateDim>>	getCandidateDimTables()
Set<CandidateFact>	getCandidateFacts()
Set<Set<CandidateFact>>	getCandidateFactSets()
Map<String,String>	getColToTableAlias()
Set<String>	getColumnsQueried(String tblName)
org.apache.hadoop.conf.Configuration	getConf()
CubeInterface	getCube()
AbstractCubeTable	getCubeTableForAlias(String alias)
Map<String,AbstractCubeTable>	getCubeTbls()
DenormalizationResolver.DenormalizationContext	getDeNormCtx()
Set<Dimension>	getDimensions()
Map<Dimension,PruneCauses<CubeDimensionTable>>	getDimPruningMsgs()
Map<org.apache.lens.cube.parse.CubeQueryContext.QueriedExprColumn,Set<Aliased<Dimension>>>	getExprColToDim()
org.apache.lens.cube.parse.ExpressionResolver.ExpressionResolverContext	getExprCtx()
Map<String,String>	getExprToAlias()
Map<String,String>	getExprToAliasMap()
PruneCauses<CubeFactTable>	getFactPruningMsgs()
org.apache.hadoop.hive.ql.parse.ASTNode	getGroupByAST()
String	getGroupByTree()
org.apache.hadoop.hive.ql.parse.ASTNode	getHavingAST()
String	getHavingTree()
HQLContextInterface	getHqlContext()
String	getInsertClause()
org.apache.hadoop.hive.ql.parse.ASTNode	getJoinAST()
Map<String,JoinChain>	getJoinchains()
Map<org.apache.hadoop.hive.ql.parse.QBJoinTree,String>	getJoinConds()
Integer	getLimitValue()
CubeMetastoreClient	getMetastoreClient()
Set<Dimension>	getNonChainedDimensions()
String	getNonExistingParts()
Map<Aliased<Dimension>,CubeQueryContext.OptionalDimCtx>	getOptionalDimensionMap()
Set<Aliased<Dimension>>	getOptionalDimensions()
org.apache.hadoop.hive.ql.parse.ASTNode	getOrderByAST()
String	getOrderByTree()
static String	getPartitionColumnOfTimeDim(CubeInterface cube, String timeDimName)
String	getPartitionColumnOfTimeDim(String timeDimName)
Set<String>	getPartitionColumnsQueried()
Collection<CandidateDim>	getPickedDimTables()
Collection<CandidateFact>	getPickedFacts()
org.apache.hadoop.hive.ql.parse.QB	getQb()
org.apache.hadoop.hive.ql.parse.QBJoinTree	getQBJoinTree()
Set<String>	getQueriedDimAttrs()
Set<String>	getQueriedExprs()
Set<String>	getQueriedExprsWithMeasures()
Set<String>	getQueriedMsrs()
AbstractCubeTable	getQueriedTable(String alias)
com.google.common.collect.ImmutableSet<String>	getQueriedTimeDimCols()
Map<String,Set<Aliased<Dimension>>>	getRefColToDim()
String	getSelectAlias(int index)
List<String>	getSelectAliases()
org.apache.hadoop.hive.ql.parse.ASTNode	getSelectAST()
String	getSelectFinalAlias(int index)
List<String>	getSelectFinalAliases()
String	getSelectTree()
Map<String,Set<String>>	getTblAliasToColumns()
static String	getTimeDimOfPartitionColumn(CubeInterface cube, String partCol)
String	getTimeDimOfPartitionColumn(String partCol)
List<TimeRange>	getTimeRanges()
org.apache.hadoop.hive.ql.parse.ASTNode	getWhereAST()
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	setAutoJoinCtx(AutoJoinContext autoJoinCtx)
void	setDeNormCtx(DenormalizationResolver.DenormalizationContext deNormCtx)
void	setExprCtx(org.apache.lens.cube.parse.ExpressionResolver.ExpressionResolverContext exprCtx)
void	setGroupByAST(org.apache.hadoop.hive.ql.parse.ASTNode groupByAST)
void	setHavingAST(org.apache.hadoop.hive.ql.parse.ASTNode havingAST)
void	setJoinCond(org.apache.hadoop.hive.ql.parse.QBJoinTree qb, String cond)
void	setLimitValue(Integer value)
void	setOrderByAST(org.apache.hadoop.hive.ql.parse.ASTNode orderByAST)
void	setSelectAST(org.apache.hadoop.hive.ql.parse.ASTNode selectAST)
void	setWhereAST(org.apache.hadoop.hive.ql.parse.ASTNode whereAST)
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, Aliased<Dimension> dim)
void	updateRefColDim(String col, Aliased<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

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 LensException

Throws:

LensException

Method Detail

hasCubeInQuery

public boolean hasCubeInQuery()

hasDimensionInQuery

public boolean hasDimensionInQuery()

addQueriedTable

public boolean addQueriedTable(String alias)
                        throws LensException

Throws:

LensException

isAutoJoinResolved

public boolean isAutoJoinResolved()

getBaseCube

public Cube getBaseCube()

getPartitionColumnsQueried

public Set<String> getPartitionColumnsQueried()

updateRefColDim

public void updateRefColDim(String col,
                   Aliased<Dimension> dim)

updateExprColDim

public void updateExprColDim(String tblAlias,
                    String col,
                    Aliased<Dimension> dim)

addOptionalJoinDimTable

public void addOptionalJoinDimTable(String alias,
                           boolean isRequired)
                             throws LensException

Throws:

LensException

addOptionalExprDimTable

public void addOptionalExprDimTable(String dimAlias,
                           String queriedExpr,
                           String srcTableAlias,
                           CandidateTable candidate,
                           String... cols)
                             throws LensException

Throws:

LensException

addOptionalDimTable

public void addOptionalDimTable(String alias,
                       CandidateTable candidate,
                       boolean isRequiredInJoin,
                       String cubeCol,
                       boolean isRef,
                       String... cols)
                         throws LensException

Throws:

LensException

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()

getJoinAST

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

getQBJoinTree

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

getOrderByTree

public String getOrderByTree()

getLimitValue

public Integer getLimitValue()

setLimitValue

public void setLimitValue(Integer value)

getNonExistingParts

public String getNonExistingParts()

toHQL

public String toHQL()
             throws LensException

Throws:

LensException

toAST

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

Throws:

LensException

getColumnsQueried

public Set<String> getColumnsQueried(String tblName)

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<Aliased<Dimension>> getOptionalDimensions()

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()

getQb

@Generated(value="lombok")
public org.apache.hadoop.hive.ql.parse.QB getQb()

getConf

@Generated(value="lombok")
public org.apache.hadoop.conf.Configuration getConf()

getTimeRanges

@Generated(value="lombok")
public List<TimeRange> getTimeRanges()

getCube

@Generated(value="lombok")
public CubeInterface getCube()

getDimensions

@Generated(value="lombok")
public Set<Dimension> getDimensions()

getNonChainedDimensions

@Generated(value="lombok")
public Set<Dimension> getNonChainedDimensions()

getJoinchains

@Generated(value="lombok")
public Map<String,JoinChain> getJoinchains()

getQueriedMsrs

@Generated(value="lombok")
public Set<String> getQueriedMsrs()

getQueriedExprs

@Generated(value="lombok")
public Set<String> getQueriedExprs()

getQueriedExprsWithMeasures

@Generated(value="lombok")
public Set<String> getQueriedExprsWithMeasures()

getColToTableAlias

@Generated(value="lombok")
public Map<String,String> getColToTableAlias()

getCandidateFactSets

@Generated(value="lombok")
public Set<Set<CandidateFact>> getCandidateFactSets()

getOptionalDimensionMap

@Generated(value="lombok")
public Map<Aliased<Dimension>,CubeQueryContext.OptionalDimCtx> getOptionalDimensionMap()

getCubeTbls

@Generated(value="lombok")
public Map<String,AbstractCubeTable> getCubeTbls()

getTblAliasToColumns

@Generated(value="lombok")
public Map<String,Set<String>> getTblAliasToColumns()

getExprToAlias

@Generated(value="lombok")
public Map<String,String> getExprToAlias()

getSelectAliases

@Generated(value="lombok")
public List<String> getSelectAliases()

getSelectFinalAliases

@Generated(value="lombok")
public List<String> getSelectFinalAliases()

getAggregateExprs

@Generated(value="lombok")
public Set<String> getAggregateExprs()

getJoinConds

@Generated(value="lombok")
public Map<org.apache.hadoop.hive.ql.parse.QBJoinTree,String> getJoinConds()

getCandidateFacts

@Generated(value="lombok")
public Set<CandidateFact> getCandidateFacts()

getCandidateDims

@Generated(value="lombok")
public Map<Dimension,Set<CandidateDim>> getCandidateDims()

getHavingAST

@Generated(value="lombok")
public org.apache.hadoop.hive.ql.parse.ASTNode getHavingAST()

Returns:

the havingAST

setHavingAST

@Generated(value="lombok")
public void setHavingAST(org.apache.hadoop.hive.ql.parse.ASTNode havingAST)

Parameters:

havingAST - the havingAST to set

getSelectAST

@Generated(value="lombok")
public org.apache.hadoop.hive.ql.parse.ASTNode getSelectAST()

Returns:

the selectAST

setSelectAST

@Generated(value="lombok")
public void setSelectAST(org.apache.hadoop.hive.ql.parse.ASTNode selectAST)

Parameters:

selectAST - the selectAST to set

getWhereAST

@Generated(value="lombok")
public org.apache.hadoop.hive.ql.parse.ASTNode getWhereAST()

Returns:

the whereAST

setWhereAST

@Generated(value="lombok")
public void setWhereAST(org.apache.hadoop.hive.ql.parse.ASTNode whereAST)

Parameters:

whereAST - the whereAST to set

getOrderByAST

@Generated(value="lombok")
public org.apache.hadoop.hive.ql.parse.ASTNode getOrderByAST()

setOrderByAST

@Generated(value="lombok")
public void setOrderByAST(org.apache.hadoop.hive.ql.parse.ASTNode orderByAST)

getGroupByAST

@Generated(value="lombok")
public org.apache.hadoop.hive.ql.parse.ASTNode getGroupByAST()

setGroupByAST

@Generated(value="lombok")
public void setGroupByAST(org.apache.hadoop.hive.ql.parse.ASTNode groupByAST)

getMetastoreClient

@Generated(value="lombok")
public CubeMetastoreClient getMetastoreClient()

getAutoJoinCtx

@Generated(value="lombok")
public AutoJoinContext getAutoJoinCtx()

setAutoJoinCtx

@Generated(value="lombok")
public void setAutoJoinCtx(AutoJoinContext autoJoinCtx)

getExprCtx

@Generated(value="lombok")
public org.apache.lens.cube.parse.ExpressionResolver.ExpressionResolverContext getExprCtx()

setExprCtx

@Generated(value="lombok")
public void setExprCtx(org.apache.lens.cube.parse.ExpressionResolver.ExpressionResolverContext exprCtx)

getDeNormCtx

@Generated(value="lombok")
public DenormalizationResolver.DenormalizationContext getDeNormCtx()

setDeNormCtx

@Generated(value="lombok")
public void setDeNormCtx(DenormalizationResolver.DenormalizationContext deNormCtx)

getFactPruningMsgs

@Generated(value="lombok")
public PruneCauses<CubeFactTable> getFactPruningMsgs()

getDimPruningMsgs

@Generated(value="lombok")
public Map<Dimension,PruneCauses<CubeDimensionTable>> getDimPruningMsgs()

getRefColToDim

@Generated(value="lombok")
public Map<String,Set<Aliased<Dimension>>> getRefColToDim()

getExprColToDim

@Generated(value="lombok")
public Map<org.apache.lens.cube.parse.CubeQueryContext.QueriedExprColumn,Set<Aliased<Dimension>>> getExprColToDim()

getPickedFacts

@Generated(value="lombok")
public Collection<CandidateFact> getPickedFacts()

getPickedDimTables

@Generated(value="lombok")
public Collection<CandidateDim> getPickedDimTables()