VIP20

本课程属于：027-金融特征平台批流一体链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Flink批流一体特征工程案例

共计 30 章节

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

Flink概述与批流一体概念

Flink发展历史 · 核心特性 · 批处理与流处理的统一架构

Flink批流一体概念

Flink环境搭建与项目初始化

本地开发环境配置 · Flink集群模式介绍 · Maven/Gradle项目搭建

Flink环境搭建

DataStream API基础

DataStream与DataSet… · Source算子（文件 · Kafka

Flink时间语义与Watermark

EventTime · ProcessingTime · IngestionTime区别

Flink窗口机制

滚动窗口 · 滑动窗口 · 会话窗口

Flink窗口机制

状态管理与容错机制

Keyed State与Operat… · 状态后端（Memory · FS

状态管理容错机制

Flink Table & SQL API

TableEnvironment创建 · 动态表概念 · SQL查询与CDC

特征工程概述

特征工程定义与流程 · 离线特征与实时特征的区别 · 批流一体特征工程架构设计

特征工程概述特征工程定义

特征数据源接入

Kafka实时流接入 · HDFS/OSS批数据读取 · JDBC维表连接

特征数据源接入Kafka

特征清洗与预处理

缺失值处理（均值填充 · 插值） · 异常值检测（Z-score

特征清洗预处理

特征变换与编码

One-Hot编码 · Label Encoding · 分箱（等距

特征变换编码

时间特征提取

时间戳解析 · 滑动窗口统计特征（均值 · 最大值

时间特征提取时间戳解析

聚合特征计算

GroupBy聚合 · 滑动聚合 · 累加器模式

聚合特征计算GroupBy

Join特征构建

Stream-Stream Join · Stream-Table Join（… · Interval Join

Join特征构建

特征存储与输出

特征写入Redis · 写入HBase · 写入Kafka

特征存储输出

Flink CEP与复杂事件特征

CEP模式定义 · Pattern API · 事件序列匹配

ProcessFunction深度应用

KeyedProcessFuncti… · 定时器（Timer） · 状态访问

ProcessFunct…深度应用

广播状态与动态特征

BroadcastStream模式 · 动态规则更新 · 实时特征配置热加载

广播状态动态特征

异步IO与外部特征服务

AsyncIO原理 · 异步查询外部特征库（Redis/My… · 超时与重试策略

批流一体特征Pipeline设计

统一特征定义DSL · 批流共用特征逻辑 · Flink批模式与流模式切换

Pipeline批流一体特征

特征回溯与历史特征计算

批处理回溯历史数据 · 时间旅行（Time Travel） · 特征回填策略

特征回溯历史特征计算

特征监控与质量保障

特征延迟监控 · 特征值分布监控 · 数据倾斜检测

特征监控质量保障

Flink ML与在线学习

Flink ML Pipeline简… · 特征向量化 · 在线模型更新与特征联动

特征工程性能优化

算子链优化 · 并行度调优 · 状态大小控制

特征工程性能优化算子链优化

端到端实时特征工程案例（一）

用户画像实时特征构建（点击流 · 浏览时长 · 偏好标签）

端到端实时特征工…用户画像实时特征…

端到端实时特征工程案例（二）

风控场景实时特征（交易频次 · 设备指纹 · 地理位置异常）

端到端实时特征工…风控场景实时特征

端到端实时特征工程案例（三）

推荐系统实时特征（实时CTR特征 · 物品协同过滤特征）

端到端实时特征工…CTR

Flink与AI平台集成

特征存储Feast/Tecton集成 · 特征服务API封装 · Flink作为特征计算引擎

生产环境部署与运维

Flink on Kubernete… · 资源管理 · 日志监控

生产环境部署运维

课程总结与未来展望

批流一体特征工程最佳实践 · Flink社区发展方向 · 特征工程趋势（Feature Sto…

课程总结未来展望