org.apache.flink.table.planner.delegation.hive.copy

Class HiveParserQBParseInfo

java.lang.Object

org.apache.flink.table.planner.delegation.hive.copy.HiveParserQBParseInfo

public class HiveParserQBParseInfo
extends Object

Counterpart of hive's org.apache.hadoop.hive.ql.parse.QBParseInfo.

Constructor Summary

Constructors

Constructor and Description
HiveParserQBParseInfo(String alias, boolean isSubQ)

Method Summary

Modifier and Type	Method and Description
void	addAggregationExprsForClause(String clause, LinkedHashMap<String,HiveParserASTNode> aggregationTrees)
void	addInsertIntoTable(String fullName, HiveParserASTNode ast)
void	addLateralViewForAlias(String alias, HiveParserASTNode lateralView)
void	addTableSpec(String tName, HiveParserBaseSemanticAnalyzer.TableSpec tSpec)
void	addWindowingExprToClause(String clause, HiveParserASTNode windowingExprNode)
HashMap<String,HiveParserASTNode>	getAggregationExprsForClause(String clause)
String	getAlias()
Map<String,ArrayList<HiveParserASTNode>>	getAliasToLateralViews()
Map<HiveParserASTNode,String>	getAllExprToColumnAlias()
Set<String>	getClauseNames()
Set<String>	getClauseNamesForDest()
HiveParserASTNode	getClusterByForClause(String clause) Get the Cluster By AST for the clause.
Set<String>	getDestCubes()
HiveParserASTNode	getDestForClause(String clause)
Set<String>	getDestGroupingSets()
Integer	getDestLimit(String dest)
Set<String>	getDestRollups()
List<String>	getDestSchemaForClause(String clause)
HashMap<String,HiveParserASTNode>	getDestToClusterBy()
HashMap<String,HiveParserASTNode>	getDestToDistributeBy()
HashMap<String,HiveParserASTNode>	getDestToGroupBy()
HashMap<String,HiveParserASTNode>	getDestToLateralView()
HashMap<String,AbstractMap.SimpleEntry<Integer,Integer>>	getDestToLimit()
HashMap<String,HiveParserASTNode>	getDestToOrderBy()
HashMap<String,HiveParserASTNode>	getDestToSortBy()
HashMap<String,HiveParserASTNode>	getDestToWhereExpr()
List<HiveParserASTNode>	getDistinctFuncExprsForClause(String clause)
HiveParserASTNode	getDistributeByForClause(String clause) Get the Distribute By AST for the clause.
HiveParserASTNode	getGroupByForClause(String clause)
HiveParserASTNode	getHavingForClause(String clause)
HiveParserASTNode	getHints()
Map<String,HiveParserASTNode>	getInsertOverwriteTables()
boolean	getIsSubQ()
HiveParserASTNode	getJoinExpr()
HiveParserASTNode	getOrderByForClause(String clause)
HiveParserASTNode	getQueryFrom()
HiveParserASTNode	getSelForClause(String clause)
HiveParserASTNode	getSortByForClause(String clause) Get the Sort By AST for the clause.
HiveParserASTNode	getSrcForAlias(String alias)
HashMap<String,HiveParserASTNode>	getWindowingExprsForClause(String clause)
boolean	isAnalyzeCommand()
boolean	isInsertIntoTable(String fullName)
boolean	isPartialScanAnalyzeCommand()
boolean	isSimpleSelectQuery()
boolean	needTableSample(String alias)
void	setAggregationExprsForClause(String clause, LinkedHashMap<String,HiveParserASTNode> aggregationTrees)
void	setAlias(String alias)
void	setClusterByExprForClause(String clause, HiveParserASTNode ast) Set the Cluster By AST for the clause.
void	setDestForClause(String clause, HiveParserASTNode ast)
void	setDestLimit(String dest, Integer offset, Integer limit)
void	setDistinctFuncExprsForClause(String clause, List<HiveParserASTNode> ast)
void	setDistributeByExprForClause(String clause, HiveParserASTNode ast) Set the Distribute By AST for the clause.
void	setExprToColumnAlias(HiveParserASTNode expr, String alias)
void	setGroupByExprForClause(String clause, HiveParserASTNode ast)
void	setHavingExprForClause(String clause, HiveParserASTNode ast)
void	setHints(HiveParserASTNode hint)
void	setIsAnalyzeCommand(boolean isAnalyzeCommand)
void	setJoinExpr(HiveParserASTNode joinExpr)
void	setNoScanAnalyzeCommand(boolean isNoScanAnalyzeCommand)
void	setOrderByExprForClause(String clause, HiveParserASTNode ast)
void	setPartialScanAnalyzeCommand(boolean isPartialScanAnalyzeCommand)
void	setQueryFromExpr(HiveParserASTNode ast)
void	setSelExprForClause(String clause, HiveParserASTNode ast)
void	setSortByExprForClause(String clause, HiveParserASTNode ast) Set the Sort By AST for the clause.
void	setSrcForAlias(String alias, HiveParserASTNode ast)
void	setTabSample(String alias)
void	setWhrExprForClause(String clause, HiveParserASTNode ast)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserQBParseInfo

