持续查询-阿里云帮助中心_(Lindorm)-阿里云帮助中心

本文介绍如何在流引擎中持续查询数据。

背景信息

持续查询（Continuous Query）是基于流表的实时计算，它的基本处理模型如下图所示。

Source表示数据源头的流表，Operator表示计算逻辑，Sink表示存储计算结果的结果表。每当源头的流表有数据插入，就会触发Operator进行计算，并将计算结果写入至Sink表中。

使用示例

CREATE CQ cq_name
INSERT INTO sink_table
SELECT
  user,
  TUMBLE_START(order_time, INTERVAL '1' DAY) AS wStart,
  SUM(amount) 
FROM source_stream
GROUP BY
  TUMBLE(order_time, INTERVAL '1' DAY), user;

参数说明

参数	是否必填	说明
cq_name	是	持续查询的唯一标识。
sink_name	是	宽表引擎中创建的结果表（Sink表），用于存储计算结果。如何创建，请参见创建结果表。
source_stream	是	流引擎中创建的流表（Source表）。