Package | Description |
---|---|
org.apache.flink.sql.parser.ddl | |
org.apache.flink.sql.parser.hive.ddl | |
org.apache.flink.sql.parser.hive.impl | |
org.apache.flink.sql.parser.impl |
Modifier and Type | Class and Description |
---|---|
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 table_name ADD column/constraint/watermark clause.
|
class |
SqlAlterTableAddConstraint
ALTER TABLE [catalog_name.][db_name.]table_name ADD [CONSTRAINT constraint_name] (PRIMARY KEY |
UNIQUE) (column, ...) [[NOT] ENFORCED].
|
class |
SqlAlterTableCompact
ALTER TABLE [[catalogName.] dataBasesName].tableName [PARTITION partition_spec] COMPACT.
|
class |
SqlAlterTableDropConstraint
ALTER TABLE [catalog_name.][db_name.]table_name DROP CONSTRAINT constraint_name.
|
class |
SqlAlterTableModify
SqlNode to describe ALTER TABLE table_name MODIFY column/constraint/watermark clause.
|
class |
SqlAlterTableOptions
ALTER TABLE [[catalogName.] dataBasesName].tableName SET ( name=value [, name=value]*).
|
class |
SqlAlterTableRename
ALTER TABLE [[catalogName.] dataBasesName].tableName RENAME TO [[catalogName.]
dataBasesName].newTableName.
|
class |
SqlAlterTableReset
ALTER TABLE [[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.
|
Modifier and Type | Class and Description |
---|---|
class |
SqlAddHivePartitions
Add partitions to a Hive table.
|
class |
SqlAlterHivePartitionRename
ALTER TABLE DDL to change the specifications of a Hive partition.
|
class |
SqlAlterHiveTable
Abstract class for ALTER DDL of a Hive table.
|
class |
SqlAlterHiveTableAddReplaceColumn
ALTER DDL to ADD or REPLACE columns for a Hive table.
|
class |
SqlAlterHiveTableChangeColumn
ALTER DDL to change a column's name, type, position, etc.
|
class |
SqlAlterHiveTableFileFormat
ALTER TABLE DDL to change a Hive table/partition's file format.
|
class |
SqlAlterHiveTableLocation
ALTER TABLE DDL to change a Hive table/partition's location.
|
class |
SqlAlterHiveTableProps
ALTER DDL to change properties of a Hive table.
|
class |
SqlAlterHiveTableSerDe
ALTER TABLE DDL to change a Hive table's SerDe.
|
Modifier and Type | Method and Description |
---|---|
SqlAlterTable |
FlinkHiveSqlParserImpl.SqlAddHivePartitions(org.apache.calcite.sql.parser.SqlParserPos startPos,
org.apache.calcite.sql.SqlIdentifier tableIdentifier,
boolean ifNotExists)
Hive syntax:
ALTER TABLE table_name ADD [IF NOT EXISTS]
PARTITION partition_spec [LOCATION 'location'][PARTITION partition_spec [LOCATION 'location']][...];
|
SqlAlterTable |
FlinkHiveSqlParserImpl.SqlAlterHiveTableAddReplaceColumn(org.apache.calcite.sql.parser.SqlParserPos startPos,
org.apache.calcite.sql.SqlIdentifier tableIdentifier,
boolean replace) |
SqlAlterTable |
FlinkHiveSqlParserImpl.SqlAlterHiveTableChangeColumn(org.apache.calcite.sql.parser.SqlParserPos startPos,
org.apache.calcite.sql.SqlIdentifier tableIdentifier) |
SqlAlterTable |
FlinkHiveSqlParserImpl.SqlAlterHiveTableSerDe(org.apache.calcite.sql.parser.SqlParserPos startPos,
org.apache.calcite.sql.SqlIdentifier tableIdentifier,
org.apache.calcite.sql.SqlNodeList partitionSpec) |
SqlAlterTable |
FlinkHiveSqlParserImpl.SqlAlterTable() |
SqlAlterTable |
FlinkHiveSqlParserImpl.SqlDropPartitions(org.apache.calcite.sql.parser.SqlParserPos startPos,
org.apache.calcite.sql.SqlIdentifier tableIdentifier,
boolean ifExists)
Hive syntax:
ALTER TABLE table_name DROP [IF EXISTS] PARTITION partition_spec[, PARTITION partition_spec, ...]
[IGNORE PROTECTION] [PURGE];
|
Modifier and Type | Method and Description |
---|---|
SqlAlterTable |
FlinkSqlParserImpl.SqlAlterTable() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.