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

贷后实时风险拦截中的Spark实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
贷后风险拦截的业务背景 · 实时计算在风控中的价值 · Spark技术栈概览
课程导论贷后风险拦截的业…
02
贷后风险场景分析
逾期预警 · 多头借贷检测 · 异常交易识别
贷后风险场景分析逾期预警
03
实时风控系统架构
Lambda架构与Kappa架构对比 · Spark Streaming在其中…
实时风控系统架构Lambda
04
Spark Streaming核心原理
DStream · 微批次 · Receiver与Direct模式
SparkStreaming
05
Structured Streaming深度解析
Event-Time处理 · Watermark机制 · 状态管理
StructuredStreaming
06
Kafka集成实战
Spark与Kafka的Exactl… · Offset管理 · 背压机制
Kafka集成实战
07
实时特征工程
滑动窗口聚合 · Session化 · 特征回溯与特征存储
实时特征工程滑动窗口聚合
08
规则引擎设计
基于Spark的实时规则匹配 · 规则热更新 · 规则优先级
规则引擎设计Spark
09
机器学习模型实时推理
Spark MLlib模型加载 · PMML/ONNX模型部署 · 模型版本管理
机器学习模型实时…Spark
10
贷后风险评分卡
评分卡原理 · Spark实现WOE编码 · 实时评分计算
贷后风险评分卡评分卡原理
11
图计算在反欺诈中的应用
GraphX实时图分析 · 社群发现 · 二度关联查询
图计算反欺诈
12
实时数据质量监控
数据完整性校验 · 延迟监控 · 异常数据告警
实时数据质量监控数据完整性校验
13
状态后端与容错
RocksDB状态后端 · Checkpoint机制 · 重启恢复策略
状态后端容错
14
性能调优
并行度设置 · 数据倾斜处理 · 序列化优化
性能调优并行度设置
15
资源管理与动态分配
Spark on YARN/Kube… · 动态Executor · 资源弹性伸缩
资源管理动态分配
16
实时数仓与风控
DWD/DWS分层设计 · 实时ETL · 维表关联（HBase/Redis）
实时数仓风控
17
复杂事件处理（CEP）
CEP模式定义 · 时间窗口约束 · 在贷后催收中的应用
CEP复杂事件处理
18
实时决策引擎
决策表 · 决策树 · Spark实现毫秒级决策
实时决策引擎决策表
19
监控与告警体系
Prometheus + Grafa… · 自定义告警规则
监控告警体系
20
A/B测试与灰度发布
实时风控策略的A/B实验 · 流量切分 · 效果评估
A/B测试
21
数据血缘与溯源
Atlas/DataHub集成 · 实时数据链路追踪
数据血缘溯源
22
安全与合规
数据脱敏 · 差分隐私 · 审计日志
安全合规
23
案例实战一
基于Structured Strea…
案例实战一Structured
24
案例实战二
实时多头借贷检测系统（多数据源Joi…
案例实战二Joi
25
案例实战三
基于GraphX的团伙欺诈实时识别
案例实战三GraphX
26
案例实战四
实时催收任务智能分配系统
案例实战四实时催收任务智能…
27
案例实战五
实时反洗钱交易监控系统
案例实战五实时反洗钱交易监…
28
生产环境踩坑记录
背压导致OOM · Checkpoint过大 · Kafka Rebalance
生产环境踩坑记录OOM
29
未来趋势
Spark + Flink融合 · Serverless Spark · 实时湖仓一体
未来趋势Spark
30
课程总结与最佳实践
架构设计原则 · 代码规范 · 运维SOP
课程总结最佳实践