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.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.