1 个回答
Dynamic Tables(动态表) 是流数据处理的核心抽象,用于统一批处理和流处理的语义。使用上例如:
#事实统计每小时的销售额
CREATE TABLE orders (
product_id STRING,
amount DOUBLE,
ts TIMESTAMP(3),
WATERMARK FOR ts AS ts - INTERVAL '5' SECOND
) WITH (...);
-- 动态表上的持续查询
SELECT
TUMBLE_START(ts, INTERVAL '1' HOUR) AS window_start,
SUM(amount) AS total_amount
FROM orders
GROUP BY TUMBLE(ts, INTERVAL '1' HOUR);
发布于:1个月前 (05-16) IP属地:
我来回答
您需要 登录 后回答此问题!