VIP20
本课程属于：010-量化因子研究变量衍生与分箱 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

实时特征计算：Flink与因子库结合实践课程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
实时特征计算的定义 · 应用场景（风控 · 推荐
课程导论实时特征计算的定…
02
Flink基础回顾
Flink架构 · DataStream API · 时间语义（Event Time/Pr…
Flink基础回顾
03
Flink状态管理
Keyed State · Operator State · 状态后端（RocksDB/FS）
Flink状态管理
04
Flink Checkpoint与容错
Exactly-Once语义 · Checkpoint配置 · Savepoint与状态恢复
FlinkCheckpoint
05
Flink SQL与Table API
动态表 · 流式SQL查询 · UDF/UDAF注册
FlinkSQL
06
因子库概念与设计
因子定义 · 因子分类（基础因子/衍生因子） · 因子生命周期管理
因子库概念设计
07
因子库元数据管理
因子注册中心 · 因子版本控制 · 因子依赖关系
因子库元数据管理因子注册
08
实时因子计算引擎架构
数据接入层 · 计算层 · 存储层
实时因子计算引擎…数据接入层
09
数据源接入实战
Kafka Source · Pulsar Source · 自定义Source
数据源接入实战Kafka
10
实时数据清洗与预处理
字段过滤 · 类型转换 · 异常值处理
实时数据清洗预处理
11
滑动窗口因子计算
Tumbling Window · Sliding Window · Session Window在因子计…
滑动窗口因子计算Tumbling
12
复杂事件处理（CEP）因子
Flink CEP模式定义 · 时间约束 · 多模式组合生成因子信号
CEP复杂事件处理
13
多流Join因子计算
Interval Join · Temporal Join · Regular Join在因子聚合中…
Join多流
14
维表关联因子
异步IO查询Redis/MySQL · 广播状态维表 · 维表缓存策略
维表关联因子IO
15
自定义聚合函数（UDAF）因子
实现复杂统计因子（均值 · 方差 · 分位数
UDAF自定义聚合函数
16
时间序列特征工程
滑动平均 · 指数加权移动平均 · 差分
时间序列特征工程滑动平均
17
因子计算中的状态复用
共享状态设计 · 状态分区策略 · 避免状态膨胀
因子计算状态复用
18
因子计算性能优化
算子链优化 · 并行度调优 · 反压处理
因子计算性能优化算子链优化
19
因子结果输出与存储
Kafka Sink · HBase Sink · ClickHouse Sink
因子结果输出存储
20
因子服务化与在线推理
RESTful API封装 · gRPC服务 · 实时特征查询接口设计
因子服务化线推理
21
因子计算血缘追踪
Flink lineage机制 · 自定义算子血缘 · 元数据血缘打通
因子计算血缘追踪Flink
22
因子计算监控与告警
Prometheus指标暴露 · Grafana看板 · 任务延迟告警
因子计算监控告警
23
因子回测与验证
历史数据回放 · 因子IC/IR计算 · 因子衰减分析
因子回测验证
24
多租户因子计算
资源隔离 · 命名空间隔离 · 租户级配置管理
多租户因子计算资源隔离
25
Flink CDC与因子计算
Debezium集成 · 实时捕获数据库变更 · 增量因子更新
FlinkCDC
26
机器学习模型因子
Flink ML Pipeline · 在线模型推理 · 模型特征实时计算
机器学习模型因子Flink
27
因子计算中的特征存储
Feature Store概念 · 在线/离线特征一致性 · 特征服务
因子计算特征存储
28
大规模因子计算实战
千级因子并行计算 · 动态因子注册 · 热加载因子逻辑
大规模因子计算实…千级因子并行计算
29
Flink与AI平台集成
Kubernetes部署 · Flink Operator · CI/CD流水线
FlinkAI
30
课程总结与最佳实践
常见坑点 · 架构演进路线 · 未来趋势（流批一体
课程总结最佳实践