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, String bridgeTableFieldArrayFilter, boolean doFlatteningEarly)

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, QueryAST ast)
JoinClause	getJoinClause(CandidateFact fact)
Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>>	getJoinPathFromColumns()
Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>>	getJoinPathToColumns()
String	getMergedJoinClause(CubeQueryContext cubeql, CandidateFact fact, QueryAST ast, 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,
               String bridgeTableFieldArrayFilter,
               boolean doFlatteningEarly)

Method Detail

getAutoJoinTarget

public AbstractCubeTable getAutoJoinTarget()

getJoinClause

public JoinClause getJoinClause(CandidateFact fact)

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,
                   QueryAST ast)
                     throws LensException

Throws:

LensException

getMergedJoinClause

public String getMergedJoinClause(CubeQueryContext cubeql,
                         CandidateFact fact,
                         QueryAST ast,
                         JoinClause joinClause,
                         Map<Dimension,CandidateDim> dimsToQuery)
                           throws LensException

Throws:

LensException

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)