VIP20
本课程属于：077-组合风险归因稳定性巡检 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Spark处理组合风险归因数据教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
组合风险归因的定义 · 为什么需要Spark · 课程目标与前置知识
课程导论组合风险归因的定…
02
风险归因基础理论
因子模型简介（CAPM · Fama-French） · 风险分解（系统风险 vs 特质风险）
风险归因基础理论CAPM
03
Spark环境搭建
Spark集群安装 · PySpark环境配置 · Jupyter Notebook集成
Spark环境搭建
04
Spark DataFrame基础
创建DataFrame · Schema定义 · 常见转换操作（select
SparkDataFrame
05
数据读取与写入
读取CSV/Parquet/JSON… · 写入到Hive表 · 分区写入策略
数据读取写入
06
数据清洗与预处理
处理缺失值 · 异常值检测 · 数据类型转换
数据清洗预处理
07
时间序列数据处理
窗口函数（Window） · 滚动计算 · 日期格式处理
时间序列数据处理Window
08
组合构建与持仓数据
模拟持仓DataFrame · 市值加权与等权组合 · 调仓逻辑
组合构建持仓数据
09
因子收益率计算
市场因子 · 规模因子 · 价值因子
因子收益率计算市场因子
10
因子暴露计算
使用OLS回归计算个股因子暴露 · 滚动窗口暴露
因子暴露计算OLS
11
协方差矩阵估计
样本协方差 · 指数加权协方差（EWMA） · Spark分布式矩阵计算
协方差矩阵估计样本协方差
12
风险分解模型
Brinson归因模型原理 · Spark实现Brinson归因
风险分解模型Brinson
13
风险归因
因子贡献度计算 · 特质风险贡献 · 边际风险贡献
风险归因因子贡献度计算
14
VaR与CVaR计算
历史模拟法 · 参数法 · 蒙特卡洛模拟的Spark实现
VaRCVaR
15
压力测试与情景分析
定义压力情景 · 批量计算组合损益 · 结果汇总
压力测试情景分析
16
性能优化
数据分区优化 · 缓存策略（cache/persist… · 广播变量应用
性能优化数据分区优化
17
UDF与自定义聚合
PySpark UDF编写 · 自定义聚合函数（UDAF） · 性能对比
UDF自定义聚合
18
SQL在风险归因中的应用
Spark SQL窗口函数 · 临时视图 · 复杂查询
SQL风险归因
19
数据倾斜处理
倾斜原因分析 · salting技术 · 两阶段聚合
数据倾斜处理倾斜原因分析
20
增量更新与流处理
Structured Streami… · 增量风险计算
增量更新流处理
21
可视化结果
使用Matplotlib/Plotl… · 因子暴露热力图
可视化结果Matplotlib/P…
22
回测框架搭建
基于Spark的回测引擎设计 · 绩效指标计算（夏普比率 · 最大回撤）
回测框架搭建Spark
23
多资产组合归因
股票+债券+衍生品组合的风险归因方法
多资产组合归因股票+债券+衍生…
24
Barra模型实战
Barra风险因子体系 · 在Spark中复现Barra归因
Barra模型实战
25
报告生成
自动化生成风险归因报告（HTML/P… · 关键指标汇总
报告生成HTML/P
26
大规模数据处理
处理千万级持仓数据 · 内存调优 · Shuffle调优
大规模数据处理处理千万级持仓数…
27
与Hive/数仓集成
读取Hive表 · 写入结果到数仓 · 调度任务（Airflow）
Hive数仓集成
28
案例实战一
股票组合日频风险归因全流程
案例实战一股票组合日频风险…
29
案例实战二
多因子对冲基金风险归因与归因分析
案例实战二多因子对冲基金风…
30
课程总结与进阶
常见陷阱 · 最佳实践 · 推荐学习资源
课程总结进阶