Skip navigation links

Back to Flink Website

Package org.apache.flink.sql.parser

Flink sql parser.

See: Description

Package org.apache.flink.sql.parser Description

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.configBuilder()
                        .setParserFactory(parserImplFactory())
                                .setQuoting(Quoting.DOUBLE_QUOTE)
                                .setUnquotedCasing(Casing.TO_UPPER)
                                .setQuotedCasing(Casing.UNCHANGED)
                                .setConformance(conformance0) // the sql conformance you want use.
                                .build());
 
Skip navigation links

Back to Flink Website

Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.