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

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<StorageCandidate,JoinClause>	getFactClauses()
String	getFromString(String fromTable, DimHQLContext sc, Map<Dimension,CandidateDim> dimsToQuery, CubeQueryContext cubeql)
JoinClause	getJoinClause(StorageCandidate sc)
Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>>	getJoinPathFromColumns()
Map<Aliased<Dimension>,Map<AbstractCubeTable,List<String>>>	getJoinPathToColumns()
String	getMergedJoinClause(CubeQueryContext cubeql, DimHQLContext sc, 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(DimHQLContext sc, Set<Dimension> qdims, CubeQueryContext cubeql)
void	pruneAllPaths(CubeInterface cube, Collection<String> candColumns, Map<Dimension,CandidateDim> dimsToQuery) Prunes the join chains defined in Cube whose starting column is not there in any of the candidate facts.
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(StorageCandidate sc)

refreshJoinPathColumns

public void refreshJoinPathColumns()

removeJoinedTable

public void removeJoinedTable(Aliased<Dimension> dim)

getFromString

public String getFromString(String fromTable,
                            DimHQLContext sc,
                            Map<Dimension,CandidateDim> dimsToQuery,
                            CubeQueryContext cubeql)
                     throws LensException

Throws:

LensException

getMergedJoinClause

public String getMergedJoinClause(CubeQueryContext cubeql,
                                  DimHQLContext sc,
                                  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,
                          Collection<String> candColumns,
                          Map<Dimension,CandidateDim> dimsToQuery)
                   throws LensException

Prunes the join chains defined in Cube whose starting column is not there in any of the candidate facts. Same is done in case of join paths defined in Dimensions.

Parameters:

cube -

dimsToQuery -

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(DimHQLContext sc,
                                         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<StorageCandidate,JoinClause> getFactClauses()

getMinCostClause

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

setMinCostClause

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