ALTER 语句 执行 ALTER 语句 ALTER TABLE ADD MODIFY DROP RENAME SET RESET ALTER VIEW ALTER DATABASE ALTER FUNCTION ALTER 语句 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink S...

UPDATE 语句 执行更新语句 语法 UPDATE 语句 UPDATE 语句可以用于根据条件更新表的数据。 注意 目前, UPDATE 语句仅支持批模式, 并且要求目标表实现了 SupportsRowLevelUpdate 接口。 如果在一个没有实现该接口的表上执行 UPDATE ，则会抛异常。目前 Flink 内置的连接器还没有实现该接...

TRUNCATE 语句 执行 TRUNCATE 语句 语法 TRUNCATE 语句 Batch TRUNCATE 语句用于删除表中的全部数据，但不会删除表本身。 注意 目前, TRUNCATE 语句仅支持批模式, 并且要求目标表实现了 SupportsTruncate 接口。 如果在一个没有实现该接口的表上执行 TRUNCATE 语句，则...

DROP 语句 执行 DROP 语句 DROP CATALOG DROP TABLE DROP DATABASE DROP VIEW DROP FUNCTION DROP 语句 DROP 语句可用于删除指定的 catalog，也可用于从当前或指定的 Catalog 中删除一个已经注册的表、视图或函数。 Flink SQL 目前支持以下 ...

Call Statements Run a CALL statement Syntax Call Statements Call 语句用来调用存储过程。存储过程通常是用来执行一些数据操作和管理任务的。 注意 目前 Call 语句要求被调用的存储过程在对应的 Catalog 中。所以，在调用存储过程前，请确保该存储过程在对应的 Catalog ...

RESET 语句 执行 RESET 语句 Syntax RESET 语句 RESET 语句用于将配置重置为默认值。 执行 RESET 语句 SQL CLI RESET 语句可以在 SQL CLI 中执行。 以下示例展示了如何在 SQL CLI 中执行一条 RESET 语句。 SQL CLI Flink SQL > RES...

UNLOAD 语句 执行 UNLOAD 语句 UNLOAD MODULE UNLOAD 语句 UNLOAD 语句用于卸载内置的或用户自定义的模块。 执行 UNLOAD 语句 Java 可以使用 TableEnvironment 的 executeSql() 方法执行 UNLOAD 语句。如果 UNLOAD 操作执行成功，executeS...

USE 语句 运行一个 USE 语句 USE CATALOG USE MODULES USE USE 语句 USE 语句用来设置当前的 catalog 或者 database。 运行一个 USE 语句 Java 可以使用 TableEnvironment 中的 executeSql() 方法执行 USE 语句。 若 USE 操作执行...

EXPLAIN 语句 执行 EXPLAIN 语句 ExplainDetails 语法 EXPLAIN 语句 EXPLAIN 语句用于解释 query 或 INSERT 语句的执行逻辑，也用于优化 query 语句的查询计划。 执行 EXPLAIN 语句 Java 可以使用 TableEnvironment 的 executeSql() ...

其他语句 其他语句 锁操作 游标操作