VIP20

本课程属于：010-量化因子研究变量衍生与分箱 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

用Flink做因子计算：实时特征服务开发教程

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

实时特征服务的概念 · 应用场景（推荐 · 风控

课程导论实时特征服务的概…

Flink基础回顾

Flink架构 · 核心概念（DataStream · 算子

Flink基础回顾

Flink DataStream API入门

Source · Transformation · Sink基础操作

FlinkDataStream

Flink时间语义与Watermark

EventTime · ProcessingTime · IngestionTime区别

Flink状态编程

KeyedState与Operato… · ValueState · ListState

Flink状态编程

Flink Checkpoint与Savepoint

状态一致性 · Exactly-Once语义 · Checkpoint配置与调优

FlinkCheckpoint

Flink Table & SQL API

TableEnvironment · 动态表 · 流式SQL查询

Flink CEP（复杂事件处理）

Pattern API · 事件序列匹配 · 超时与跳过策略

特征工程基础

特征分类（离散/连续/文本） · 特征处理流程（清洗 · 变换

特征工程基础特征分类

实时特征服务架构设计

整体架构（数据源->计算层->存储层… · 技术选型（Flink+Redis/H…

实时特征服务架构…整体架构

数据源接入

Kafka Source配置 · Schema Registry · Avro/Protobuf序列化

数据源接入Kafka

特征计算算子开发

滑动窗口聚合 · Session窗口 · Over窗口

特征计算算子开发滑动窗口聚合

特征存储设计

Redis数据结构选择（Hash/S… · TTL策略 · HBase RowKey设计

特征存储设计Redis

实时特征服务层开发

基于Flink的RESTful AP… · gRPC接口实现 · 请求路由与负载均衡

实时特征服务层开…Flink

特征更新与回填

实时流更新 · 离线批处理回填 · Lambda架构与Kappa架构对比

特征更新回填

特征血缘与元数据管理

特征定义 · 版本管理 · 血缘追踪（Atlas/自研）

特征血缘元数据管理

特征质量监控

数据延迟监控 · 特征值分布漂移检测 · 空值率与异常值告警

特征质量监控数据延迟监控

Flink作业性能调优

并行度设置 · 算子链 · Buffer超时

Flink作业性能调优

Flink作业高可用与容错

JobManager HA · TaskManager故障恢复 · 重启策略配置

Flink作业高可用

Flink与机器学习模型集成

实时模型推理（PMML/ONNX/T… · 特征拼接与模型打分

Flink机器学习模型集成

实时特征服务测试

单元测试（TestHarness） · 集成测试（MiniCluster） · 端到端测试（Kafka+Redis）

实时特征服务测试TestHarness

Flink CDC与实时特征

Debezium+Kafka+Fli… · 实时特征更新

多租户特征服务

租户隔离 · 资源配额 · 特征权限控制

多租户特征服务租户隔离

特征缓存策略

本地缓存（Caffeine） · 分布式缓存（Redis Cluste… · 缓存一致性（Cache-Aside/…

特征缓存策略Caffeine

实时特征服务监控与告警

Prometheus+Grafana… · Flink Metrics · 业务告警规则

实时特征服务监控告警

Flink SQL在特征计算中的应用

CREATE TABLE AS SE… · Temporal Join · 维表关联（Async IO）

特征服务灰度发布与回滚

蓝绿部署 · 金丝雀发布 · 特征开关

特征服务灰度发布回滚

实时特征服务安全

数据加密（TLS） · 认证鉴权（OAuth2/JWT） · SQL注入防护

实时特征服务安全TLS

案例实战一

实时推荐特征服务（用户行为序列 · 物品属性 · 实时统计特征）

案例实战一实时推荐特征服务

案例实战二

实时风控特征服务（设备指纹 · IP信誉 · 交易频次

案例实战二实时风控特征服务