org.apache.lens.cube.parse

Class CandidateFact

java.lang.Object

org.apache.lens.cube.parse.CandidateFact

All Implemented Interfaces:

CandidateTable, QueryAST

public class CandidateFact
extends Object
implements CandidateTable, QueryAST

Holds context of a candidate fact table.

Method Summary

Methods

Modifier and Type	Method and Description
String	addAndGetAliasFromSelect(org.apache.hadoop.hive.ql.parse.ASTNode ast, AliasDecider aliasDecider)
void	addToHaving(org.apache.hadoop.hive.ql.parse.ASTNode ast)
void	copyASTs(CubeQueryContext cubeql)
boolean	equals(Object obj)
AbstractCubeTable	getBaseTable() Get base table of the candidate table
Collection<String>	getColumns() Get columns of candidate table
List<Integer>	getDimFieldIndices()
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()
Integer	getLimitValue()
String	getName() Get name of the candidate table
int	getNumQueriedParts()
org.apache.hadoop.hive.ql.parse.ASTNode	getOrderByAST()
String	getOrderByString()
Set<FactPartition>	getPartsQueried() Get partitions queried
Map<TimeRange,Map<String,LinkedHashSet<FactPartition>>>	getRangeToStoragePartMap()
Map<TimeRange,Map<String,String>>	getRangeToStorageWhereMap()
org.apache.hadoop.hive.ql.parse.ASTNode	getSelectAST()
List<Integer>	getSelectIndices()
String	getSelectString()
String	getStorageString(String alias) Get storage string of the base table alias passed
Set<String>	getStorageTables() Get storage tables corresponding to this candidate
org.apache.hadoop.hive.ql.parse.ASTNode	getStorageWhereClause(String storageTable)
String	getStorageWhereString(String storageTable)
Map<String,org.apache.hadoop.hive.ql.parse.ASTNode>	getStorgeWhereClauseMap()
Map<String,String>	getStorgeWhereStringMap()
CubeFactTable	getTable() Get candidate table
Set<String>	getTimePartCols(CubeQueryContext query)
org.apache.hadoop.hive.ql.parse.ASTNode	getWhereAST()
String	getWhereString()
int	hashCode()
boolean	isExpressionAnswerable(org.apache.hadoop.hive.ql.parse.ASTNode node, CubeQueryContext context)
boolean	isValidForTimeRange(TimeRange timeRange)
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 joinAST)
void	setLimitValue(Integer limitValue)
void	setOrderByAST(org.apache.hadoop.hive.ql.parse.ASTNode orderByAST)
void	setSelectAST(org.apache.hadoop.hive.ql.parse.ASTNode selectAST)
void	setStorageTables(Set<String> storageTables)
void	setWhereAST(org.apache.hadoop.hive.ql.parse.ASTNode whereAST)
String	toString()
void	updateASTs(CubeQueryContext cubeql) Update the ASTs to include only the fields queried from this fact, in all the expressions
void	updateFromString(CubeQueryContext query, Set<Dimension> queryDims, Map<Dimension,CandidateDim> dimsToQuery)

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getColumns

public Collection<String> getColumns()

Description copied from interface: CandidateTable

Get columns of candidate table

Specified by:

getColumns in interface CandidateTable

Returns:

set or list of columns

isValidForTimeRange

public boolean isValidForTimeRange(TimeRange timeRange)

addToHaving

public void addToHaving(org.apache.hadoop.hive.ql.parse.ASTNode ast)

addAndGetAliasFromSelect

public String addAndGetAliasFromSelect(org.apache.hadoop.hive.ql.parse.ASTNode ast,
                              AliasDecider aliasDecider)

copyASTs

public void copyASTs(CubeQueryContext cubeql)
              throws LensException

Throws:

LensException

getStorageWhereClause

public org.apache.hadoop.hive.ql.parse.ASTNode getStorageWhereClause(String storageTable)

getStorageWhereString

public String getStorageWhereString(String storageTable)

isExpressionAnswerable

public boolean isExpressionAnswerable(org.apache.hadoop.hive.ql.parse.ASTNode node,
                             CubeQueryContext context)
                               throws LensException

Throws:

LensException

updateASTs

public void updateASTs(CubeQueryContext cubeql)
                throws LensException

Update the ASTs to include only the fields queried from this fact, in all the expressions

Parameters:

cubeql -

Throws:

LensException

getStorageString

public String getStorageString(String alias)

Description copied from interface: CandidateTable

Get storage string of the base table alias passed

Specified by:

getStorageString in interface CandidateTable

Returns:

storage string

setStorageTables

public void setStorageTables(Set<String> storageTables)

getBaseTable

public AbstractCubeTable getBaseTable()

Description copied from interface: CandidateTable

Get base table of the candidate table

Specified by:

getBaseTable in interface CandidateTable

Returns:

Cube or DerivedCube or Dimesions

getTable

public CubeFactTable getTable()

Description copied from interface: CandidateTable

Get candidate table

Specified by:

getTable in interface CandidateTable

Returns:

Candidate fact or dim table

getName

public String getName()

Description copied from interface: CandidateTable

Get name of the candidate table

Specified by:

getName in interface CandidateTable

Returns:

name

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getSelectString

public String getSelectString()

Specified by:

getSelectString in interface QueryAST

getWhereString

public String getWhereString()

Specified by:

getWhereString in interface QueryAST

getHavingString

public String getHavingString()

Specified by:

getHavingString in interface QueryAST

getOrderByString

public String getOrderByString()

Specified by:

getOrderByString in interface QueryAST

getSelectIndices

public List<Integer> getSelectIndices()

Returns:

the selectIndices

getDimFieldIndices

public List<Integer> getDimFieldIndices()

Returns:

the groupbyIndices

getGroupByString

public String getGroupByString()

Specified by:

getGroupByString in interface QueryAST

getTimePartCols

public Set<String> getTimePartCols(CubeQueryContext query)
                            throws LensException

Throws:

LensException

updateFromString

public void updateFromString(CubeQueryContext query,
                    Set<Dimension> queryDims,
                    Map<Dimension,CandidateDim> dimsToQuery)
                      throws LensException

Throws:

LensException

getStorageTables

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

Description copied from interface: CandidateTable

Get storage tables corresponding to this candidate

Specified by:

getStorageTables in interface CandidateTable

Returns:

getNumQueriedParts

@Generated(value="lombok")
public int getNumQueriedParts()

getPartsQueried

@Generated(value="lombok")
public Set<FactPartition> getPartsQueried()

Description copied from interface: CandidateTable

Get partitions queried

Specified by:

getPartsQueried in interface CandidateTable

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

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

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

getJoinAST

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

Specified by:

getJoinAST in interface QueryAST

setJoinAST

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

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

getLimitValue

@Generated(value="lombok")
public Integer getLimitValue()

Specified by:

getLimitValue in interface QueryAST

setLimitValue

@Generated(value="lombok")
public void setLimitValue(Integer limitValue)

Specified by:

setLimitValue in interface QueryAST

getFromString

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

Specified by:

getFromString in interface QueryAST

getStorgeWhereClauseMap

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

getStorgeWhereStringMap

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

getRangeToStoragePartMap

@Generated(value="lombok")
public Map<TimeRange,Map<String,LinkedHashSet<FactPartition>>> getRangeToStoragePartMap()

getRangeToStorageWhereMap

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