我想实现这样一个功能：统计每天处理的数据量，并写到redis中
1条回答 默认 最新
相关推荐 更多相似问题
- 2022-05-27 11:19回答 1 已采纳 当10:14:51的数据来之前，流中最大的事件时间 >= 10:24:50(窗口结束时间) + watermark延迟时间 + 允许延迟时间 ，导致当前waterMark 的值更新为 这个最大的
- 2023-03-07 15:49回答 4 已采纳 Flink 在启动任务的时候，创建输入分片时发生了错误，导致无法启动任务。你需要检查一下程序中读取文件的代码是否正确，文件路径是否正确，文件是否存在，并且当前用户是否有访问该文件的权限。如果需要，可以
- 2022-04-24 10:13回答 1 已采纳 多个节点，同时获取到了数据，几个节点就有几次
- 2022-12-09 21:10力不竭!!!战不止!!!的博客 其中最常见的场景，就是窗口聚合计算。之前我们已经了解了 Flink 中基本的聚合操作。在流处理中，我们往往需要面对的是连续不断、无休无止的无界流，不可能等到所有所有数据都到齐了才开始处理。所以聚合计算其实...
- 2022-05-25 08:00百思不得小赵的博客 Flink 提供了通用的 WindowAssigner：滚动窗口（tumbling window）、滑动窗口（sliding window）、 会话窗口（session window）、全局窗口（global window） 代码如下： public class WindowTest1_TimeWindow { ...
- 没有解决我的问题, 去提问
