org.apache.lens.cube.parse

Class CandidateFact

java.lang.Object

org.apache.lens.cube.parse.CandidateFact

All Implemented Interfaces:

CandidateTable

public class CandidateFact
extends Object
implements CandidateTable

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()
org.apache.hadoop.hive.ql.parse.ASTNode	getGroupByAST()
String	getGroupByTree()
org.apache.hadoop.hive.ql.parse.ASTNode	getHavingAST()
String	getHavingTree()
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	getOrderByTree()
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	getSelectTree()
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)
Map<String,org.apache.hadoop.hive.ql.parse.ASTNode>	getStorgeWhereClauseMap()
CubeFactTable	getTable() Get candidate table
Set<String>	getTimePartCols(CubeQueryContext query)
org.apache.hadoop.hive.ql.parse.ASTNode	getWhereAST()
String	getWhereTree()
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

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)

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

getSelectTree

public String getSelectTree()

getWhereTree

public String getWhereTree()

getHavingTree

public String getHavingTree()

getOrderByTree

public String getOrderByTree()

getSelectIndices

public List<Integer> getSelectIndices()

Returns:

the selectIndices

getDimFieldIndices

public List<Integer> getDimFieldIndices()

Returns:

the groupbyIndices

getGroupByTree

public String getGroupByTree()

getTimePartCols

public Set<String> getTimePartCols(CubeQueryContext query)
                            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()

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

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)

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

getJoinAST

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

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

setOrderByAST

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

getLimitValue

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

setLimitValue

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

getStorgeWhereClauseMap

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

getRangeToStoragePartMap

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

getRangeToStorageWhereMap

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