Discard语句 Discard语句 Example: proc p ( x , y : int ): int = result = x + y discard p ( 3 , 4 ) # 丢弃 `p` 的返回值 discard 语句评估其表达式的副作用并将表达式的结果值丢弃，其应在已知忽略此值...

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

JAR 语句 执行 JAR 语句 ADD JAR 限制 SHOW JARS REMOVE JAR JAR 语句 JAR 语句用于将用户 jar 添加到 classpath、或将用户 jar 从 classpath 中删除或展示运行时 classpath 中添加的 jar。 目前 Flink SQL 支持以下 JAR 语句： ADD JA...

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

DESCRIBE 语句 执行 DESCRIBE 语句 语法 DESCRIBE TABLE DESCRIBE CATALOG DESCRIBE JOB DESCRIBE 语句 DESCRIBE 语句用于描述表或视图的 schema，或catalog 的元数据，或 Flink 集群上的指定作业。 执行 DESCRIBE 语句 Java 可...

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

LOAD 语句 执行 LOAD 语句 LOAD MODULE LOAD 语句 LOAD 语句用于加载内置的或用户自定义的模块。 执行 LOAD 语句 Java 可以使用 TableEnvironment 的 executeSql() 方法执行 LOAD 语句。如果 LOAD 操作执行成功，executeSql() 方法会返回 ‘OK’...

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

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

脚本语句 注释 声明 POS DO IF-THEN-ELSEIF-THEN-ELSE 脚本语句 这些语句在对象编程编辑器的左栏中。这些语句执行 Neuron 程序的表达。语句右边一列的所有内容（如果没有新的语句，则在下一行）都属于这个语句。 注释 这句话对系统没有任何意义。这只是对操作者的注释。它也可以用来暂时删除其他语句，以避免某些操作...