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