org.apache.lens.cube.parse.join

Class AutoJoinContext

java.lang.Object

org.apache.lens.cube.parse.join.AutoJoinContext

public class AutoJoinContext
extends Object

Store join chain information resolved by join resolver

Constructor Summary

Constructors

Constructor and Description
AutoJoinContext(Map<Aliased<Dimension>,List<JoinPath>> allPaths, Set<Dimension> requiredDimensions, Map<AbstractCubeTable,org.apache.hadoop.hive.ql.parse.JoinType> tableJoinTypeMap, AbstractCubeTable autoJoinTarget, String joinTypeCfg, boolean joinsResolved, boolean flattenBridgeTables, String bridgeTableFieldAggr)

Method Summary

Methods

Modifier and Type	Method and Description
Set<String>	getAllJoinPathColumnsOfTable(AbstractCubeTable table)
Map<Aliased<Dimension>,List<JoinPath>>	getAllPaths()
AbstractCubeTable	getAutoJoinTarget()
Set<Dimension>	getDimsOnPath(Map<Aliased<Dimension>,List<TableRelationship>> joinChain, Set<Dimension> qdims)
Map<CandidateFact,JoinClause>	getFactClauses()
String	getFromString(String fromTable, CandidateFact fact, Set<Dimension> qdims, Map<Dimension,CandidateDim> dimsToQuery, CubeQueryContext cubeql)
Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>>	getJoinPathFromColumns()
Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>>	getJoinPathToColumns()
String	getMergedJoinClause(CubeQueryContext cubeql, JoinClause joinClause, Map<Dimension,CandidateDim> dimsToQuery)
JoinClause	getMinCostClause()
Map<AbstractCubeTable,org.apache.hadoop.hive.ql.parse.JoinType>	getTableJoinTypeMap()
boolean	isJoinsResolved()
boolean	isReachableDim(Dimension dim)
boolean	isReachableDim(Dimension dim, String alias)
Set<Dimension>	pickOptionalTables(CandidateFact fact, Set<Dimension> qdims, CubeQueryContext cubeql)
void	pruneAllPaths(CubeInterface cube, Set<CandidateFact> cfacts, Map<Dimension,CandidateDim> dimsToQuery)
void	pruneAllPathsForCandidateDims(Map<Dimension,Set<CandidateDim>> candidateDims) Prunes allPaths by removing paths which contain columns that are not present in any candidate dims.
void	refreshJoinPathColumns()
void	removeJoinedTable(Aliased<Dimension> dim)
void	setMinCostClause(JoinClause minCostClause)

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoJoinContext

public AutoJoinContext(Map<Aliased<Dimension>,List<JoinPath>> allPaths,
               Set<Dimension> requiredDimensions,
               Map<AbstractCubeTable,org.apache.hadoop.hive.ql.parse.JoinType> tableJoinTypeMap,
               AbstractCubeTable autoJoinTarget,
               String joinTypeCfg,
               boolean joinsResolved,
               boolean flattenBridgeTables,
               String bridgeTableFieldAggr)

Method Detail

getAutoJoinTarget

public AbstractCubeTable getAutoJoinTarget()

refreshJoinPathColumns

public void refreshJoinPathColumns()

removeJoinedTable

public void removeJoinedTable(Aliased<Dimension> dim)

getFromString

public String getFromString(String fromTable,
                   CandidateFact fact,
                   Set<Dimension> qdims,
                   Map<Dimension,CandidateDim> dimsToQuery,
                   CubeQueryContext cubeql)
                     throws LensException

Throws:

LensException

getMergedJoinClause

public String getMergedJoinClause(CubeQueryContext cubeql,
                         JoinClause joinClause,
                         Map<Dimension,CandidateDim> dimsToQuery)

getDimsOnPath

public Set<Dimension> getDimsOnPath(Map<Aliased<Dimension>,List<TableRelationship>> joinChain,
                           Set<Dimension> qdims)

isJoinsResolved

public boolean isJoinsResolved()

Returns:

the joinsResolved

getAllJoinPathColumnsOfTable

public Set<String> getAllJoinPathColumnsOfTable(AbstractCubeTable table)

pruneAllPaths

public void pruneAllPaths(CubeInterface cube,
                 Set<CandidateFact> cfacts,
                 Map<Dimension,CandidateDim> dimsToQuery)
                   throws LensException

Throws:

LensException

pruneAllPathsForCandidateDims

public void pruneAllPathsForCandidateDims(Map<Dimension,Set<CandidateDim>> candidateDims)
                                   throws LensException

Prunes allPaths by removing paths which contain columns that are not present in any candidate dims.

Parameters:

candidateDims - candidate dimensions

Throws:

LensException

pickOptionalTables

public Set<Dimension> pickOptionalTables(CandidateFact fact,
                                Set<Dimension> qdims,
                                CubeQueryContext cubeql)
                                  throws LensException

Throws:

LensException

getAllPaths

public Map<Aliased<Dimension>,List<JoinPath>> getAllPaths()

isReachableDim

public boolean isReachableDim(Dimension dim)

isReachableDim

public boolean isReachableDim(Dimension dim,
                     String alias)

getTableJoinTypeMap

@Generated(value="lombok")
public Map<AbstractCubeTable,org.apache.hadoop.hive.ql.parse.JoinType> getTableJoinTypeMap()

getJoinPathFromColumns

@Generated(value="lombok")
public Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>> getJoinPathFromColumns()

getJoinPathToColumns

@Generated(value="lombok")
public Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>> getJoinPathToColumns()

getFactClauses

@Generated(value="lombok")
public Map<CandidateFact,JoinClause> getFactClauses()

getMinCostClause

@Generated(value="lombok")
public JoinClause getMinCostClause()

setMinCostClause

@Generated(value="lombok")
public void setMinCostClause(JoinClause minCostClause)