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

DESCRIBE 语句 执行 DESCRIBE 语句 语法 DESCRIBE 语句 DESCRIBE 语句用于描述表或视图的 schema。 执行 DESCRIBE 语句 Java 可以使用 TableEnvironment 的 executeSql() 方法执行 DESCRIBE 语句。如果 DESCRIBE 操作执行成功，execu...

CREATE 语句 执行 CREATE 语句 CREATE TABLE Columns WATERMARK PRIMARY KEY PARTITIONED BY WITH Options LIKE AS select_statement CREATE CATALOG CREATE DATABASE CREATE VIEW ...

LIMIT 语句 LIMIT 语句 Batch LIMIT 子句限制 SELECT 语句返回的行数。 通常，此子句与 ORDER BY 结合使用，以确保结果是确定性的。 以下示例选择 Orders 表中的前 3 行。 SELECT * FROM Orders ORDER BY orderTime LIMIT 3

SET 语句 执行 SET 语句 Syntax SET 语句 SET 语句用于修改配置或展示配置。 执行 SET 语句 SQL CLI SET 语句可以在 SQL CLI 中执行。 以下示例展示了如何在 SQL CLI 中执行一条 SET 语句。 SQL CLI Flink SQL > SET 'table.local...

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

DESCRIBE 语句 执行 DESCRIBE 语句 语法 DESCRIBE 语句 DESCRIBE 语句用于描述表或视图的 schema。 执行 DESCRIBE 语句 Java 可以使用 TableEnvironment 的 executeSql() 方法执行 DESCRIBE 语句。如果 DESCRIBE 操作执行成功，execu...

ANALYZE 语句 执行 ANALYZE TABLE 语句 语法 ANALYZE 语句 ANALYZE 语句被用于为存在的表收集统计信息，并将统计信息写入该表的 catalog 中。当前版本中，ANALYZE 语句只支持 ANALYZE TABLE ， 且只能由用户手动触发。 注意 现在, ANALYZE TABLE 只支持批模式（Bat...

INSERT 语句 执行 INSERT 语句 将 SELECT 查询数据插入表中 语法 示例 将值插入表中 语法 示例 插入数据到多张表 语法 示例 INSERT 语句 INSERT 语句用来向表中添加行。 执行 INSERT 语句 Java 单条 INSERT 语句，可以使用 TableEnvironment 中的 ex...

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