org.apache.hadoop.hive.ql.parse
Class QB

java.lang.Object
  org.apache.hadoop.hive.ql.parse.QB

public class QB
extends Object

Implementation of the query block.

Constructor Summary

QB()

QB(String outer_id, String alias, boolean isSubQ)

Method Summary

void	addAlias(String alias)
void	addDestToWindowingSpec(String dest, WindowingSpec windowingSpec)
void	addPTFNodeToSpec(ASTNode node, PTFInvocationSpec spec)
void	countSel()
void	countSelDi()
boolean	exists(String alias)
List<String>	getAliases()
HashMap<String,WindowingSpec>	getAllWindowingSpecs()
static String	getAppendedAliasFromId(String outer_id, String alias)
String	getId()
boolean	getIsQuery()
CreateTableDesc	getLLocalDirectoryDesc()
QBMetaData	getMetaData()
int	getNumGbys()
int	getNumJoins()
int	getNumSelDi()
int	getNumSels()
QBParseInfo	getParseInfo()
PTFInvocationSpec	getPTFInvocationSpec(ASTNode node)
HashMap<ASTNode,PTFInvocationSpec>	getPTFNodeToSpec()
QBJoinTree	getQbJoinTree()
List<String>	getSkewedColumnNames(String alias) Retrieve skewed column name for a table.
Set<String>	getSubqAliases()
QBExpr	getSubqForAlias(String alias)
Set<String>	getTabAliases()
CreateTableDesc	getTableDesc()
String	getTabNameForAlias(String alias)
Map<String,String>	getTabPropsForAlias(String alias)
WindowingSpec	getWindowingSpec(String dest)
boolean	hasTableSample(String alias)
boolean	hasWindowingSpec(String dest)
boolean	isAnalyzeRewrite()
boolean	isCTAS() Whether this QB is for a CREATE-TABLE-AS-SELECT.
boolean	isSimpleSelectQuery()
void	print(String msg)
void	rewriteCTEToSubq(String alias, String cteName, QBExpr qbexpr)
void	rewriteViewToSubq(String alias, String viewName, QBExpr qbexpr)
void	setAnalyzeRewrite(boolean isAnalyzeRewrite)
void	setIsQuery(boolean isQuery)
void	setLocalDirectoryDesc(CreateTableDesc localDirectoryDesc)
void	setQbJoinTree(QBJoinTree qbjoin)
void	setQBParseInfo(QBParseInfo qbp)
void	setSubqAlias(String alias, QBExpr qbexpr)
void	setTabAlias(String alias, String tabName)
void	setTableDesc(CreateTableDesc desc)
void	setTabProps(String alias, Map<String,String> props)

Methods inherited from class java.lang.Object

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

Constructor Detail

QB

public QB()

QB

public QB(String outer_id,
          String alias,
          boolean isSubQ)

Method Detail

print

public void print(String msg)

getAppendedAliasFromId

public static String getAppendedAliasFromId(String outer_id,
                                            String alias)

getParseInfo

public QBParseInfo getParseInfo()

getMetaData

public QBMetaData getMetaData()

setQBParseInfo

public void setQBParseInfo(QBParseInfo qbp)

countSelDi

public void countSelDi()

countSel

public void countSel()

exists

public boolean exists(String alias)

setTabAlias

public void setTabAlias(String alias,
                        String tabName)

setSubqAlias

public void setSubqAlias(String alias,
                         QBExpr qbexpr)

setTabProps

public void setTabProps(String alias,
                        Map<String,String> props)

addAlias

public void addAlias(String alias)

getId

public String getId()

getNumGbys

public int getNumGbys()

getNumSelDi

public int getNumSelDi()

getNumSels

public int getNumSels()

getNumJoins

public int getNumJoins()

getSubqAliases

public Set<String> getSubqAliases()

getTabAliases

public Set<String> getTabAliases()

getAliases

public List<String> getAliases()

getSubqForAlias

public QBExpr getSubqForAlias(String alias)

getTabNameForAlias

public String getTabNameForAlias(String alias)

getTabPropsForAlias

public Map<String,String> getTabPropsForAlias(String alias)

rewriteViewToSubq

public void rewriteViewToSubq(String alias,
                              String viewName,
                              QBExpr qbexpr)

rewriteCTEToSubq

public void rewriteCTEToSubq(String alias,
                             String cteName,
                             QBExpr qbexpr)

getQbJoinTree

public QBJoinTree getQbJoinTree()

setQbJoinTree

public void setQbJoinTree(QBJoinTree qbjoin)

setIsQuery

public void setIsQuery(boolean isQuery)

getIsQuery

public boolean getIsQuery()

isSimpleSelectQuery

public boolean isSimpleSelectQuery()

hasTableSample

public boolean hasTableSample(String alias)

getTableDesc

public CreateTableDesc getTableDesc()

setTableDesc

public void setTableDesc(CreateTableDesc desc)

getLLocalDirectoryDesc

public CreateTableDesc getLLocalDirectoryDesc()

setLocalDirectoryDesc

public void setLocalDirectoryDesc(CreateTableDesc localDirectoryDesc)

isCTAS

public boolean isCTAS()

Whether this QB is for a CREATE-TABLE-AS-SELECT.

getSkewedColumnNames

public List<String> getSkewedColumnNames(String alias)

Retrieve skewed column name for a table.

Parameters:

alias - table alias

Returns:

isAnalyzeRewrite

public boolean isAnalyzeRewrite()

setAnalyzeRewrite

public void setAnalyzeRewrite(boolean isAnalyzeRewrite)

getPTFInvocationSpec

public PTFInvocationSpec getPTFInvocationSpec(ASTNode node)

addPTFNodeToSpec

public void addPTFNodeToSpec(ASTNode node,
                             PTFInvocationSpec spec)

getPTFNodeToSpec

public HashMap<ASTNode,PTFInvocationSpec> getPTFNodeToSpec()

getWindowingSpec

public WindowingSpec getWindowingSpec(String dest)

addDestToWindowingSpec

public void addDestToWindowingSpec(String dest,
                                   WindowingSpec windowingSpec)

hasWindowingSpec

public boolean hasWindowingSpec(String dest)

getAllWindowingSpecs

public HashMap<String,WindowingSpec> getAllWindowingSpecs()