public HiveParserQBParseInfo(String alias,
                             boolean isSubQ)

Method Detail

setAggregationExprsForClause

public void setAggregationExprsForClause(String clause,
                                         LinkedHashMap<String,HiveParserASTNode> aggregationTrees)

addAggregationExprsForClause

public void addAggregationExprsForClause(String clause,
                                         LinkedHashMap<String,HiveParserASTNode> aggregationTrees)

addInsertIntoTable

public void addInsertIntoTable(String fullName,
                               HiveParserASTNode ast)

isInsertIntoTable

public boolean isInsertIntoTable(String fullName)

getAggregationExprsForClause

public HashMap<String,HiveParserASTNode> getAggregationExprsForClause(String clause)

addWindowingExprToClause

public void addWindowingExprToClause(String clause,
                                     HiveParserASTNode windowingExprNode)

getWindowingExprsForClause

public HashMap<String,HiveParserASTNode> getWindowingExprsForClause(String clause)

setDistinctFuncExprsForClause

public void setDistinctFuncExprsForClause(String clause,
                                          List<HiveParserASTNode> ast)

getDistinctFuncExprsForClause

public List<HiveParserASTNode> getDistinctFuncExprsForClause(String clause)

setSelExprForClause

public void setSelExprForClause(String clause,
                                HiveParserASTNode ast)

setQueryFromExpr

public void setQueryFromExpr(HiveParserASTNode ast)

setWhrExprForClause

public void setWhrExprForClause(String clause,
                                HiveParserASTNode ast)

setHavingExprForClause

public void setHavingExprForClause(String clause,
                                   HiveParserASTNode ast)

setGroupByExprForClause

public void setGroupByExprForClause(String clause,
                                    HiveParserASTNode ast)

setDestForClause

public void setDestForClause(String clause,
                             HiveParserASTNode ast)

getDestSchemaForClause

public List<String> getDestSchemaForClause(String clause)

setClusterByExprForClause

public void setClusterByExprForClause(String clause,
                                      HiveParserASTNode ast)

Set the Cluster By AST for the clause.

setDistributeByExprForClause

public void setDistributeByExprForClause(String clause,
                                         HiveParserASTNode ast)

Set the Distribute By AST for the clause.

setSortByExprForClause

public void setSortByExprForClause(String clause,
                                   HiveParserASTNode ast)

Set the Sort By AST for the clause.

setOrderByExprForClause

public void setOrderByExprForClause(String clause,
                                    HiveParserASTNode ast)

setSrcForAlias

public void setSrcForAlias(String alias,
                           HiveParserASTNode ast)

getClauseNames

public Set<String> getClauseNames()

getClauseNamesForDest

public Set<String> getClauseNamesForDest()

getDestForClause

public HiveParserASTNode getDestForClause(String clause)

getDestToWhereExpr

