文档

持续查询

更新时间:

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

背景信息

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

image

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表)。