首页
个人开发
工作相关
搜索
登录
搜索
colo
欲买桂花同载酒
累计撰写
1825
篇文章
累计收到
0
条评论
首页
栏目
首页
个人开发
工作相关
Flink
2025-12-12
设计基于Flink的金融交易欺诈检测系统:处理乱序事件与动态更新检测规则
实现要点:使用事件时间语义和Watermark机制处理乱序交易数据通过Keyed State存储用户交易行为画像(如滑动窗口统计)采用Broadcast State模式实现动态欺诈规则更新结合CEP库检测复杂模式(如短时间内多笔小额交易)使用两阶段提交确保端到端Exactly-Once语义
2025年-12月-12日
5 阅读
0 评论
Flink
2025-12-12
解释Flink中的事件时间(Event Time)与处理时间(Processing Time)的区别
事件时间(Event Time)和处理时间(Processing Time)是Flink中两种核心时间语义:事件时间:基于数据本身携带的时间戳(如日志生成时间)处理时间:基于Flink算子所在机器的系统时钟时间主要区别:事件时间能处理乱序事件,处理时间不能事件时间需要水位线(Watermark)机制处理时间延迟更低但结果不确定
2025年-12月-12日
4 阅读
0 评论
Flink