1 个回答
完整的事件事件处理流程代码示例如下:
-- 1. 定义表(带事件时间和水印)
CREATE TABLE user_events (
user_id STRING,
event_time TIMESTAMP(3),
WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND
) WITH (...);
-- 2. 执行窗口聚合
SELECT
TUMBLE_START(event_time, INTERVAL '10' MINUTE) AS window_start,
COUNT(*) AS events_count
FROM user_events
GROUP BY TUMBLE(event_time, INTERVAL '10' MINUTE);
发布于:3周前 (05-16) IP属地:
我来回答
您需要 登录 后回答此问题!