游客发表

Flink SQL知其所以然:大家都用 Cumulate Window 计算累计指标啦

发帖时间:2025-11-04 23:55:55

Flink SQL知其所以然:大家都用 Cumulate Window 计算累计指标啦
复制SELECT UNIX_TIMESTAMP(CAST(window_end AS STRING)) * 1000 as window_end,知其指标         window_start,         sum(money) as sum_money,        count(distinct id) as count_distinct_id  FROMTABLE(CUMULATE(           TABLE source_table           , DESCRIPTOR(row_time)           , INTERVAL 60SECOND          , INTERVAL 1DAY))  GROUPBY window_start,           window_end  1.2.3.4.5.6.7.8.9.10.11.

    热门排行

    友情链接