xingyuan cheng created FLINK-22817:
--------------------------------------
Summary: About flink1.13 hive integration Kafka SQL
Key: FLINK-22817
URL: https://issues.apache.org/jira/browse/FLINK-22817
Project: Flink
Issue Type: New Feature
Components: Table SQL / Planner
Affects Versions: 1.13.1
Environment: flink: 1.13.1
flink calcite: 1.26.1
kafka-eagle: 2.0.5
kafka-eagle calcite 1.21.0
Reporter: xingyuan cheng
Attachments: hive-2021-06-01-2.png, hive-2021-06-01-3.png,
hive-2021-06-01.png
hello, I observe the community’s proposal
Flip-152:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-152%3A+Hive+Query+Syntax+Compatibility
We can know that
```
CREATE CATALOG myhive WITH (
'Type' ='hive',
'Default-database' ='default',
'Hive-conf-dir' ='/data/hive/conf/'
);
To
USE CATALOG myhive;
Set table.sql-dialect=hive;
```
When specifying the sql-dialect type, it will follow the SPI from the
configuration file
The org.apache.flink.table.factories.TableFactory file under
flink-connector-hive is assigned to HiveParserFactory to parse the
corresponding grammar, and HiveParser is the corresponding grammar parser
And perform grammatical analysis in HiveParserFactory#create
During the course of investigating kafka-eagle, I found
Among them, KSQL is also based on calcite for grammatical analysis, and can
support DDL and DML of kafka tables
Test-related classes are in: KSqlParser#TestKSqlParser
And completed the analysis of the corresponding grammar in
KsqlParser#parseQueryKSql
Does the community have any good suggestions for this proposal?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
