VIP20
本课程属于：070-量化策略回测坏账率哨兵 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink实时流处理回测坏账率哨兵教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与业务背景
坏账率定义 · 实时风控哨兵概念 · Flink在金融风控中的价值
课程导论业务背景
02
Flink核心概念速览
DataStream · Event Time · Processing Time
Flink核心概念速览
03
开发环境搭建
JDK · Maven · Flink集群（Standalone…
开发环境搭建JDK
04
第一个Flink流处理程序
WordCount变体——实时交易计… · 理解Source/Transform…
Flink第一个
05
数据源接入实战
Kafka Source配置 · 反序列化器 · 消费偏移量管理
数据源接入实战Kafka
06
数据模型与POJO定义
交易事件类（TransactionE… · 序列化与反序列化
POJO数据模型
07
坏账率核心指标计算
滑动窗口内坏账交易数/总交易数 · 使用SQL或DataStream A…
坏账率核心指标计…滑动窗口内坏账交…
08
Watermark与乱序处理
设置Watermark策略 · 处理延迟数据 · allowedLateness
Watermark乱序处理
09
状态后端与精确一次语义
RocksDB状态后端配置 · Checkpointing设置 · 端到端Exactly-Once
状态后端精确一次语义
10
KeyedProcessFunction高级应用
自定义定时器 · 状态管理 · 动态规则加载
KeyedProcess…高级应用
11
动态规则引擎设计
从外部配置中心（如Nacos/Zoo…
动态规则引擎设计Nacos/Zoo
12
Side Output分流
将正常交易与疑似坏账交易分流到不同侧…
SideOutput
13
复杂事件处理（CEP）
使用Flink CEP库定义坏账模式…
CEP复杂事件处理
14
实时回测框架设计
历史数据回放（Kafka重放） · 模拟时间推进 · 结果对比
实时回测框架设计Kafka
15
回测指标计算
准确率 · 召回率 · F1-score
回测指标计算准确率
16
哨兵告警机制
阈值触发告警 · 告警级别（INFO/WARN/CRI… · 告警去重
哨兵告警机制阈值触发告警
17
告警通道集成
钉钉/企业微信Webhook · 邮件 · 短信（阿里云SMS）
告警通道集成Webhook
18
Flink SQL在坏账分析中的应用
CREATE TABLE · TUMBLE/HOP窗口 · GROUP BY
FlinkSQL
19
维表关联（AsyncIO）
实时关联用户画像 · 黑名单等外部维度数据
AsyncIO维表关联
20
性能调优
并行度设置 · 算子链 · 缓冲区调优
性能调优并行度设置
21
内存管理与GC优化
Heap/Off-Heap配置 · Flink内存模型 · 避免Full GC
GC内存管理
22
监控与告警体系
Prometheus + Grafa… · 自定义Metrics
监控告警体系
23
日志采集与链路追踪
SLF4J + Logback · 接入ELK · TraceId传递
日志采集链路追踪
24
容错与恢复
Savepoint机制 · 从Savepoint重启 · 作业升级
容错恢复
25
多环境部署
开发/测试/生产环境配置分离 · Docker化部署
多环境部署开发
26
单元测试与集成测试
Flink Test Harness · Mock数据源 · 验证算子逻辑
单元测试集成测试
27
数据湖集成
将回测结果写入Iceberg/Hud… · 支持离线分析
数据湖集成Iceberg/Hud
28
A/B实验平台
同时运行多个规则版本 · 对比坏账率与误报率
A/B实验平台
29
生产案例实战
某金融公司坏账率从2%降至0.5%的…
生产案例实战某金融公司坏账率…
30
课程总结与未来展望
Flink 2.0新特性 · AI辅助风控 · 实时数仓融合趋势
课程总结未来展望