我想实现这样一个功能：统计每天处理的数据量，并写到redis中
1条回答 默认 最新
- 2022-05-27 11:19回答 1 已采纳 当10:14:51的数据来之前，流中最大的事件时间 >= 10:24:50(窗口结束时间) + watermark延迟时间 + 允许延迟时间 ，导致当前waterMark 的值更新为 这个最大的
- 2022-04-24 10:13回答 1 已采纳 多个节点，同时获取到了数据，几个节点就有几次
- 2023-03-07 15:49回答 4 已采纳 Flink 在启动任务的时候，创建输入分片时发生了错误，导致无法启动任务。你需要检查一下程序中读取文件的代码是否正确，文件路径是否正确，文件是否存在，并且当前用户是否有访问该文件的权限。如果需要，可以
- 2022-12-09 21:10力不竭!!!战不止!!!的博客 其中最常见的场景，就是窗口聚合计算。之前我们已经了解了 Flink 中基本的聚合操作。在流处理中，我们往往需要面对的是连续不断、无休无止的无界流，不可能等到所有所有数据都到齐了才开始处理。所以聚合计算其实...
- 2023-03-28 20:55回答 2 已采纳 对于时间窗口，开始时间和结束时间的计算方式如下： 滚动时间窗口：按照固定的时间长度对数据进行分组，窗口的大小和滑动步长相同，例如，5秒的滚动窗口，每5秒钟计算一次。开始时间为当前窗口大小的整数倍，结束
- 2023-03-05 21:39回答 1 已采纳 你把全部报错复制到记事本发给我
- 2023-02-01 10:55回答 4 已采纳 题主的思路完全正确可行，因为我就是这么做的。也是一开始觉得不是很正规，但确实能解决实际的业务问题，要相信自己。 梳理一下BaseJar：丢到linux服务器上，用来解析Flink SQL语句MySQ
- 2023-11-06 14:42在我们日常使用flink这个框架的过程中，我们会经常使用到窗口，让我们通过下面这篇...想要更加方便高效地处理无界流，其中的一种方式是将无限数据切割成有限的“数据块”进行处理，这就是所谓的“窗口”（Window）。
- 2021-08-03 10:23回答 1 已采纳 超过00:00的数据如果不需要，直接放入测流就好。不管是后续使用还是丢掉。或者本身就有时间字段，直接加filter算子过滤不参与flink计算就好。
- 2022-02-09 15:08回答 2 已采纳 在这里：https://github.com/apache/flink/tree/69d9fade5b0e3629c84548c06f0624e9e66fdefe/flink-connectors/f
- 2022-08-11 17:52回答 1 已采纳 两个JDBC的维表加上主键定义PRIMARY KEY (sf_id) NOT ENFORCED
- 2022-09-03 20:15@SmartSi的博客 在之前的文章中我们已经了解了 Flink 的，并介绍了其中涉及的组件：WindowAssigner、WindowFunction、Trigger、Evictor。在中我们知道可以通过不同类型的窗口分配器 WindowAssigner 将元素分配到窗口中。在指定 ...
- 2021-07-16 14:22回答 1 已采纳 OutputTag获取迟到数据，二次消费
- 2022-02-19 02:37bone_ds的博客 1.Flink窗口的概念 窗口（window）就是将无限流切割为有限流的一种方式，它会将流数据分发到有限大小的桶（bucket）中进行分析 2.Flink的窗口分类 其实, 在用window前首先需要确认应该是在keyBy后的流上用, 还是在...
- 2022-05-25 08:00百思不得小赵的博客 Flink 提供了通用的 WindowAssigner：滚动窗口（tumbling window）、滑动窗口（sliding window）、 会话窗口（session window）、全局窗口（global window） 代码如下： public class WindowTest1_TimeWindow { ...
- 没有解决我的问题, 去提问
悬赏问题
- ¥15 delta降尺度计算的一些细节，有偿
- ¥15 Arduino红外遥控代码有问题
- ¥15 数值计算离散正交多项式
- ¥30 数值计算均差系数编程
- ¥15 redis-full-check比较 两个集群的数据出错
- ¥15 Matlab编程问题
- ¥15 训练的多模态特征融合模型准确度很低怎么办
- ¥15 kylin启动报错log4j类冲突
- ¥15 超声波模块测距控制点灯，灯的闪烁很不稳定，经过调试发现测的距离偏大
- ¥15 import arcpy出现importing _arcgisscripting 找不到相关程序