全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

解释Flink中的Dynamic Tables概念

提问者：帅平问题分类：面试刷题

Flink面试题 Flink

发布于：1个月前 (05-16) IP属地：

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属地：

我来回答