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

类 SqlCreateHiveTable

java.lang.Object

org.apache.calcite.sql.SqlNode

org.apache.calcite.sql.SqlCall

org.apache.calcite.sql.SqlDdl

org.apache.calcite.sql.SqlCreate

org.apache.flink.sql.parser.ddl.SqlCreateTable

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

所有已实现的接口:

Cloneable, org.apache.flink.sql.parser.ExtendedSqlNode

public class SqlCreateHiveTable
extends org.apache.flink.sql.parser.ddl.SqlCreateTable

CREATE Table DDL for Hive dialect.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	SqlCreateHiveTable.HiveTableCreationContext Creation context for a Hive table.
static class	SqlCreateHiveTable.HiveTableRowFormat To represent ROW FORMAT in CREATE TABLE DDL.
static class	SqlCreateHiveTable.HiveTableStoredAs To represent STORED AS in CREATE TABLE DDL.

从类继承的嵌套类/接口 org.apache.flink.sql.parser.ddl.SqlCreateTable

org.apache.flink.sql.parser.ddl.SqlCreateTable.TableCreationContext

字段概要

字段

限定符和类型	字段和说明
static String	IDENTIFIER
static String	NOT_NULL_COLS
static String	NOT_NULL_CONSTRAINT_TRAITS
static String	PK_CONSTRAINT_TRAIT
static String	TABLE_IS_EXTERNAL
static String	TABLE_LOCATION_URI

从类继承的字段 org.apache.flink.sql.parser.ddl.SqlCreateTable

OPERATOR

从类继承的字段 org.apache.calcite.sql.SqlCreate

ifNotExists

从类继承的字段 org.apache.calcite.sql.SqlDdl

DDL_OPERATOR

从类继承的字段 org.apache.calcite.sql.SqlNode

EMPTY_ARRAY, pos

构造器概要

构造器

构造器和说明

SqlCreateHiveTable(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, SqlCreateHiveTable.HiveTableCreationContext creationContext, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNodeList partColList, org.apache.calcite.sql.SqlCharStringLiteral comment, boolean isTemporary, boolean isExternal, SqlCreateHiveTable.HiveTableRowFormat rowFormat, SqlCreateHiveTable.HiveTableStoredAs storedAs, org.apache.calcite.sql.SqlCharStringLiteral location, boolean ifNotExists)

方法概要

限定符和类型	方法和说明
void	unparse(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec)

从类继承的方法 org.apache.flink.sql.parser.ddl.SqlCreateTable

fullTableName, getColumnList, getColumnSqlString, getComment, getFullConstraints, getOperandList, getOperator, getPartitionKeyList, getPropertyList, getTableConstraints, getTableLike, getTableName, getWatermark, hasRegularColumnsOnly, isIfNotExists, isTemporary, printIndent, validate

从类继承的方法 org.apache.calcite.sql.SqlCreate

getReplace, setReplace

从类继承的方法 org.apache.calcite.sql.SqlCall

accept, clone, equalsDeep, findValidOptions, getCallSignature, getFunctionQuantifier, getKind, getMonotonicity, isCountStar, isExpanded, operand, operandCount, setOperand, validate

从类继承的方法 org.apache.calcite.sql.SqlNode

clone, clone, cloneArray, equalDeep, equalDeep, equalsDeep, getParserPosition, isA, toList, toList, toSqlString, toSqlString, toSqlString, toString, unparseWithParentheses, validateExpr

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

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

字段详细资料

IDENTIFIER

public static final String IDENTIFIER

另请参阅:

常量字段值

TABLE_LOCATION_URI

public static final String TABLE_LOCATION_URI

另请参阅:

常量字段值

TABLE_IS_EXTERNAL

public static final String TABLE_IS_EXTERNAL

另请参阅:

常量字段值

PK_CONSTRAINT_TRAIT

public static final String PK_CONSTRAINT_TRAIT

另请参阅:

常量字段值

NOT_NULL_CONSTRAINT_TRAITS

public static final String NOT_NULL_CONSTRAINT_TRAITS

另请参阅:

常量字段值

NOT_NULL_COLS

public static final String NOT_NULL_COLS

另请参阅:

常量字段值

构造器详细资料

SqlCreateHiveTable

public SqlCreateHiveTable(org.apache.calcite.sql.parser.SqlParserPos pos,
                          org.apache.calcite.sql.SqlIdentifier tableName,
                          org.apache.calcite.sql.SqlNodeList columnList,
                          SqlCreateHiveTable.HiveTableCreationContext creationContext,
                          org.apache.calcite.sql.SqlNodeList propertyList,
                          org.apache.calcite.sql.SqlNodeList partColList,
                          @Nullable
                          org.apache.calcite.sql.SqlCharStringLiteral comment,
                          boolean isTemporary,
                          boolean isExternal,
                          SqlCreateHiveTable.HiveTableRowFormat rowFormat,
                          SqlCreateHiveTable.HiveTableStoredAs storedAs,
                          org.apache.calcite.sql.SqlCharStringLiteral location,
                          boolean ifNotExists)
                   throws ParseException

抛出:

ParseException

方法详细资料

unparse

public void unparse(org.apache.calcite.sql.SqlWriter writer,
                    int leftPrec,
                    int rightPrec)

覆盖:

unparse 在类中 org.apache.flink.sql.parser.ddl.SqlCreateTable