VIP20

本课程属于：029-贷后预警策略实时风险拦截 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

Spark Streaming在贷后预警中的应用

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

贷后预警业务背景 · Spark Streaming技术优… · 课程目标与学习路径

课程导论贷后预警业务背景

贷后预警业务基础

贷后管理流程 · 风险预警指标（逾期率 · 迁徙率）

贷后预警业务基础贷后管理流程

Spark Streaming核心概念

DStream · Receiver · Batch Interval

开发环境搭建

JDK · Scala · Spark集群

开发环境搭建JDK

第一个Spark Streaming程序

WordCount案例 · 本地模式运行 · 理解DAG执行流程

数据源接入（一）

Socket数据源 · 文件系统数据源（HDFS） · 自定义Receiver

数据源接入Socket

数据源接入（二）

Kafka数据源（Direct Ap… · Kafka Offset管理 · Exactly-Once语义

数据源接入Kafka

数据源接入（三）

Flume数据源 · Kinesis数据源 · 多数据源整合策略

数据源接入Flume

DStream转换操作

无状态转换（map · filter · union）

DStream转换操作

窗口长度与滑动间隔 · reduceByKeyAndWind… · countByWindow实战

窗口操作窗口长度

贷后预警数据模型设计

客户还款计划表 · 交易流水表 · 逾期标签表

贷后预警数据模型…客户还款计划表

实时特征计算（一）

滚动逾期天数计算 · 历史最大逾期天数 · 近30天还款次数

实时特征计算滚动逾期天数计算

实时特征计算（二）

滑动窗口聚合特征（近7天/30天逾期… · 比率特征计算

实时特征计算滑动窗口聚合特征

预警规则引擎设计

规则配置化 · 规则优先级 · 规则匹配流程（阈值规则

预警规则引擎设计规则配置化

规则引擎实现

基于DStream的规则匹配 · 规则命中计数 · 规则热更新方案

规则引擎实现DStream

预警等级动态调整

基于评分卡的风险评分 · 等级映射 · 动态阈值调整策略

预警等级动态调整基于评分卡的风险…

mapWithState详解 · StateSpec配置 · 状态超时与清理策略

状态管理mapWithState

贷后预警案例（一）

实时逾期监控预警——从Kafka消费… · 计算逾期天数并触发预警

贷后预警案例Kafka

贷后预警案例（二）

多头借贷风险预警——跨平台借贷次数统… · 关联规则匹配

贷后预警案例多头借贷风险预警

贷后预警案例（三）

异常还款行为预警——还款金额突变检测 · 还款时间异常检测

贷后预警案例异常还款行为预警

性能优化（一）

并行度调优 · 数据序列化（Kryo） · 内存管理与GC调优

性能优化并行度调优

性能优化（二）

背压机制（Backpressure） · 数据倾斜处理 · Checkpoint优化

性能优化Backpressure

容错与可靠性

Checkpoint机制 · WAL（Write Ahead Lo… · Driver HA配置

容错可靠性

监控与告警

Spark UI指标解读 · Grafana+Prometheus… · 自定义告警通知（短信/邮件）

结构化流（Structured Streaming）入门

与DStream对比 · Event-Time处理 · Watermark机制

StructuredStreaming

结构化流在贷后预警中的应用

使用DataFrame/DataSe… · 流表Join

结构化流贷后预警

贷后预警数据可视化

实时看板设计（ECharts/Gra… · 预警趋势图 · Top N风险客户

贷后预警数据可视…ECharts/Gra

生产环境部署

Spark on YARN/Kube… · 资源规划 · 日志收集与问题排查

生产环境部署Spark

项目实战（一）

端到端贷后预警系统搭建——数据采集 · 实时计算 · 规则匹配

项目实战端到端贷后预警系…

项目实战（二）

系统压测 · 效果评估 · 总结与最佳实践

项目实战系统压测