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

Class HiveParserQBMetaData

java.lang.Object

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

public class HiveParserQBMetaData
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEST_TABLE

Constructor Summary

Constructors

Constructor and Description
HiveParserQBMetaData()

Method Summary

Modifier and Type	Method and Description
String	getDestFileForAlias(String alias)
CatalogPartitionSpec	getDestPartitionForAlias(String alias)
Integer	getDestTypeForAlias(String alias)
Map<String,Tuple3<String,CatalogTable,CatalogPartitionSpec>>	getNameToDestPartition()
Map<String,Tuple2<String,CatalogTable>>	getNameToDestTable()
Map<String,String>	getPartSpecForAlias(String alias)
Tuple2<String,CatalogTable>	getSrcForAlias(String alias)
void	setDestForAlias(String alias, String fname, boolean isDfsFile)
void	setDestForAlias(String alias, String tabName, CatalogTable tab)
void	setDestForAlias(String alias, String tabName, CatalogTable tab, CatalogPartitionSpec part)
void	setPartSpecForAlias(String alias, Map<String,String> partSpec)
void	setSrcForAlias(String alias, String tabName, CatalogTable tab)

Methods inherited from class java.lang.Object

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

Field Detail

DEST_TABLE

public static final int DEST_TABLE

See Also:

Constant Field Values

Constructor Detail

HiveParserQBMetaData

public HiveParserQBMetaData()

Method Detail

setSrcForAlias

public void setSrcForAlias(String alias,
                           String tabName,
                           CatalogTable tab)

setDestForAlias

public void setDestForAlias(String alias,
                            String tabName,
                            CatalogTable tab)

setDestForAlias

public void setDestForAlias(String alias,
                            String tabName,
                            CatalogTable tab,
                            CatalogPartitionSpec part)

setDestForAlias

public void setDestForAlias(String alias,
                            String fname,
                            boolean isDfsFile)

getNameToDestTable

public Map<String,Tuple2<String,CatalogTable>> getNameToDestTable()

getDestFileForAlias

public String getDestFileForAlias(String alias)

getDestPartitionForAlias

public CatalogPartitionSpec getDestPartitionForAlias(String alias)

getNameToDestPartition

public Map<String,Tuple3<String,CatalogTable,CatalogPartitionSpec>> getNameToDestPartition()

getSrcForAlias

public Tuple2<String,CatalogTable> getSrcForAlias(String alias)

getPartSpecForAlias

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

setPartSpecForAlias

public void setPartSpecForAlias(String alias,
                                Map<String,String> partSpec)

getDestTypeForAlias

public Integer getDestTypeForAlias(String alias)