iceberg-flink 八：累积窗口使用。（CUMULATE）

朱雀 2024-03-31 10:30 57阅读 0赞

## 一：为什么出现累计窗口（CUMULATE） ##

在flink中有滑动窗口，滚动窗口，会话窗口。前俩者是公司常用的，他们统计的是某个时间段内的数据。但是我们有些时候，有需求，求每一天，从当天0：00开始，进行计算，例如：双十一，统计当天的销售额度。遇到这种需求，前俩者解决此类问题会比较麻烦。所以在新版本的flink当中，开源了CUMULATE窗口。

## 二：CUMULATE是什么窗口。 ##

可以将CUMULATE窗口看作是升级版本的滚动窗口。将某一时间段内滚动窗口求出的值进行累加。

## 三：怎么使用？ ##

SELECT 
        cast(PROCTIME() as timestamp_ltz) as window_end_time,
        manufacturer_name,
        event_id,
        case when state is null then -1 else state end ,
        cast(sum(agg)as string ) as agg
    FROM TABLE(CUMULATE(
           TABLE dm_cumulate
           , DESCRIPTOR(ts1)
           , INTERVAL '5' MINUTES
           , INTERVAL '1' DAY(9)))
    GROUP BY
              window_end
             ,window_start
             ,manufacturer_name
             ,event_id
             ,case when state is null then -1 else state end

### 1 . 注意点一 ###

CUMULATE 共有四个参数。  
第一个 table 表名。  
第二个 时间字段。  
第三个 累计的步长。  
第四个 累计的时间。  
注：第四个参数，如果写1 day，那么就是从今天的0：00到今晚24：00 进行统计，明天开始，又会从新的0：00开始统计。  
如果写2，或者更多，意味着从前俩天开始一直统计。在0：00的时候，会继续进行累加。

发表评论取消回复

表情：

评论列表（有 0 条评论，57人围观）

还没有评论，来说两句吧...

相关阅读

相关 nginx使用累积

.nginx 域名访问指向 index.html，添加如下配置即可 location = / \{ index index.html; \} 2.如果 upstrea...

雨点打透心脏的1/2处/ 2024年04月19日 12:41/ 0 赞/ 42 阅读

相关 iceberg-flink 八：累积窗口使用。（CUMULATE）

一：为什么出现累计窗口（CUMULATE）在flink中有滑动窗口，滚动窗口，会话窗口。前俩者是公司常用的，他们统计的是某个时间段内的数据。但是我们有些时候，有需求，求

朱雀/ 2024年03月31日 10:30/ 0 赞/ 58 阅读

相关大数据Flink（七十六）：SQL的渐进式窗口（CUMULATE）

![157f466d8173410dac58546dc0a0cdee.jpeg][] 文章目录 SQL的渐进式窗口（CUMULATE） -----------------

向右看齐/ 2023年10月15日 20:06/ 0 赞/ 35 阅读

相关 java Flink（八）窗口模式之时间窗口增量聚合以及全窗口模式计算

窗口模式简述：可以把无限的数据流进行切分为有线流的一种方式，它会将流数据分发到有限大小桶中进行分析。类型：时间窗口：按照时间段进行分桶，例如 8点-9点，9点-

╰+攻爆jí腚メ/ 2022年11月15日 15:55/ 0 赞/ 182 阅读

相关使用mysql 注意点累积

1.今天遇到一个问题，有一个实体，其中他有一个字段为values 结果报错。。。mysql 数据库字段不能为values 否则会报错后续累积自己在开发

- 日理万妓/ 2022年09月18日 15:42/ 0 赞/ 176 阅读

相关 struts2标签累积

<s:iterator 标签一定是针对集合对象这里的集合可以是set list a.set集合遍历假设set 集合为 \{1,2,3,4,5\} <s:iterat

喜欢ヅ旅行/ 2022年09月17日 13:16/ 0 赞/ 210 阅读

相关 css 元素累积点滴

(1).padding是内边距的意思，是内容区到边框之间的距离，一个框架有4各部分，由内到外依次是：内容区，内边距（padding）,边框(border),外边距(margin

ゝ一世哀愁。/ 2022年09月17日 11:18/ 0 赞/ 179 阅读

相关 linux指令-新人累积

查看进程:ps \-ef| grep tomcat (清理不必要的进程) 系统内存使用情况: free -m 冻结当前进程: sync 手工释放进程: echo

深藏阁楼爱情的钟/ 2022年08月18日 12:15/ 0 赞/ 150 阅读

相关 hive累积报表hql

问题：下面是一个员工的业绩数据，数据格式是username,date,money,数据如下 A,2015-01,5 A,2015-01,15 B,20

古城微笑少年丶/ 2022年06月01日 11:49/ 0 赞/ 182 阅读

相关 MySQL经验累积

1，尽可能地少进行连表查询。如果一定要进行连表查询，一定要消除笛卡儿积现象。对于MySQL是小表在前大表在后，Oracle是大表在前小表在后，并且这个相等字段一定要

系统管理员/ 2022年05月23日 06:43/ 0 赞/ 190 阅读