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

Class HiveParserLoadSemanticAnalyzer

java.lang.Object

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

public class HiveParserLoadSemanticAnalyzer
extends Object

Ported hive's org.apache.hadoop.hive.ql.parse.LoadSemanticAnalyzer.

Constructor Summary

Constructors

Constructor and Description
HiveParserLoadSemanticAnalyzer(HiveConf conf, org.apache.calcite.tools.FrameworkConfig frameworkConfig, org.apache.calcite.plan.RelOptCluster cluster, CatalogManager catalogManager)

Method Summary

Modifier and Type	Method and Description
HiveLoadDataOperation	convertToOperation(HiveParserASTNode ast)
static org.apache.hadoop.fs.FileStatus[]	matchFilesOrDir(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserLoadSemanticAnalyzer

public HiveParserLoadSemanticAnalyzer(HiveConf conf,
                                      org.apache.calcite.tools.FrameworkConfig frameworkConfig,
                                      org.apache.calcite.plan.RelOptCluster cluster,
                                      CatalogManager catalogManager)
                               throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

Method Detail

convertToOperation

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

Throws:

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

matchFilesOrDir

public static org.apache.hadoop.fs.FileStatus[] matchFilesOrDir(org.apache.hadoop.fs.FileSystem fs,
                                                                org.apache.hadoop.fs.Path path)
                                                         throws IOException

Throws:

IOException