CREATE TAG DROP TAG ALTER TAG SHOW TAGS DESCRIBE TAG DELETE TAG 增加和删除标签

INSERT VERTEX DELETE VERTEX UPDATE VERTEX UPSERT VERTEX

ADD COLUMN ADD INDEX ADMIN ADMIN CANCEL DDL ADMIN CHECKSUM TABLE ADMIN CHECK [TABLE|INDEX] ADMIN SHOW DDL [JOBS|QUERIES] ADMIN SHOW TELEMETRY ALTER DATABASE ALTER INDEX ...

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

ALTER 语句 执行 ALTER 语句 ALTER TABLE ALTER VIEW ALTER DATABASE ALTER FUNCTION ALTER 语句 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句： ALTER TABLE ALTER...

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

表规格 语法定义 使用场景 查询表 按历史状态过滤 表规格 eKuiper 流是无界且不可变的，任何新数据都会附加到当前流中进行处理。 Table 用于表示流的当前状态。它可以被认为是流的快照。用户可以使用 table 来保留一批数据进行处理。 在 eKuiper 中不允许单独使用表格。仅建议与流进行 join 操作。join 流时，表格将...

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

INSERT VERTEX DELETE VERTEX UPDATE VERTEX UPSERT VERTEX