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

实时因子计算：Flink流处理与特征服务搭建教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
实时因子计算的定义 · 应用场景（风控 · 推荐
课程导论实时因子计算的定…
02
Flink核心概念
Flink架构 · DataStream API · 有状态流处理
Flink核心概念
03
开发环境搭建
JDK · Maven · Flink集群（Standalone…
开发环境搭建JDK
04
Flink DataStream API基础
Source（Kafka · Socket · 文件）
FlinkDataStream
05
Flink时间语义与Watermark
事件时间 · 处理时间 · 摄入时间
FlinkWatermark
06
Flink窗口操作
滚动窗口 · 滑动窗口 · 会话窗口
Flink窗口操作
07
Flink状态管理
Keyed State（ValueS… · ListState · MapState）
Flink状态管理
08
Flink容错机制
Checkpoint原理 · Savepoint · Exactly-Once语义
Flink容错机制
09
Flink Table & SQL
Table API基础 · 动态表 · 流式SQL查询
FlinkTable
10
Flink CEP（复杂事件处理）
Pattern API · 匹配规则定义 · 超时处理
FlinkCEP
11
实时因子概念
因子定义 · 因子分类（基础因子 · 衍生因子
实时因子概念因子定义
12
因子计算引擎选型
Flink vs Spark Str… · 为何选择Flink做因子计算
因子计算引擎选型Flink
13
因子存储设计
Redis（热数据） · HBase（冷数据） · MySQL（元数据）
因子存储设计Redis
14
特征服务架构
特征服务整体架构图 · 特征生产层 · 特征存储层
特征服务架构特征服务整体架构…
15
特征服务API设计
RESTful API（获取单个特征 · 批量特征） · gRPC接口
API特征服务
16
特征服务缓存策略
本地缓存（Caffeine） · 分布式缓存（Redis） · 缓存穿透/击穿/雪崩解决方案
特征服务缓存策略Caffeine
17
特征服务高可用设计
服务注册与发现（Nacos/Eure… · 负载均衡 · 熔断降级（Sentinel/Hyst…
特征服务高可用设…Nacos/Eure
18
Flink与特征服务集成
Flink将计算好的因子写入Redi… · 特征服务从存储层读取并提供API
Flink特征服务集成
19
实时特征计算案例一
用户画像因子（近7天登录次数 · 近1小时消费金额 · 设备偏好）
实时特征计算案例…用户画像因子
20
实时特征计算案例二
交易风控因子（IP异常检测 · 设备指纹 · 交易频次
实时特征计算案例…IP
21
实时特征计算案例三
推荐系统因子（实时点击率 · 实时转化率 · 用户实时兴趣标签）
实时特征计算案例…推荐系统因子
22
Flink作业性能调优
并行度设置 · 算子链 · 反压检测与处理
Flink作业性能调优
23
Flink作业监控与告警
Flink Web UI · Metrics（吞吐量 · 延迟
Flink作业监控
24
特征服务性能测试
压测工具（JMeter/Locust… · QPS/TPS/延迟指标 · 性能瓶颈分析与优化
特征服务性能测试JMeter/Locus…
25
特征服务日志与链路追踪
ELK日志收集 · SkyWalking/Pinpoin… · 问题排查实战
特征服务日志链路追踪
26
实时因子计算数据质量
数据完整性 · 准确性 · 时效性监控
实时因子计算数据…数据完整性
27
实时因子计算安全
数据脱敏 · 访问控制（RBAC） · API鉴权（JWT/OAuth2）
实时因子计算安全数据脱敏
28
CI/CD与部署
Flink作业打包与部署（Flink… · Flink on K8s） · 特征服务Docker化
CI/CD部署
29
项目实战一
实时风控因子平台（需求分析 · 架构设计 · Flink作业开发
项目实战一实时风控因子平台
30
项目实战二
实时推荐特征平台（需求分析 · 架构设计 · Flink作业开发
项目实战二实时推荐特征平台