流式 SQL
流式 SQL 支持基于共享内存表进行实时 SQL 查询和持续结果更新。用户可以声明表为流式 SQL 输入表,注册流式 SQL 查询,订阅实时结果,并管理查询的生命周期。该功能适合对实时行情、监控指标等数据进行低延迟分析。相关函数如下所示:
函数名 | 函数介绍 |
---|---|
declareStreamingSQLTable | 声明指定表为流式 SQL 输入表,只有被声明的表才能注册流式 SQL 查询。声明不会影响该表在普通 SQL 中的使用。 |
getStreamingSQLStatus | 查询流式 SQL 查询状态,支持查询单条或所有查询。管理员可查看所有用户查询。 |
listStreamingSQLTables | 列举当前用户声明的所有流式 SQL 表,管理员可查看所有用户声明。返回表包含表名、共享状态及声明用户列表。 |
registerStreamingSQL | 注册流式 SQL 查询,返回查询 ID,并自动生成结果变更日志流表。支持 SELECT、WHERE、JOIN(仅支持等值连接,且仅支持 ej、lj、rj、fj 类型)、ORDER BY 等关键字。 |
revokeStreamingSQL | 注销已注册的流式 SQL 查询。 |
revokeStreamingSQLTable | 注销之前声明的流式 SQL 表。注销前须先取消该表上的所有流式 SQL 查询订阅。只能注销当前用户声明的表。注销仅移除流式 SQL 功能,不删除表或数据。 |
subscribeStreamingSQL | 订阅指定流式 SQL 查询结果,订阅端执行查询并维护实时更新的共享结果表。 |
unsubscribeStreamingSQL | 取消订阅指定流式 SQL 查询结果,订阅端停止更新结果表。 |