VIP20
本课程属于：051-贷后预警实验评估 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink贷后预警实验评估实战教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与实验环境准备
Flink贷后预警业务背景 · 实验目标 · Flink集群搭建（Standalo…
课程导论实验环境准备
02
贷后预警数据模型设计
贷后数据实体关系（客户 · 贷款 · 还款计划
贷后预警数据模型…贷后数据实体关系
03
Flink DataStream API基础
Source（Kafka · MySQL CDC） · Transformation（map
FlinkDataStream
04
Flink Table & SQL API入门
动态表概念 · TableEnvironment创建 · Kafka流表定义
FlinkTable
05
贷后预警规则引擎设计
规则模型（规则ID · 条件表达式 · 阈值
贷后预警规则引擎…ID
06
基于CEP的复杂事件预警
Flink CEP API介绍 · Pattern定义（贷款逾期序列检测… · 匹配结果输出与告警
CEP基于
07
状态编程与容错机制
Keyed State（ValueS… · MapState）在预警累计次数中的… · Checkpoint与Savepoi…
状态编程容错机制
08
窗口计算与逾期聚合分析
Tumbling/Sliding/… · Watermark策略与迟到数据处理
窗口计算逾期聚合分析
09
多流关联与风险画像
Interval Join（客户信息… · Temporal Join（拉取最新… · Connect与CoProcessF…
多流关联风险画像
10
贷后预警指标计算
逾期率（DPD30+/DPD60+） · 不良率 · 回收率
贷后预警指标计算DPD30+/DPD60…
11
预警结果分级与处置策略
预警等级划分（红/橙/黄） · 处置动作映射（短信通知 · 人工催收
预警结果分级处置策略
12
实时特征工程
滑动窗口特征（近30天逾期次数） · 累计特征（总贷款余额） · 比率特征（还款/应还比）的Flink…
实时特征工程滑动窗口特征
13
模型评估指标体系
准确率 · 精确率 · 召回率
模型评估指标体系准确率
14
离线评估与在线评估对比
离线回放历史数据评估（Batch模式… · 在线实时评估（Streaming模式… · 评估结果存储与可视化
离线评估线评估对比
15
实验评估数据集构建
正负样本定义（逾期客户为正样本） · 时间戳对齐 · 训练集/测试集划分策略（时间序列切分…
实验评估数据集构…正负样本定义
16
Flink ML Pipeline集成
Flink ML库介绍 · 特征标准化 · OneHot编码
FlinkML
17
模型部署与在线推理
模型序列化（ModelSeriali… · Flink ProcessFunct… · 实时评分与阈值判定
模型部署线推理
18
A/B实验框架设计
实验分组（对照组/实验组） · 流量切分（Random Key Mo… · 指标对比（逾期率差异显著性检验）
A/B实验框架设计
19
预警延迟与吞吐量优化
算子链（Operator Chain… · 缓冲区调优 · 并行度调整
预警延迟吞吐量优化
20
数据质量监控与异常检测
字段完整性校验 · 值域校验 · 时间戳乱序检测
数据质量监控异常检测
21
多租户与业务隔离
租户ID路由 · 独立状态空间 · 资源队列隔离
多租户业务隔离
22
预警结果回写与闭环
Flink JDBC Sink写入M… · 回调接口触发处置动作 · 结果反馈流更新状态
预警结果回写闭环
23
可视化大屏集成
Flink实时数据推送到WebSoc… · ECharts实时图表展示（逾期趋势 · 预警分布）
可视化大屏集成Flink
24
灰度发布与回滚策略
Flink任务版本管理 · Savepoint恢复 · 蓝绿部署在预警任务中的应用
灰度发布回滚策略
25
安全与权限控制
Flink SQL RBAC · Kafka ACL · 数据脱敏（手机号/身份证号）
安全权限控制
26
性能压测与资源评估
使用Flink Benchmark工… · 模拟高并发贷款事件流 · CPU/内存/网络瓶颈分析
性能压测资源评估
27
故障演练与高可用
TaskManager宕机恢复 · Kafka Broker故障模拟 · ZooKeeper Leader选举…
故障演练高可用
28
贷后预警实验报告生成
实验参数记录（规则版本 · 模型版本） · 评估指标汇总
贷后预警实验报告…实验参数记录
29
端到端实战项目整合
从Kafka接入贷款事件 -> 规则…
端到端实战项目整…Kafka
30
课程总结与进阶方向
Flink 2.0新特性（自适应调度 · 动态表） · AI for FinTech（图神经…
课程总结进阶方向