问答 2024-10-28 来自:开发者社区

Flink sql 累计历史订单金额

使用的是Flink + hologres 有个业务场景,想统计订单表的累计金额,并且要根据累计金额计算实际收入,实际收入的公式为: (如果累计金额小于100万)实际收入 = 累计金额的85% (如果累计金额大于等于100万)实际收入 = 1000000 * 85% + 超出100万部分的 70% 然后要求结果实时计算,初步想法是用CUMULATE窗口,但不知道该如何实现,CUMULATE累计当.....

文章 2024-08-22 来自:开发者社区

Flink SQL 在快手实践问题之使用Dynamic Cumulate Window绘制直播间累计UV曲线如何解决

问题一:CUMULATE窗口函数相比传统方案有哪些优点? CUMULATE窗口函数相比传统方案有哪些优点? 参考回答: CUMULATE窗口函数的优点包括使用窗口结束时间作为横坐标,确保每个点的纵坐标是对应时间点的累计值,使曲线在回溯历史或作业failover时都能完全还原,且分维度值相加等于总维度值;同时,使用两阶段聚合防止distinct key倾...

Flink SQL 在快手实践问题之使用Dynamic Cumulate Window绘制直播间累计UV曲线如何解决
问答 2024-08-02 来自:开发者社区

flink 累计重启如何排查问题?

flink 累计重启如何排查问题?

问答 2024-07-26 来自:开发者社区

在Flink CDC中使用窗口去重然后进行累计求和计算,输出的求和结果会出现跳变,为什么?

在Flink CDC中使用窗口去重然后进行累计求和计算,输出的求和结果会出现跳变,为什么?请参考图片:

问答 2024-07-23 来自:开发者社区

如何在Flink SQL中使用Dynamic Cumulate Window绘制直播间累计UV曲线?

如何在Flink SQL中使用Dynamic Cumulate Window绘制直播间累计UV曲线?

问答 2024-06-12 来自:开发者社区

Flink 统计周期内累计值CUMULATE函数

Flink 统计周期内累计值CUMULATE函数

问答 2024-03-11 来自:开发者社区

flink cdc重启策略,3次指的是累计三次还是连续3次?

flink cdc重启策略,3次指的是累计三次还是连续3次,在生产上前三次重启都成功了,第四次失败了。

问答 2023-09-19 来自:开发者社区

有没有用flink计算过历史累计数据?

有没有大佬用flink计算过历史累计数据?

问答 2023-05-28 来自:开发者社区

能用Flink SQL cumulate window计算当天每来一笔交易累计当天交易额么?

能用Flink SQL cumulate window计算当天每来一笔交易累计当天交易额么?

问答 2023-03-08 来自:开发者社区

请问flink 1.14 版本 ,按照官方文档杀掉重启,觉状态还是从头开始累计。是为什么?

请问flink 1.14 版本 ,按照官方文档,杀掉重启,感觉状态还是从头开始累计,而且那个 hdfs 目录 下面的 taskowned 是空的 这是为什么?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注