Skip navigation links

Back to Flink Website

Package org.apache.flink.sql.parser.hive

Flink sql parser for hive dialect.

See: Description

Package org.apache.flink.sql.parser.hive Description

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.config()
              .withParserFactory(new FlinkSqlParserImplFactory(conformance0))
              .withQuoting(Quoting.DOUBLE_QUOTE)
              .withUnquotedCasing(Casing.TO_UPPER)
              .withQuotedCasing(Casing.UNCHANGED)
              .withConformance(conformance0); // the sql conformance you want use.
 
Skip navigation links

Back to Flink Website

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