VIP20
本课程属于：082-支付风控策略批次偏移诊断 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

商户批次风险迁移：Flink实时诊断实践指南

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
商户批次风险迁移的背景 · 痛点与Flink实时诊断的价值
课程导论商户批次风险迁移…
02
风险迁移基础概念
什么是批次风险 · 迁移策略 · 实时与离线对比
风险迁移基础概念什么是批次风险
03
Flink核心概念速览
DataStream · 算子 · 状态
Flink核心概念速览
04
商户批次数据模型设计
商户维度表 · 批次流水表 · 风险标签表的设计原则
商户批次数据模型…商户维度表
05
Flink开发环境搭建
JDK · Maven · Flink集群
Flink开发环境搭建
06
第一个Flink实时诊断作业
读取Kafka商户批次事件流 · 简单过滤与打印
Flink第一个
07
Source连接器实战
Kafka Source配置 · 反序列化 · 起始消费位置策略
Source连接器实战
08
Sink连接器实战
写入MySQL/ClickHouse · Exactly-Once语义保证
Sink连接器实战
09
状态编程基础
ValueState · ListState · MapState在商户画像中的应用
状态编程基础ValueState
10
KeyedProcessFunction深度解析
定时器 · 状态清理与商户批次超时检测
KeyedProcess…深度解析
11
Watermark与乱序处理
设置Watermark策略 · 处理延迟到达的批次事件
Watermark乱序处理
12
窗口计算在风险迁移中的应用
Tumbling/Sliding窗口… · 失败率
窗口计算风险迁移
13
侧输出流（Side Output）
分离正常批次与异常批次 · 分流处理
SideOutput
14
广播状态模式
动态加载风控规则 · 实时更新商户风险阈值
广播状态模式动态加载风控规则
15
多流关联（Join）
商户批次流与商户档案流实时关联 · 丰富风险上下文
Join多流关联
16
复杂事件处理（CEP）
检测商户批次连续失败 · 金额突增等风险模式
CEP复杂事件处理
17
Flink SQL在批次风险分析中的应用
创建动态表 · 执行连续查询
FlinkSQL
18
Checkpoint与Savepoint机制
配置 · 调优与迁移恢复实战
CheckpointSavepoint
19
状态后端选择与优化
RocksDB · HashMap状态后端对比与生产配置
状态后端选择优化
20
Flink作业性能调优
并行度 · 内存 · 网络缓冲
Flink作业性能调优
21
监控与告警体系
集成Prometheus+Grafa… · 自定义风险指标监控
监控告警体系
22
日志与异常诊断
Flink日志级别 · 错误栈分析 · 常见运行时异常排查
日志异常诊断
23
数据倾斜处理
Key分布不均导致的热点问题及解决方…
数据倾斜处理Key
24
端到端一致性保障
从Kafka到Sink的Exactl…
端到端一致性保障Kafka
25
灰度发布与版本管理
Flink作业的滚动升级 · 状态兼容性处理
灰度发布版本管理
26
商户批次风险迁移全流程案例
从数据接入到风险评分输出
商户批次风险迁移…从数据接入到风险…
27
实时特征工程
基于Flink计算商户历史批次均值 · 标准差 · Z-score
实时特征工程Flink
28
机器学习模型集成
在Flink中调用PMML/ONNX…
机器学习模型集成Flink
29
生产环境踩坑实录
常见问题 · 解决方案与最佳实践总结
生产环境踩坑实录常见问题
30
课程总结与展望
实时风控的未来趋势 · Flink与AI融合方向
课程总结实时风控的未来趋…