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

JOB Statements 执行 JOB 语句 SHOW JOBS STOP JOB JOB Statements Job 语句用于管理作业的生命周期。 目前 Flink SQL 支持以下 JOB 语句： SHOW JOBS STOP JOB 执行 JOB 语句 SQL CLI 以下示例展示如何在 SQL CLI 中执行 JOB...

SHOW 语句 执行 SHOW 语句 SHOW CATALOGS SHOW CURRENT CATALOG SHOW DATABASES SHOW CURRENT DATABASE SHOW TABLES SHOW TABLES 示例 SHOW CREATE TABLE SHOW COLUMNS SHOW COLUMNS 示例 SHOW ...

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

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

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

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

ORDER BY 语句 ORDER BY 语句 Batch Streaming ORDER BY 子句使结果行根据指定的表达式进行排序。 如果两行根据最左边的表达式相等，则根据下一个表达式进行比较，依此类推。 如果根据所有指定的表达式它们相等，则它们以与实现相关的顺序返回。 在流模式下运行时，表的主要排序顺序必须按时间属性 升序。 所有后续的 o...

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...