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

Class HiveParserQB

java.lang.Object

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

public class HiveParserQB
extends Object

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

Constructor Summary

Constructors

Constructor	Description
HiveParserQB(String outerId, String alias, boolean isSubQ)

Method Summary

Modifier and Type	Method	Description
void	addAlias(String alias)
void	addDestToWindowingSpec(String dest, HiveParserWindowingSpec windowingSpec)
void	addPTFNodeToSpec(HiveParserASTNode node, HiveParserPTFInvocationSpec spec)
boolean	containsQueryWithoutSourceTable()	returns true, if the query block contains any query, or subquery without a source table.
void	countSel()
void	countSelDi()
boolean	exists(String alias)
List<String>	getAliases()
Set<String>	getAliasInsideView()
HashMap<String,HiveParserWindowingSpec>	getAllWindowingSpecs()
HiveParserDirectoryDesc	getDirectoryDesc()
String	getId()
boolean	getIsQuery()	Set to true in SemanticAnalyzer.getMetadataForDestFile, if destination is a file and query is not CTAS.
HiveParserQBMetaData	getMetaData()
int	getNumSels()
String	getOriginTabNameForAlias(String alias)
HiveParserQBParseInfo	getParseInfo()
HiveParserPTFInvocationSpec	getPTFInvocationSpec(HiveParserASTNode node)
List<String>	getSkewedColumnNames(String alias)	Retrieve skewed column name for a table.
Set<String>	getSubqAliases()
HiveParserQBExpr	getSubqForAlias(String alias)
Set<String>	getTabAliases()
org.apache.hadoop.hive.ql.plan.CreateTableDesc	getTableDesc()
String	getTabNameForAlias(String alias)
Map<String,Tuple2<ResolvedCatalogTable,List<List<String>>>>	getValuesTableToData()
HashMap<String,CatalogView>	getViewToTabSchema()
HiveParserWindowingSpec	getWindowingSpec(String dest)
boolean	hasWindowingSpec(String dest)
int	incrNumSubQueryPredicates()
boolean	isCTAS()
boolean	isInsideView()
boolean	isMaterializedView()
boolean	isSimpleSelectQuery()
void	print(String msg)
void	rewriteCTEToSubq(String alias, String cteName, HiveParserQBExpr qbexpr)
void	rewriteViewToSubq(String alias, String viewName, HiveParserQBExpr qbexpr, CatalogView view)
void	setDirectoryDesc(HiveParserDirectoryDesc directoryDesc)
void	setInsideView(boolean insideView)
void	setIsQuery(boolean isQuery)
void	setSubqAlias(String alias, HiveParserQBExpr qbexpr)
void	setTabAlias(String alias, String originTableName, String qualifiedName)	Maintain table alias -> (originTableName, qualifiedName).
void	setTabProps(String alias, Map<String,String> props)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserQB

public HiveParserQB(String outerId,
                    String alias,
                    boolean isSubQ)

Method Detail

print

public void print(String msg)

getParseInfo

public HiveParserQBParseInfo getParseInfo()

getMetaData

public HiveParserQBMetaData getMetaData()

countSelDi

public void countSelDi()

countSel

public void countSel()

exists

public boolean exists(String alias)

setTabAlias

public void setTabAlias(String alias,
                        String originTableName,
                        String qualifiedName)

Maintain table alias -> (originTableName, qualifiedName).

Parameters:

alias - table alias

originTableName - table name that be actually specified, may be "table", "db.table", "catalog.db.table"

qualifiedName - table name with full path, always is "catalog.db.table"

setSubqAlias

public void setSubqAlias(String alias,
                         HiveParserQBExpr qbexpr)

setTabProps

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

addAlias

public void addAlias(String alias)

getId

public String getId()

getNumSels

public int getNumSels()

getSubqAliases

public Set<String> getSubqAliases()

getTabAliases

public Set<String> getTabAliases()

getAliases

public List<String> getAliases()

getSubqForAlias

public HiveParserQBExpr getSubqForAlias(String alias)

getTabNameForAlias

public String getTabNameForAlias(String alias)

getOriginTabNameForAlias

public String getOriginTabNameForAlias(String alias)

rewriteViewToSubq

public void rewriteViewToSubq(String alias,
                              String viewName,
                              HiveParserQBExpr qbexpr,
                              CatalogView view)

rewriteCTEToSubq

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

setIsQuery

public void setIsQuery(boolean isQuery)

getIsQuery

public boolean getIsQuery()

Set to true in SemanticAnalyzer.getMetadataForDestFile, if destination is a file and query is not CTAS.

isSimpleSelectQuery

public boolean isSimpleSelectQuery()

getTableDesc

public org.apache.hadoop.hive.ql.plan.CreateTableDesc getTableDesc()

setDirectoryDesc

public void setDirectoryDesc(HiveParserDirectoryDesc directoryDesc)

getDirectoryDesc

public HiveParserDirectoryDesc getDirectoryDesc()

isCTAS

public boolean isCTAS()

getSkewedColumnNames

public List<String> getSkewedColumnNames(String alias)

Retrieve skewed column name for a table.

getPTFInvocationSpec

public HiveParserPTFInvocationSpec getPTFInvocationSpec(HiveParserASTNode node)

addPTFNodeToSpec

public void addPTFNodeToSpec(HiveParserASTNode node,
                             HiveParserPTFInvocationSpec spec)

getWindowingSpec

public HiveParserWindowingSpec getWindowingSpec(String dest)

addDestToWindowingSpec

public void addDestToWindowingSpec(String dest,
                                   HiveParserWindowingSpec windowingSpec)

hasWindowingSpec

public boolean hasWindowingSpec(String dest)

getAllWindowingSpecs

public HashMap<String,HiveParserWindowingSpec> getAllWindowingSpecs()

incrNumSubQueryPredicates

public int incrNumSubQueryPredicates()

getViewToTabSchema

public HashMap<String,CatalogView> getViewToTabSchema()

isInsideView

public boolean isInsideView()

setInsideView

public void setInsideView(boolean insideView)

getAliasInsideView

public Set<String> getAliasInsideView()

containsQueryWithoutSourceTable

public boolean containsQueryWithoutSourceTable()

returns true, if the query block contains any query, or subquery without a source table. Like select current_user(), select current_database()

Returns:

true, if the query block contains any query without a source table

isMaterializedView

public boolean isMaterializedView()

getValuesTableToData

public Map<String,Tuple2<ResolvedCatalogTable,List<List<String>>>> getValuesTableToData()