org.apache.flink.sql.parser.hive.ddl

类 HiveDDLUtils

java.lang.Object

org.apache.flink.sql.parser.hive.ddl.HiveDDLUtils

public class HiveDDLUtils
extends Object

Util methods for Hive DDL Sql nodes.

字段概要

字段

限定符和类型	字段和说明
static String	COL_DELIMITER

方法概要

限定符和类型	方法和说明
static org.apache.calcite.sql.SqlNodeList	checkReservedDBProperties(org.apache.calcite.sql.SqlNodeList props)
static org.apache.calcite.sql.SqlNodeList	checkReservedTableProperties(org.apache.calcite.sql.SqlNodeList props)
static void	convertDataTypes(org.apache.calcite.sql.SqlNodeList columns)
static void	convertDataTypes(org.apache.flink.sql.parser.ddl.SqlTableColumn.SqlRegularColumn column)
static org.apache.calcite.sql.SqlNodeList	deepCopyColList(org.apache.calcite.sql.SqlNodeList colList)
static org.apache.flink.sql.parser.ddl.SqlTableColumn.SqlRegularColumn	deepCopyTableColumn(org.apache.flink.sql.parser.ddl.SqlTableColumn.SqlRegularColumn column)
static byte	defaultTrait()
static byte	disableConstraint(byte trait)
static byte	enableConstraint(byte trait)
static byte	encodeConstraintTrait(SqlHiveConstraintTrait trait)
static org.apache.calcite.sql.SqlNodeList	ensureNonGeneric(org.apache.calcite.sql.SqlNodeList props)
static byte	noRelyConstraint(byte trait)
static byte	noValidateConstraint(byte trait)
static byte	relyConstraint(byte trait)
static boolean	requireEnableConstraint(byte trait)
static boolean	requireRelyConstraint(byte trait)
static boolean	requireValidateConstraint(byte trait)
static org.apache.flink.sql.parser.ddl.SqlTableOption	toTableOption(String key, org.apache.calcite.sql.SqlNode value, org.apache.calcite.sql.parser.SqlParserPos pos)
static org.apache.flink.sql.parser.ddl.SqlTableOption	toTableOption(String key, String value, org.apache.calcite.sql.parser.SqlParserPos pos)
static void	unescapePartitionSpec(org.apache.calcite.sql.SqlNodeList partSpec)
static void	unescapeProperties(org.apache.calcite.sql.SqlNodeList properties)
static org.apache.calcite.sql.SqlCharStringLiteral	unescapeStringLiteral(org.apache.calcite.sql.SqlCharStringLiteral literal)
static byte	validateConstraint(byte trait)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

COL_DELIMITER

public static final String COL_DELIMITER

另请参阅:

常量字段值

方法详细资料

checkReservedDBProperties

public static org.apache.calcite.sql.SqlNodeList checkReservedDBProperties(org.apache.calcite.sql.SqlNodeList props)
                                                                    throws ParseException

抛出:

ParseException

checkReservedTableProperties

public static org.apache.calcite.sql.SqlNodeList checkReservedTableProperties(org.apache.calcite.sql.SqlNodeList props)
                                                                       throws ParseException

抛出:

ParseException

ensureNonGeneric

public static org.apache.calcite.sql.SqlNodeList ensureNonGeneric(org.apache.calcite.sql.SqlNodeList props)
                                                           throws ParseException

抛出:

ParseException

toTableOption

public static org.apache.flink.sql.parser.ddl.SqlTableOption toTableOption(String key,
                                                                           org.apache.calcite.sql.SqlNode value,
                                                                           org.apache.calcite.sql.parser.SqlParserPos pos)

toTableOption

public static org.apache.flink.sql.parser.ddl.SqlTableOption toTableOption(String key,
                                                                           String value,
                                                                           org.apache.calcite.sql.parser.SqlParserPos pos)

convertDataTypes

public static void convertDataTypes(org.apache.calcite.sql.SqlNodeList columns)
                             throws ParseException

抛出:

ParseException

convertDataTypes

public static void convertDataTypes(org.apache.flink.sql.parser.ddl.SqlTableColumn.SqlRegularColumn column)
                             throws ParseException

抛出:

ParseException

defaultTrait

public static byte defaultTrait()

enableConstraint

public static byte enableConstraint(byte trait)

disableConstraint

public static byte disableConstraint(byte trait)

validateConstraint

public static byte validateConstraint(byte trait)

noValidateConstraint

public static byte noValidateConstraint(byte trait)

relyConstraint

public static byte relyConstraint(byte trait)

noRelyConstraint

public static byte noRelyConstraint(byte trait)

requireEnableConstraint

public static boolean requireEnableConstraint(byte trait)

requireValidateConstraint

public static boolean requireValidateConstraint(byte trait)

requireRelyConstraint

public static boolean requireRelyConstraint(byte trait)

encodeConstraintTrait

public static byte encodeConstraintTrait(SqlHiveConstraintTrait trait)

deepCopyColList

public static org.apache.calcite.sql.SqlNodeList deepCopyColList(org.apache.calcite.sql.SqlNodeList colList)

deepCopyTableColumn

public static org.apache.flink.sql.parser.ddl.SqlTableColumn.SqlRegularColumn deepCopyTableColumn(org.apache.flink.sql.parser.ddl.SqlTableColumn.SqlRegularColumn column)

unescapeProperties

public static void unescapeProperties(org.apache.calcite.sql.SqlNodeList properties)

unescapeStringLiteral

public static org.apache.calcite.sql.SqlCharStringLiteral unescapeStringLiteral(org.apache.calcite.sql.SqlCharStringLiteral literal)

unescapePartitionSpec

public static void unescapePartitionSpec(org.apache.calcite.sql.SqlNodeList partSpec)