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

Flink sql parser.

请参阅: 说明

接口概要

接口	说明
ExtendedSqlNode	An remark interface which should be inherited by extended sql nodes which are not supported by Calcite core parser.

类概要

类	说明
SqlConstraintValidator	Util to validate SqlTableConstraint.
SqlPartitionSpecProperty	Properties of PartitionSpec, a key-value pair with key as component identifier and value as string literal.
SqlPartitionUtils	Utils methods for partition DDLs.
SqlProperty	Properties of a DDL, a key-value pair with key as component identifier and value as string literal.
SqlUnparseUtils	Utils to unparse DDLs.

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

Flink sql parser.

This module contains the DDLs and some custom DMLs for Apache Flink.

Most of the sql grammars belong to sql standard or Flink's dialect. To support a new sql dialect, add a new sql conformance to FlinkSqlConformance, then use this sql conformance to make context aware decisions in parse block. See the usage of FlinkSqlConformance.HIVE in parserImpls.ftl.

To use a specific sql dialect for the parser, config the parser to the specific sql conformance with a code snippet like below:

   SqlParser.create(source,
                SqlParser.config()
                        .withParserFactory(parserImplFactory())
                                .withQuoting(Quoting.DOUBLE_QUOTE)
                                .withUnquotedCasing(Casing.TO_UPPER)
                                .withQuotedCasing(Casing.UNCHANGED)
                                .withConformance(conformance0); // the sql conformance you want use.