解释Flink中的Dynamic Tables概念

提问者:帅平 问题分类:面试刷题
解释Flink中的Dynamic Tables概念
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属地:
我来回答