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

Flink实时风控特征工程实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与风控概述
实时风控业务背景 · 特征工程在风控中的价值 · 课程整体架构与学习路径
课程导学风控概述
02
Flink开发环境搭建
JDK · Maven · Flink集群安装与配置
Flink开发环境搭建
03
Flink核心概念速通
DataStream API · 时间语义 · 窗口机制
Flink核心概念速通
04
风控数据源接入
Kafka数据源配置 · 自定义Source · 数据格式解析（JSON/CSV/Av…
风控数据源接入Kafka
05
实时数据清洗与预处理
空值处理 · 字段类型转换 · 异常值过滤
实时数据清洗预处理
06
基础统计特征计算
计数 · 求和 · 均值
基础统计特征计算计数
07
时间窗口特征工程
滚动窗口 · 滑动窗口 · 会话窗口在风控场景中的应用与代码实现
时间窗口特征工程滚动窗口
08
用户行为序列特征
基于KeyedState实现用户最近…
用户行为序列特征KeyedState
09
频率与速率特征
单位时间内的操作频率 · 操作速率 · 突发度（Burstiness）计算
频率速率特征
10
时间间隔特征
相邻事件时间差 · 平均间隔 · 间隔方差
时间间隔特征相邻事件时间差
11
地理位置与IP特征
IP归属地解析 · 经纬度距离计算 · 常用城市/国家统计
IP地理位置
12
设备指纹特征
设备ID聚合统计 · 设备切换频率 · 模拟器检测特征
设备指纹特征ID
13
关联图谱特征
基于Flink Gelly或自实现的… · 关联设备数 · 团伙检测特征
关联图谱特征Flink
14
复杂事件处理（CEP）特征
使用Flink CEP库定义风控规则…
CEP复杂事件处理
15
实时特征存储与维表关联
使用Redis/MySQL/HBas… · 通过AsyncIO实现实时关联
实时特征存储维表关联
16
特征归一化与分箱
实时Min-Max归一化 · Z-score标准化 · 等频/等距分箱实现
特征归一化分箱
17
特征交叉与组合
笛卡尔积交叉 · 多项式特征 · 基于业务逻辑的交叉特征
特征交叉组合
18
滑动衰减特征
基于时间衰减系数的加权统计特征（如指…
滑动衰减特征基于时间衰减系数…
19
实时特征回溯与校验
特征正确性验证 · 延迟数据处理 · Watermark策略对特征的影响
实时特征回溯校验
20
多流Join特征工程
双流Join · Interval Join · Window Join在风控特征中的…
Join多流
21
特征工程Pipeline架构设计
模块化设计 · 特征注册中心 · 配置化特征生成
Pipeline特征工程
22
状态管理与性能优化
State TTL配置 · RocksDB优化 · KeyBy策略
状态管理性能优化
23
实时特征监控与告警
特征延迟监控 · 特征值分布监控 · 特征缺失率告警
实时特征监控告警
24
基于SQL的特征工程
使用Flink SQL进行窗口聚合 · 维表Join · UDTF自定义特征函数
SQL基于
25
特征工程测试与验证
单元测试 · 集成测试 · 特征回测
特征工程测试验证
26
实时风控模型推理集成
将特征向量输出到模型服务（如PMML…
实时风控模型推理…PMML
27
实战案例一
登录风控场景特征工程（IP · 设备 · 行为序列
实战案例一IP
28
实战案例二
交易风控场景特征工程（金额统计 · 商户关联 · 时间间隔
实战案例二交易风控场景特征…
29
实战案例三
信贷风控场景特征工程（多头借贷特征 · 联系人图谱 · 行为评分卡特征）
实战案例三信贷风控场景特征…
30
课程总结与进阶方向
常见踩坑经验 · 生产环境最佳实践 · 未来趋势（Flink ML + 实时…
课程总结进阶方向