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

特征服务搭建指南：Flink流处理与因子计算

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
特征服务概述
特征服务的定义 · 在实时推荐与风控中的核心价值 · 与离线特征的区别
特征服务概述特征服务的定义
02
Flink基础回顾
Flink架构 · DataStream API · 时间语义
Flink基础回顾
03
实时特征计算场景
实时用户画像 · 实时点击率预估 · 实时反欺诈特征
实时特征计算场景实时用户画像
04
Flink开发环境搭建
JDK · Maven · Flink集群模式选择
Flink开发环境搭建
05
Flink项目骨架
Maven项目结构 · pom.xml依赖管理 · 主类与入口函数设计
Flink项目骨架
06
数据源接入
Kafka Source配置 · JSON/AVRO反序列化 · Source并行度调优
数据源接入Kafka
07
数据清洗与预处理
字段过滤 · 脏数据丢弃 · 时间戳标准化
数据清洗预处理
08
KeyBy与状态编程
KeyBy分组原理 · ValueState/MapStat… · 状态TTL配置
KeyBy状态编程
09
滑动窗口特征计算
滑动窗口定义 · 窗口内聚合（计数/均值/最大最小） · 窗口结果输出
滑动窗口特征计算滑动窗口定义
10
会话窗口特征计算
会话间隔设置 · 会话内行为序列拼接 · 会话级统计特征
会话窗口特征计算会话间隔设置
11
复杂事件处理(CEP)
CEP模式定义 · 连续事件匹配 · 超时与阈值检测
CEP复杂事件处理
12
自定义ProcessFunction
RichProcessFunctio… · 定时器(Timer)应用 · 侧输出(Side Output)
ProcessFunct…自定义
13
特征存储设计
Redis/MySQL/HBase选… · 特征Key设计原则 · 特征过期策略
特征存储设计Redis/MySQL/…
14
Flink与Redis集成
Redis Sink配置 · 特征写入与读取 · 连接池优化
FlinkRedis
15
Flink与HBase集成
HBase表设计 · BufferedMutator批量写… · RowKey设计
FlinkHBase
16
特征服务API设计
RESTful API规范 · 特征查询接口 · 批量查询接口
API特征服务
17
特征服务高可用
Flink Checkpoint配置 · Exactly-Once语义 · 故障恢复策略
特征服务高可用Flink
18
特征服务监控
Prometheus指标暴露 · Flink Web UI监控 · 自定义告警规则
特征服务监控Prometheus
19
特征服务性能调优
并行度调整 · 算子链优化 · 反压(Backpressure)处理
特征服务性能调优并行度调整
20
特征服务安全
Kafka SSL加密 · Flink认证授权 · 特征数据脱敏
特征服务安全Kafka
21
特征服务版本管理
特征版本号设计 · 灰度发布 · 回滚机制
特征服务版本管理特征版本号设计
22
特征服务测试
单元测试(TestNG) · 集成测试(Flink MiniClu… · 性能测试
特征服务测试TestNG
23
特征服务部署
Flink on YARN/K8s部… · 资源分配 · 日志收集
特征服务部署Flink
24
特征服务CI/CD
Jenkins流水线 · Docker镜像构建 · 自动化部署脚本
CI/CD特征服务
25
实时特征服务案例
实时用户活跃度特征 · 实时商品热度特征
实时特征服务案例实时用户活跃度特…
26
实时特征服务案例
实时交易风险评分特征 · 实时设备指纹特征
实时特征服务案例实时交易风险评分…
27
特征服务与机器学习
特征在线推理 · 模型特征对齐 · 特征重要性分析
特征服务机器学习
28
特征服务数据治理
特征血缘追踪 · 数据质量监控 · 特征一致性校验
特征服务数据治理特征血缘追踪
29
特征服务扩展
多流Join · 维表关联(HBase/Redis) · 异步IO
特征服务扩展Join
30
特征服务总结与展望
Flink 2.0新特性 · 流批一体趋势 · 特征平台演进方向
特征服务总结Flink