org.apache.flink.table.planner.operations

Class AlterSchemaConverter

java.lang.Object

org.apache.flink.table.planner.operations.AlterSchemaConverter

public class AlterSchemaConverter
extends Object

Converter to convert SqlAlterTableSchema with source table to generate new Schema.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.operations.Operation	convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropColumn dropColumn, org.apache.flink.table.catalog.ResolvedCatalogTable oldTable) Convert ALTER TABLE DROP (col1 [, col2, ...]) to generate an updated Schema.
org.apache.flink.table.operations.Operation	convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropConstraint dropConstraint, org.apache.flink.table.catalog.ResolvedCatalogTable oldTable) Convert ALTER TABLE DROP CONSTRAINT constraint_name to generate an updated Schema.
org.apache.flink.table.operations.Operation	convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropPrimaryKey dropPrimaryKey, org.apache.flink.table.catalog.ResolvedCatalogTable oldTable) Convert ALTER TABLE DROP PRIMARY KEY to generate an updated Schema.
org.apache.flink.table.operations.Operation	convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropWatermark dropWatermark, org.apache.flink.table.catalog.ResolvedCatalogTable oldTable) Convert ALTER TABLE DROP WATERMARK to generate an updated Schema.
org.apache.flink.table.operations.Operation	convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableRenameColumn renameColumn, org.apache.flink.table.catalog.ResolvedCatalogTable oldTable) Convert ALTER TABLE RENAME col_name to new_col_name to generate an updated Schema.
org.apache.flink.table.operations.Operation	convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableSchema alterTableSchema, org.apache.flink.table.catalog.ResolvedCatalogTable oldTable) Convert ALTER TABLE ADD | MODIFY (<schema_component> [, <schema_component>, ...])

Methods inherited from class java.lang.Object

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

Method Detail

convertAlterSchema

public org.apache.flink.table.operations.Operation convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableSchema alterTableSchema,
                                                                      org.apache.flink.table.catalog.ResolvedCatalogTable oldTable)

Convert ALTER TABLE ADD | MODIFY (<schema_component> [, <schema_component>, ...]) to generate an updated Schema.

convertAlterSchema

public org.apache.flink.table.operations.Operation convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableRenameColumn renameColumn,
                                                                      org.apache.flink.table.catalog.ResolvedCatalogTable oldTable)

Convert ALTER TABLE RENAME col_name to new_col_name to generate an updated Schema.

convertAlterSchema

public org.apache.flink.table.operations.Operation convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropColumn dropColumn,
                                                                      org.apache.flink.table.catalog.ResolvedCatalogTable oldTable)

Convert ALTER TABLE DROP (col1 [, col2, ...]) to generate an updated Schema.

convertAlterSchema

public org.apache.flink.table.operations.Operation convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropPrimaryKey dropPrimaryKey,
                                                                      org.apache.flink.table.catalog.ResolvedCatalogTable oldTable)

Convert ALTER TABLE DROP PRIMARY KEY to generate an updated Schema.

convertAlterSchema

public org.apache.flink.table.operations.Operation convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropConstraint dropConstraint,
                                                                      org.apache.flink.table.catalog.ResolvedCatalogTable oldTable)

Convert ALTER TABLE DROP CONSTRAINT constraint_name to generate an updated Schema.

convertAlterSchema

public org.apache.flink.table.operations.Operation convertAlterSchema(org.apache.flink.sql.parser.ddl.SqlAlterTableDropWatermark dropWatermark,
                                                                      org.apache.flink.table.catalog.ResolvedCatalogTable oldTable)

Convert ALTER TABLE DROP WATERMARK to generate an updated Schema.