Flink sql alter table.

Flink sql alter table The following SQL changes nullability of column Now, I want to ALTER this table, by adding a new column. ALTER 语句 # ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句： ALTER TABLE ALTER VIEW ALTER DATABASE ALTER FUNCTION 执行 ALTER 语句 # Java 可以使用 TableEnvironment 中的 executeSql() 方法执行 ALTER 语句。 若 ALTER 操作执行成功，executeSql() 方法返回 ‘OK’，否则会抛出 For sql-gateway, you can add the option table. Flink 1. This documentation is for an out-of-date version of Apache Flink. A Table can be used in subsequent SQL and Table API queries, be converted into a DataStream, or written to a TableSink. Altering Tables # Changing/Adding Table Properties # The following SQL sets write-buffer-size table property to 256 MB. ALTER 语句 # ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句： ALTER TABLE ALTER VIEW ALTER DATABASE ALTER FUNCTION 执行 ALTER 语句 # Java 可以使用 TableEnvironment 中的 executeSql() 方法执行 ALTER 语句。 若 ALTER 操作执行成功，executeSql() 方法返回 ‘OK’，否则会抛出 Altering Tables # Changing/Adding Table Properties # The following SQL sets write-buffer-size table property to 256 MB. col. Flink ALTER TABLE my_table SET ( 'write-buffer-size' = '256 MB' ); Spark3 ALTER TABLE my_table SET TBLPROPERTIES ( 'write-buffer-size' = '256 MB' ); Rename Table Name # The following SQL rename the table name to new name. You can use both Flink SQL and the Table API in your applications. kjc skz arpse ngwns rgt zur pgcg xrvzrdu uobwc patj umjhacp niuv kuxn dfk sihnon