Interface | Description |
---|---|
ExtendedSqlNode |
An remark interface which should be inherited by extended sql nodes which are not supported by
Calcite core parser.
|
Class | Description |
---|---|
SqlPartitionSpecProperty |
Properties of PartitionSpec, a key-value pair with key as component identifier and value as
string literal.
|
SqlPartitionUtils |
Utils methods for partition DDLs.
|
SqlProperty |
Properties of a DDL, a key-value pair with key as component identifier and value as string
literal.
|
SqlUnparseUtils |
Utils to unparse DDLs.
|
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());
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.