VIP20
本课程属于：003-实时交易风控训练集切分 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

交易风控样本切分与Flink实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风控样本概述
交易风控样本的定义 · 样本在风控模型中的重要性 · 样本生命周期管理
风控样本概述交易风控样本的定…
02
样本切分基础
训练集/验证集/测试集划分原则 · 时间序列切分与随机切分的区别
样本切分基础训练集
03
Flink环境搭建
Flink集群安装 · Flink开发环境配置 · Flink作业提交方式
Flink环境搭建
04
Flink DataStream API入门
Source · Transformation · Sink核心算子详解
FlinkDataStream
05
Flink Table & SQL入门
动态表概念 · 流式SQL查询 · 与DataStream互转
FlinkTable
06
Flink状态管理
Keyed State与Operat… · 状态后端配置 · 状态TTL
Flink状态管理
07
Flink时间语义与Watermark
EventTime/Processi… · Watermark生成策略
FlinkWatermark
08
Flink Checkpoint与容错
Checkpoint原理 · Exactly-Once语义 · Savepoint使用
FlinkCheckpoint
09
交易数据实时接入
Kafka Source连接器配置 · JSON/AVRO反序列化 · Schema Registry集成
交易数据实时接入Kafka
10
交易数据预处理
字段清洗 · 缺失值填充 · 异常值过滤
交易数据预处理字段清洗
11
特征工程基础
交易金额 · 频次 · 设备指纹
特征工程基础交易金额
12
滑动窗口特征计算
使用Flink滑动窗口计算过去1小时…
滑动窗口特征计算Flink
13
会话窗口特征计算
基于用户行为的会话切分 · 会话内特征聚合
会话窗口特征计算基于用户行为的会…
14
样本标签生成
逾期标签 · 欺诈标签 · 正常标签的定义与延迟标注策略
样本标签生成逾期标签
15
样本时间对齐
特征时间窗口与标签时间点的对齐逻辑 · 避免未来信息泄露
样本时间对齐特征时间窗口
16
样本正负样本均衡
过采样 · 欠采样 · SMOTE在Flink中的实现思路
样本正负样本均衡过采样
17
样本切分策略一
基于时间戳的严格时序切分（训练集<验…
样本切分策略一基于时间戳的严格…
18
样本切分策略二
基于用户ID的哈希切分（保证同一用户…
样本切分策略二ID
19
样本切分策略三
分层抽样切分（按交易金额/地区分层保…
样本切分策略三分层抽样切分
20
样本切分策略四
滑动窗口交叉验证（时间序列交叉验证在…
样本切分策略四滑动窗口交叉验证
21
样本存储与版本管理
将切分后的样本写入HDFS/OSS · 记录样本元数据与版本号
样本存储版本管理
22
Flink CEP复杂事件处理
定义欺诈模式（如短时间内高频交易） · 输出风险事件
FlinkCEP
23
实时特征存储
将计算好的特征写入Redis/All… · 供在线推理使用
实时特征存储Redis/All
24
Flink与模型推理集成
使用PMML/ONNX模型在Flin…
Flink模型推理集成
25
样本管道监控
监控样本生成延迟 · 数据倾斜 · 特征缺失率等关键指标
样本管道监控监控样本生成延迟
26
Flink作业性能调优
并行度设置 · 算子链优化 · 反压处理
Flink作业性能调优
27
端到端样本管道实战
从Kafka消费→特征计算→标签对齐…
端到端样本管道实…Kafka
28
样本质量评估
切分后各集合的分布一致性检验（KS检… · PSI指标）
样本质量评估KS
29
A/B测试与样本回溯
使用历史样本回测模型效果 · 对比不同切分策略
A/B测试
30
课程总结与最佳实践
常见踩坑点 · 生产环境部署建议 · 未来演进方向
课程总结最佳实践