org.apache.lens.cube.parse

Class CubeQueryContext

java.lang.Object

org.apache.lens.cube.parse.CubeQueryContext

All Implemented Interfaces:

QueryAST

public class CubeQueryContext
extends Object
implements QueryAST

Field Summary

Fields

Modifier and Type	Field and Description
static String	NOW

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

Modifier and Type	Method and Description
void	addColumnsQueried(Map<String,Set<String>> tblAliasToColumns) Add given map of tblAliasToColumns.
void	addColumnsQueried(String tblAlias, String column) Add given table alias and column
void	addDimPruningMsgs(Dimension dim, CubeDimensionTable dimtable, CandidateTablePruneCause msg)
String	getAliasForTableName(Named named)
String	getAliasForTableName(String tableName)
org.apache.hadoop.hive.ql.parse.ASTNode	getAst()
AutoJoinContext	getAutoJoinCtx()
Map<Dimension,Set<CandidateDim>>	getCandidateDims()
Map<Dimension,Set<CandidateDim>>	getCandidateDimTables()
Set<Candidate>	getCandidates() This is the set of working Candidates that gets updated during different phases of query resolution.
Map<String,String>	getColToTableAlias()
Set<String>	getColumnsQueried(String tblAlias) Get columns queried by tblAlias
org.apache.hadoop.conf.Configuration	getConf()
CubeInterface	getCube()
AbstractCubeTable	getCubeTableForAlias(String alias)
Map<String,AbstractCubeTable>	getCubeTbls()
org.apache.lens.cube.parse.DenormalizationResolver.DenormalizationContext	getDeNormCtx() Get denormalization context
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()
String	getFromString()
org.apache.hadoop.hive.ql.parse.ASTNode	getGroupByAST()
String	getGroupByString()
org.apache.hadoop.hive.ql.parse.ASTNode	getHavingAST()
String	getHavingString()
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()
Map<Aliased<Dimension>,org.apache.lens.cube.parse.CubeQueryContext.OptionalDimCtx>	getOptionalDimensionMap()
org.apache.hadoop.hive.ql.parse.ASTNode	getOrderByAST()
String	getOrderByString()
Candidate	getPickedCandidate()
Collection<CandidateDim>	getPickedDimTables()
org.apache.hadoop.hive.ql.parse.QB	getQb()
Set<String>	getQueriedExprs()
Set<String>	getQueriedExprsWithMeasures()
Set<String>	getQueriedMsrs()
List<org.apache.lens.cube.parse.QueriedPhraseContext>	getQueriedPhrases()
AbstractCubeTable	getQueriedTable(String alias)
QueryWriterContext	getQueryWriterContext()
QueryWriterContext	getQueryWriterContext(Candidate cand, Map<Dimension,CandidateDim> dimsToQuery)
TimeRangeWriter	getRangeWriter()
Map<String,Set<Aliased<Dimension>>>	getRefColToDim()
org.apache.hadoop.hive.ql.parse.ASTNode	getSelectAST()
List<org.apache.lens.cube.parse.SelectPhraseContext>	getSelectPhrases()
String	getSelectString()
PruneCauses<Candidate>	getStoragePruningMsgs()
Map<String,Set<String>>	getTblAliasToColumns() Get tblAlias to column
List<TimeRange>	getTimeRanges()
org.apache.hadoop.hive.ql.parse.ASTNode	getWhereAST()
String	getWhereString()
void	print()
void	setAutoJoinCtx(AutoJoinContext autoJoinCtx)
void	setDeNormCtx(org.apache.lens.cube.parse.DenormalizationResolver.DenormalizationContext deNormCtx) Set denormalization context
void	setExprCtx(org.apache.lens.cube.parse.ExpressionResolver.ExpressionResolverContext exprCtx)
void	setFromString(String fromString)
void	setGroupByAST(org.apache.hadoop.hive.ql.parse.ASTNode groupByAST)
void	setHavingAST(org.apache.hadoop.hive.ql.parse.ASTNode havingAST)
void	setJoinAST(org.apache.hadoop.hive.ql.parse.ASTNode node)
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)
void	setWhereString(String whereString)
boolean	shouldReplaceTimeDimWithPart()
org.apache.hadoop.hive.ql.parse.ASTNode	toAST(org.apache.hadoop.hive.ql.Context ctx)
String	toHQL()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.lens.cube.parse.QueryAST

copyFrom

Field Detail

NOW

public static final String NOW

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

getCubeTableForAlias

public AbstractCubeTable getCubeTableForAlias(String alias)

getCandidateDimTables

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

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

getSelectString

public String getSelectString()

Specified by:

getSelectString in interface QueryAST

setWhereString

public void setWhereString(String whereString)

Specified by:

