程序包 org.apache.flink.sql.parser.hive

Flink sql parser for hive dialect.

请参阅: 说明

程序包org.apache.flink.sql.parser.hive的说明

Flink sql parser for hive dialect.

This module contains the DDLs and some custom DMLs for the Hive dialect.

To use a specific sql dialect for the parser, get the corresponding sql conformance and use it with FlinkSqlParserImplFactory to create the parser like below:

   SqlParser.create(source,
                SqlParser.configBuilder()
                        .setParserFactory(new FlinkSqlParserImplFactory(conformance0))
                                .setQuoting(Quoting.DOUBLE_QUOTE)
                                .setUnquotedCasing(Casing.TO_UPPER)
                                .setQuotedCasing(Casing.UNCHANGED)
                                .setConformance(conformance0) // the sql conformance you want use.
                                .build());