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
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()
String	getGroupByTree()
org.apache.hadoop.hive.ql.parse.ASTNode	getHavingAST()
String	getHavingTree()
org.apache.hadoop.hive.ql.parse.ASTNode	getJoinTree()
String	getName() Get name of the candidate table
int	getNumQueriedParts()
Set<FactPartition>	getPartsQueried() Get partitions queried
Map<TimeRange,Map<String,LinkedHashSet<FactPartition>>>	getRangeToStoragePartMap()
Map<TimeRange,Map<String,String>>	getRangeToStorageWhereMap()
Map<TimeRange,String>	getRangeToWhereClause()
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
Map<String,String>	getStorgeWhereClauseMap()
CubeFactTable	getTable() Get candidate table
Set<String>	getTimePartCols(CubeQueryContext query)
org.apache.hadoop.hive.ql.parse.ASTNode	getWhereAST()
String	getWhereClause(String storageTable)
String	getWhereTree()
int	hashCode()
boolean	isValidForTimeRange(TimeRange timeRange)
void	setHavingAST(org.apache.hadoop.hive.ql.parse.ASTNode havingAST)
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	updateTimeranges(CubeQueryContext cubeql)

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)

copyASTs

public void copyASTs(CubeQueryContext cubeql)
              throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

getWhereClause

public String getWhereClause(String storageTable)

updateTimeranges

public void updateTimeranges(CubeQueryContext cubeql)
                      throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

updateASTs

public void updateASTs(CubeQueryContext cubeql)
                throws org.apache.hadoop.hive.ql.parse.SemanticException

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

Parameters:

cubeql -

Throws:

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

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

getGroupbyTree

public String getGroupbyTree()

getSelectAST

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

Returns:

the selectAST

setSelectAST

public void setSelectAST(org.apache.hadoop.hive.ql.parse.ASTNode selectAST)

Parameters:

selectAST - the selectAST to set

getWhereAST

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

Returns:

the whereAST

setWhereAST

public void setWhereAST(org.apache.hadoop.hive.ql.parse.ASTNode whereAST)

Parameters:

whereAST - the whereAST to set

getHavingAST

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

Returns:

the havingAST

setHavingAST

public void setHavingAST(org.apache.hadoop.hive.ql.parse.ASTNode havingAST)

Parameters:

havingAST - the havingAST to set

getSelectIndices

public List<Integer> getSelectIndices()

Returns:

the selectIndices

getDimFieldIndices

public List<Integer> getDimFieldIndices()

Returns:

the groupbyIndices

getGroupByAST

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

getGroupByTree

public String getGroupByTree()

getTimePartCols

public Set<String> getTimePartCols(CubeQueryContext query)
                            throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

getJoinTree

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

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

getRangeToWhereClause

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

getStorgeWhereClauseMap

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

getRangeToStoragePartMap

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

getRangeToStorageWhereMap

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