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

SQL流式处理在风险归因中的应用

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风险归因概述
金融风险类型 · 归因分析目标 · 流式处理在风控中的价值
风险归因概述金融风险类型
02
SQL流式处理基础
流式SQL概念 · 与传统批处理SQL的区别 · 常见流引擎（Flink/KSQL）简…
SQL流式处理基础
03
事件时间与处理时间
事件时间语义 · 处理时间语义 · 水位线（Watermark）机制
事件时间处理时间
04
流式数据源接入
Kafka主题配置 · JSON/AVRO格式解析 · Schema Registry集成
流式数据源接入Kafka
05
流式表定义与DDL
CREATE TABLE语法 · WITH参数 · 时间属性声明（PROCTIME/RO…
DDL流式表定义
06
连续查询与物化视图
连续查询原理 · 物化视图刷新策略 · 结果表（Sink）定义
连续查询物化视图
07
窗口聚合基础
滚动窗口（Tumble） · 滑动窗口（Hop） · 会话窗口（Session）
窗口聚合基础Tumble
08
风险因子流式计算
市场因子（价格波动） · 信用因子（违约概率） · 操作因子（交易异常）
风险因子流式计算市场因子
09
归因模型SQL实现
线性归因模型 · 因子贡献度计算 · 残差项处理
SQL归因模型
10
多因子联合分析
交叉因子效应 · 协方差矩阵流式近似 · 因子相关性监控
多因子联合分析交叉因子效应
11
实时风险指标计算
VaR（在险价值）流式近似 · ES（预期亏损）滚动计算
实时风险指标计算VaR
12
异常检测与归因
基于Z-Score的流式异常检测 · 归因到具体因子 · 告警触发
异常检测归因
13
时间衰减与权重
指数加权移动平均（EWMA） · 衰减因子配置 · 历史数据权重调整
时间衰减权重
14
数据质量与延迟处理
迟到数据处理策略 · 侧输出（Side Output） · 数据质量监控表
数据质量延迟处理
15
状态管理与容错
Flink状态后端 · Checkpoint机制 · Exactly-Once语义保障
状态管理容错
16
UDF与自定义函数
标量函数 · 聚合函数 · 表值函数在归因中的应用
UDF自定义函数
17
流表关联（Join）
Interval Join · Temporal Join · Lookup Join在因子关联中的…
Join流表关联
18
归因结果持久化
写入ClickHouse/Elast… · 结果表分区策略 · 数据保留策略
归因结果持久化ClickHouse/E…
19
实时仪表盘集成
WebSocket推送 · Grafana数据源配置 · 归因结果可视化
实时仪表盘集成WebSocket
20
性能调优
并行度设置 · 算子链优化 · Mini-Batch与Buffer调…
性能调优并行度设置
21
归因回测框架
历史数据回放 · 归因结果对比 · 回测指标（MAE/MAPE）
归因回测框架历史数据回放
22
多层级归因
资产层 · 因子层 · 策略层归因分解
多层级归因资产层
23
归因结果校验
归因恒等式验证 · 残差分析 · 归因稳定性监控
归因结果校验归因恒等式验证
24
流式归因与机器学习结合
在线学习模型输出作为因子 · 模型SHAP值流式计算
流式归因机器学习结合
25
合规与审计
归因日志记录 · 数据血缘追踪 · 审计查询SQL模板
合规审计
26
多数据源融合
实时行情 · 交易流水 · 舆情数据流式归因
多数据源融合实时行情
27
归因场景实战
股票组合归因 · 债券久期归因 · 衍生品希腊字母归因
归因场景实战股票组合归因
28
故障排查与调试
SQL执行计划分析 · 算子Metrics监控 · 常见错误处理
故障排查调试
29
流式归因架构设计
Lambda架构 vs Kappa架… · 技术选型对比 · 高可用设计
流式归因架构设计Lambda
30
课程总结与展望
流式归因最佳实践 · 未来趋势（AI原生归因） · 推荐学习路径
课程总结流式归因最佳实践