@PublicEvolving public enum SqlDialect extends Enum<SqlDialect>
In most of the cases, the built-in compatibility mode should be sufficient. For some features, i.e. the "INSERT INTO T PARTITION(a='xxx') ..." grammar, you may need to switch to the Hive dialect if required.
We may introduce other SQL dialects in the future.
Enum Constant and Description |
---|
DEFAULT
Flink's default SQL behavior.
|
HIVE
SQL dialect that allows some Apache Hive specific grammar.
|
Modifier and Type | Method and Description |
---|---|
static SqlDialect |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static SqlDialect[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final SqlDialect DEFAULT
public static final SqlDialect HIVE
Note: We might never support all of the Hive grammar. See the documentation for supported features.
public static SqlDialect[] values()
for (SqlDialect c : SqlDialect.values()) System.out.println(c);
public static SqlDialect valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.