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

Class HiveParserDDLSemanticAnalyzer

java.lang.Object

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

public class HiveParserDDLSemanticAnalyzer
extends Object

Ported hive's org.apache.hadoop.hive.ql.parse.DDLSemanticAnalyzer, and also incorporated functionalities from SemanticAnalyzer and FunctionSemanticAnalyzer. It's mainly used to convert HiveParserASTNode to the corresponding Operation.

Constructor Summary

Constructors

Constructor and Description
HiveParserDDLSemanticAnalyzer(HiveParserQueryState queryState, HiveCatalog hiveCatalog, CatalogManager catalogManager, HiveParser hiveParser, HiveShim hiveShim, HiveParserContext context, HiveParserDMLHelper dmlHelper, org.apache.calcite.tools.FrameworkConfig frameworkConfig, org.apache.calcite.plan.RelOptCluster cluster, org.apache.flink.table.planner.calcite.FlinkContext flinkContext)

Method Summary

Modifier and Type	Method and Description
Operation	convertToOperation(HiveParserASTNode ast)
static void	encodeRowFormat(HiveParserBaseSemanticAnalyzer.HiveParserRowFormatParams rowFormatParams, Map<String,String> props)
static void	encodeStorageFormat(HiveParserStorageFormat storageFormat, Map<String,String> props)
static HashMap<String,String>	getPartSpec(HiveParserASTNode partspec)
static HashMap<String,String>	getProps(HiveParserASTNode prop)
static String	getTypeName(HiveParserASTNode node)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserDDLSemanticAnalyzer

public HiveParserDDLSemanticAnalyzer(HiveParserQueryState queryState,
                                     HiveCatalog hiveCatalog,
                                     CatalogManager catalogManager,
                                     HiveParser hiveParser,
                                     HiveShim hiveShim,
                                     HiveParserContext context,
                                     HiveParserDMLHelper dmlHelper,
                                     org.apache.calcite.tools.FrameworkConfig frameworkConfig,
                                     org.apache.calcite.plan.RelOptCluster cluster,
                                     org.apache.flink.table.planner.calcite.FlinkContext flinkContext)
                              throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

Method Detail

getTypeName

public static String getTypeName(HiveParserASTNode node)
                          throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

convertToOperation

public Operation convertToOperation(HiveParserASTNode ast)
                             throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

encodeRowFormat

public static void encodeRowFormat(HiveParserBaseSemanticAnalyzer.HiveParserRowFormatParams rowFormatParams,
                                   Map<String,String> props)

encodeStorageFormat

public static void encodeStorageFormat(HiveParserStorageFormat storageFormat,
                                       Map<String,String> props)

getProps

public static HashMap<String,String> getProps(HiveParserASTNode prop)

getPartSpec

public static HashMap<String,String> getPartSpec(HiveParserASTNode partspec)