public HashMap<String,HiveParserASTNode> getDestToWhereExpr()

getGroupByForClause

public HiveParserASTNode getGroupByForClause(String clause)

getDestRollups

public Set<String> getDestRollups()

getDestCubes

public Set<String> getDestCubes()

getDestGroupingSets

public Set<String> getDestGroupingSets()

getDestToGroupBy

public HashMap<String,HiveParserASTNode> getDestToGroupBy()

getHavingForClause

public HiveParserASTNode getHavingForClause(String clause)

getSelForClause

public HiveParserASTNode getSelForClause(String clause)

getQueryFrom

public HiveParserASTNode getQueryFrom()

getClusterByForClause

public HiveParserASTNode getClusterByForClause(String clause)

Get the Cluster By AST for the clause.

getDestToClusterBy

public HashMap<String,HiveParserASTNode> getDestToClusterBy()

getDistributeByForClause

public HiveParserASTNode getDistributeByForClause(String clause)

Get the Distribute By AST for the clause.

getDestToDistributeBy

public HashMap<String,HiveParserASTNode> getDestToDistributeBy()

getSortByForClause

public HiveParserASTNode getSortByForClause(String clause)

Get the Sort By AST for the clause.

getOrderByForClause

public HiveParserASTNode getOrderByForClause(String clause)

getDestToSortBy

public HashMap<String,HiveParserASTNode> getDestToSortBy()

getDestToOrderBy

public HashMap<String,HiveParserASTNode> getDestToOrderBy()

getSrcForAlias

public HiveParserASTNode getSrcForAlias(String alias)

getAlias

public String getAlias()

setAlias

public void setAlias(String alias)

getIsSubQ

public boolean getIsSubQ()

getJoinExpr

public HiveParserASTNode getJoinExpr()

setJoinExpr

public void setJoinExpr(HiveParserASTNode joinExpr)

needTableSample

public boolean needTableSample(String alias)

setTabSample

public void setTabSample(String alias)

getAllExprToColumnAlias

public Map<HiveParserASTNode,String> getAllExprToColumnAlias()

setExprToColumnAlias

public void setExprToColumnAlias(HiveParserASTNode expr,
                                 String alias)

setDestLimit

public void setDestLimit(String dest,
                         Integer offset,
                         Integer limit)

getDestLimit

public Integer getDestLimit(String dest)

isSimpleSelectQuery

public boolean isSimpleSelectQuery()

setHints

public void setHints(HiveParserASTNode hint)

getHints

public HiveParserASTNode getHints()

getAliasToLateralViews

public Map<String,ArrayList<HiveParserASTNode>> getAliasToLateralViews()

addLateralViewForAlias

public void addLateralViewForAlias(String alias,
                                   HiveParserASTNode lateralView)

setIsAnalyzeCommand

public void setIsAnalyzeCommand(boolean isAnalyzeCommand)

isAnalyzeCommand

public boolean isAnalyzeCommand()

addTableSpec

public void addTableSpec(String tName,
                         HiveParserBaseSemanticAnalyzer.TableSpec tSpec)

getDestToLimit

public HashMap<String,AbstractMap.SimpleEntry<Integer,Integer>> getDestToLimit()

getDestToLateralView

public HashMap<String,HiveParserASTNode> getDestToLateralView()

setNoScanAnalyzeCommand

public void setNoScanAnalyzeCommand(boolean isNoScanAnalyzeCommand)

Parameters:

isNoScanAnalyzeCommand - the isNoScanAnalyzeCommand to set

isPartialScanAnalyzeCommand

public boolean isPartialScanAnalyzeCommand()

Returns:

the isPartialScanAnalyzeCommand

setPartialScanAnalyzeCommand

public void setPartialScanAnalyzeCommand(boolean isPartialScanAnalyzeCommand)

Parameters:

isPartialScanAnalyzeCommand - the isPartialScanAnalyzeCommand to set

getInsertOverwriteTables

public Map<String,HiveParserASTNode> getInsertOverwriteTables()