VIP20
本课程属于：048-量化回测实验评估 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Spark加速回测计算实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
回测计算概述
回测在量化交易中的重要性 · 传统回测的性能瓶颈 · Spark加速回测的优势
回测计算概述回测
02
Spark核心概念回顾
RDD · DataFrame · Dataset
Spark核心概念回顾
03
Spark环境搭建与配置
Spark集群部署模式（Standa… · Spark配置参数调优（execut… · 并行度）
Spark环境搭建
04
回测数据模型设计
OHLCV数据结构 · 事件驱动模型 · Bar数据与Tick数据的Spark…
回测数据模型设计OHLCV
05
数据加载与预处理
使用Spark读取CSV/Parqu… · 数据清洗与去重
数据加载预处理
06
分布式时间序列处理
窗口函数（Window） · 滑动窗口计算移动平均线 · 布林带等技术指标
分布式时间序列处…Window
07
向量化回测基础
利用DataFrame进行批量信号计… · 避免逐行循环 · 向量化操作的性能优势
向量化回测基础DataFrame
08
自定义聚合函数（UDAF）
实现复杂的资金曲线计算 · 最大回撤 · 夏普比率等统计指标
UDAF自定义聚合函数
09
事件驱动回测框架设计
基于RDD的事件流处理 · 订单簿模拟 · 撮合引擎的分布式实现
事件驱动回测框架…RDD
10
多标的并行回测
使用groupBy与partitio…
多标的并行回测groupBy
11
参数扫描与优化
网格搜索 · 随机搜索在Spark上的并行实现 · 超参数调优
参数扫描优化
12
蒙特卡洛模拟
使用Spark进行大量随机路径模拟 · 风险价值（VaR）计算
蒙特卡洛模拟Spark
13
回测结果聚合与统计
合并多个回测结果 · 计算收益分布 · 胜率
回测结果聚合统计
14
缓存与持久化策略
cache/persist的合理使用 · 序列化方式选择（Kryo vs Ja… · 内存与磁盘权衡
缓存持久化策略
15
Shuffle优化
减少Shuffle数据量 · 使用Broadcast Join · 避免数据倾斜
Shuffle优化
16
数据倾斜处理
倾斜检测 · 加盐（Salting）技术 · 自定义分区器
数据倾斜处理倾斜检测
17
Spark SQL在回测中的应用
使用Spark SQL进行复杂查询 · 窗口函数 · 时间序列连接
SparkSQL
18
Delta Lake与版本管理
使用Delta Lake实现数据版本… · 时间旅行 · 增量回测
DeltaLake
19
回测流水线构建
使用ML Pipelines构建端到… · 特征工程与模型评估
回测流水线构建ML
20
实时回测与流处理
使用Structured Strea… · 在线回测
实时回测流处理
21
性能监控与调优
Spark UI解读 · Stage划分 · Task执行时间分析
性能监控调优
22
GPU加速回测
Spark与GPU结合（RAPIDS… · GPU加速矩阵运算
GPU加速回测
23
回测结果可视化
使用Spark与Matplotlib… · 生成收益曲线与回撤图
回测结果可视化Spark
24
回测框架对比
Backtrader · Zipline · QuantConnect与Spark…
回测框架对比Backtrader
25
回测中的过拟合防范
交叉验证 · Walk-Forward分析 · 在Spark中实现时间序列交叉验证
回测过拟合防范
26
回测数据质量保障
数据完整性检查 · 异常值检测 · 幸存者偏差处理
回测数据质量保障数据完整性检查
27
回测结果存储与报告生成
将结果写入数据库（MySQL/Pos… · 生成HTML/PDF报告
回测结果存储报告生成
28
回测作业调度与自动化
使用Airflow调度Spark回测… · 依赖管理与重试机制
回测作业调度自动化
29
回测成本与风险管理
交易成本模拟 · 滑点模型 · 仓位管理
回测成本风险管理
30
综合实战案例
构建一个完整的Spark回测系统（从… · 涵盖多标的 · 多策略
综合实战案例Spark