setWhereString in interface QueryAST

getWhereString

public String getWhereString()

Specified by:

getWhereString in interface QueryAST

getGroupByString

public String getGroupByString()

Specified by:

getGroupByString in interface QueryAST

getHavingString

public String getHavingString()

Specified by:

getHavingString in interface QueryAST

getJoinAST

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

Specified by:

getJoinAST in interface QueryAST

setJoinAST

public void setJoinAST(org.apache.hadoop.hive.ql.parse.ASTNode node)

Specified by:

setJoinAST in interface QueryAST

getOrderByString

public String getOrderByString()

Specified by:

getOrderByString in interface QueryAST

getLimitValue

public Integer getLimitValue()

Specified by:

getLimitValue in interface QueryAST

setLimitValue

public void setLimitValue(Integer value)

Specified by:

setLimitValue in interface QueryAST

getQueryWriterContext

public QueryWriterContext getQueryWriterContext(Candidate cand,
                                                Map<Dimension,CandidateDim> dimsToQuery)
                                         throws LensException

Throws:

LensException

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

getQueriedTable

public AbstractCubeTable getQueriedTable(String alias)

shouldReplaceTimeDimWithPart

public boolean shouldReplaceTimeDimWithPart()

getAst

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

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

getCandidates

@Generated(value="lombok")
public Set<Candidate> getCandidates()

This is the set of working Candidates that gets updated during different phases of query resolution. Each ContextRewriter may add/remove/update Candiadtes in this working set and from the final set of Candidates single pickedCandidate is chosen.

getOptionalDimensionMap

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

getCubeTbls

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

getSelectPhrases

@Generated(value="lombok")
public List<org.apache.lens.cube.parse.SelectPhraseContext> getSelectPhrases()

getQueriedPhrases

@Generated(value="lombok")
public List<org.apache.lens.cube.parse.QueriedPhraseContext> getQueriedPhrases()

getJoinConds

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

getCandidateDims

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

getHavingAST

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

Specified by:

getHavingAST in interface QueryAST

Returns:

the havingAST

setHavingAST

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

Specified by:

setHavingAST in interface QueryAST

Parameters:

havingAST - the havingAST to set

getSelectAST

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

Specified by:

getSelectAST in interface QueryAST

Returns:

the selectAST

setSelectAST

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

Specified by:

setSelectAST in interface QueryAST

Parameters:

selectAST - the selectAST to set

getWhereAST

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

Specified by:

getWhereAST in interface QueryAST

Returns:

the whereAST

setWhereAST

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

Specified by:

setWhereAST in interface QueryAST

Parameters:

whereAST - the whereAST to set

getOrderByAST

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

Specified by:

getOrderByAST in interface QueryAST

setOrderByAST

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

Specified by:

setOrderByAST in interface QueryAST

getGroupByAST

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

Specified by:

getGroupByAST in interface QueryAST

setGroupByAST

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

Specified by:

setGroupByAST in interface QueryAST

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 org.apache.lens.cube.parse.DenormalizationResolver.DenormalizationContext getDeNormCtx()

Get denormalization context

Returns:

DenormalizationContext

setDeNormCtx

@Generated(value="lombok")
public void setDeNormCtx(org.apache.lens.cube.parse.DenormalizationResolver.DenormalizationContext deNormCtx)

Set denormalization context

Parameters:

deNormCtx - DenormalizationContext

getStoragePruningMsgs

@Generated(value="lombok")
public PruneCauses<Candidate> getStoragePruningMsgs()

getDimPruningMsgs

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

setFromString

@Generated(value="lombok")
public void setFromString(String fromString)

Specified by:

setFromString in interface QueryAST

getFromString

@Generated(value="lombok")
public String getFromString()

Specified by:

getFromString in interface QueryAST

getRangeWriter

@Generated(value="lombok")
public TimeRangeWriter getRangeWriter()

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

getQueryWriterContext

@Generated(value="lombok")
public QueryWriterContext getQueryWriterContext()

getPickedCandidate

@Generated(value="lombok")
public Candidate getPickedCandidate()

getPickedDimTables

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

addColumnsQueried

public void addColumnsQueried(String tblAlias,
                              String column)

Add given table alias and column

Parameters:

tblAlias - Table alias

column - column

addColumnsQueried

public void addColumnsQueried(Map<String,Set<String>> tblAliasToColumns)

Add given map of tblAliasToColumns.

Parameters:

tblAliasToColumns - map of tblAliasToColumns

getColumnsQueried

public Set<String> getColumnsQueried(String tblAlias)

Get columns queried by tblAlias

Parameters:

tblAlias - tbl alias name

Returns:

set of column names

getTblAliasToColumns

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

Get tblAlias to column

Returns:

map of tblAliasToColumns