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.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());
 
Skip navigation links

Back to Flink Website

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