| 程序包 | 说明 |
|---|---|
| org.apache.flink.sql.parser.ddl | |
| org.apache.flink.sql.parser.impl |
| 限定符和类型 | 类和说明 |
|---|---|
class |
SqlAddPartitions
ALTER TABLE DDL to add partitions to a table.
|
class |
SqlAddReplaceColumns
ALTER DDL to ADD or REPLACE columns for a table.
|
class |
SqlAlterTableAdd
SqlNode to describe ALTER TABLE [IF EXISTS] table_name ADD column/constraint/watermark clause.
|
class |
SqlAlterTableAddConstraint
ALTER TABLE [IF EXISTS] [catalog_name.]
|
class |
SqlAlterTableCompact
ALTER TABLE [IF EXISTS] [[catalogName.] dataBasesName].tableName [PARTITION partition_spec]
COMPACT.
|
class |
SqlAlterTableDropColumn
SqlNode to describe ALTER TABLE [IF EXISTS] table_name DROP column clause.
|
class |
SqlAlterTableDropConstraint
ALTER TABLE [IF EXISTS] [catalog_name.]
|
class |
SqlAlterTableDropPrimaryKey
ALTER TABLE [IF EXISTS] [catalog_name.]
|
class |
SqlAlterTableDropWatermark
SqlNode to describe ALTER TABLE [IF EXISTS] table_name DROP watermark clause.
|
class |
SqlAlterTableModify
SqlNode to describe ALTER TABLE [IF EXISTS] table_name MODIFY column/constraint/watermark clause.
|
class |
SqlAlterTableOptions
ALTER TABLE [IF EXISTS] [[catalogName.] dataBasesName].tableName SET ( name=value [,
name=value]*).
|
class |
SqlAlterTableRename
ALTER TABLE [IF EXISTS] [[catalogName.] dataBasesName].tableName RENAME TO [[catalogName.]
|
class |
SqlAlterTableRenameColumn
ALTER TABLE [IF EXISTS] [[catalogName.] dataBasesName].tableName RENAME originColumnName TO
newColumnName.
|
class |
SqlAlterTableReset
ALTER TABLE [IF EXISTS] [[catalogName.] dataBasesName].tableName RESET ( 'key1' [, 'key2']*).
|
class |
SqlAlterTableSchema
Abstract class to describe statements which are used to alter table schema.
|
class |
SqlChangeColumn
ALTER DDL to CHANGE a column for a table.
|
class |
SqlDropPartitions
ALTER TABLE DDL to drop partitions of a table.
|
| 限定符和类型 | 方法和说明 |
|---|---|
SqlAlterTable |
FlinkSqlParserImpl.SqlAlterTable() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.