VIP20
本课程属于：027-金融特征平台批流一体链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink实时特征计算实战指南

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
Flink概述
Flink的发展历史 · 核心特性（事件驱动 · 流批一体）
Flink的发展历史
02
Flink环境搭建
本地模式（Standalone） · YARN模式 · Kubernetes模式的安装与配置
Flink环境搭建
03
Flink编程模型
DataStream API基础 · Source/Transformat… · 执行环境（StreamExecuti…
Flink编程模型
04
Flink数据类型与序列化
支持的数据类型（POJO · Tuple · Scala Case Class）
Flink数据类型
05
Flink Source算子详解
基于文件（readTextFile） · 基于Socket · 基于Kafka（FlinkKafka…
FlinkSource
06
Flink Transformation算子（上）
map · flatMap · filter
FlinkTransformati…
07
Flink Transformation算子（下）
union · connect · coMap
FlinkTransformati…
08
Flink Sink算子详解
writeAsText · print · Kafka Sink（FlinkKa…
FlinkSink
09
Flink时间语义
EventTime · IngestionTime · ProcessingTime的区别与…
Flink时间语义
10
Flink Watermark机制
Watermark的生成策略（周期性 · 标点式） · allowedLateness
FlinkWatermark
11
Flink Window操作
滚动窗口（Tumbling） · 滑动窗口（Sliding） · 会话窗口（Session）
FlinkWindow
12
Flink Window函数
ReduceFunction · AggregateFunction · ProcessWindowFunct…
FlinkWindow
13
Flink状态管理（上）
Keyed State（ValueS… · ListState · MapState
Flink状态管理
14
Flink状态管理（下）
Operator State（Lis… · UnionListState · BroadcastState）
Flink状态管理
15
Flink Checkpoint与Savepoint
Checkpoint原理（Barri… · Exactly-Once语义 · Savepoint的触发与恢复
FlinkCheckpoint
16
Flink容错机制
重启策略（固定延迟 · 失败率 · 无重启）
Flink容错机制
17
Flink Table & SQL API
TableEnvironment · 动态表（Dynamic Table） · 流式SQL查询
FlinkTable
18
Flink CEP（复杂事件处理）
Pattern API（begin · next · followedBy
FlinkCEP
19
Flink与Kafka集成
Kafka Source/Sink配… · Offset提交策略（Checkpo… · Auto）
FlinkKafka
20
Flink实时特征计算场景
用户画像实时更新 · 实时推荐特征 · 风控特征（如交易频次
Flink实时特征计算场景
21
实时特征计算架构设计
Lambda架构 vs Kappa架… · Flink作为核心引擎的典型架构图
实时特征计算架构…Lambda
22
特征存储选型
Redis（高性能键值） · HBase（宽表存储） · MySQL（关系型）
特征存储选型Redis
23
Flink + Redis实时特征计算
Redis Connector配置 · 将特征写入Redis Hash/Se… · 读取特征做实时Join
FlinkRedis
24
Flink + HBase实时特征计算
HBase Connector配置 · RowKey设计 · 批量写入与读取优化
FlinkHBase
25
Flink + MySQL实时特征计算
JDBC Connector配置 · 维表Join（Temporal Ta… · 异步IO优化
FlinkMySQL
26
Flink实时特征ETL
数据清洗（过滤脏数据） · 字段转换（JSON解析 · 类型转换）
FlinkETL
27
Flink实时特征聚合
基于时间窗口的聚合（5分钟交易总额） · 基于计数窗口的聚合（最近100次点击…
Flink实时特征聚合
28
Flink实时特征关联
双流Join（Interval Jo… · Regular Join） · 维表Join（AsyncIO
Flink实时特征关联
29
Flink实时特征监控与调优
反压（Backpressure）监控 · Checkpoint失败调优 · 并行度调整
Flink实时特征监控
30
Flink实时特征计算实战项目
实时用户行为特征计算（点击 · 购买 · 收藏）
Flink实时特征计算实战…