VIP7
本课程属于：018-Flink实时数仓与流批平台工程 后端、数据与云原生工程 · 共 7 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

流批一体中的状态复用技巧

📚 共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
状态复用概述
流批一体架构演进、状态复用的核心价值、适用场景分析。
架构价值场景
02
状态后端选型
RocksDB状态后端、Heap状态后端、FsState状态后端对比。
RocksDBHeapFsState
03
状态数据结构
ValueState、ListState、MapState、ReducingState、AggregatingState。
ValueStateListStateMapState
04
状态TTL管理
TTL配置策略、过期状态清理机制、状态大小控制。
TTL清理容量
05
状态序列化
Java序列化 vs 自定义序列化、Kryo序列化、Avro序列化。
KryoAvro性能
06
状态分区与KeyBy
KeyBy原理、状态分区策略、倾斜问题处理。
KeyBy分区倾斜
07
状态后端配置
RocksDB调优参数、内存管理、磁盘IO优化。
调优内存IO
08
状态快照与恢复
Checkpoint机制、Savepoint机制、Exactly-Once语义。
CheckpointSavepoint一致性
09
增量Checkpoint
增量快照原理、RocksDB增量Checkpoint、性能对比。
增量RocksDB性能
10
状态迁移
算子升级状态兼容、状态Schema演进、状态重分布。
兼容Schema重分布
11
广播状态
BroadcastState原理、动态配置更新、模式切换。
广播动态配置模式
12
算子状态
ListCheckpointed、BroadcastState、UnionListState。
算子ListUnion
13
状态一致性
端到端Exactly-Once、两阶段提交、Kafka事务集成。
Exactly-Once2PCKafka
14
状态查询服务
QueryableState架构、外部查询接口、低延迟访问。
查询接口低延迟
15
状态延迟监控
状态访问延迟指标、火焰图分析、性能瓶颈定位。
监控火焰图瓶颈
16
状态大小控制
状态压缩、状态分片、状态淘汰策略。
压缩分片淘汰
17
多流状态关联
CoProcessFunction、IntervalJoin、WindowJoin。
CoProcessIntervalJoinWindow
18
状态与时间语义
EventTime状态、ProcessingTime状态、Watermark对齐。
EventTimeProcessingTimeWatermark
19
状态后端热切换
运行时切换状态后端、双写策略、零停机迁移。
热切换双写零停机
20
状态复用模式
状态共享、状态继承、状态模板。
共享继承模板
21
状态版本管理
状态版本号、向后兼容、向前兼容。
版本兼容演进
22
状态测试
单元测试状态、集成测试状态、Mock状态后端。
单元测试集成测试Mock
23
状态安全
状态加密、访问控制、审计日志。
加密访问控制审计
24
状态清理策略
全量清理、增量清理、惰性清理。
全量增量惰性
25
状态与窗口结合
窗口状态复用、Session窗口状态、滑动窗口状态。
窗口Session滑动
26
状态存储优化
LSM-Tree原理、Bloom Filter、Compaction策略。
LSM-TreeBloomCompaction
27
状态网络传输
状态序列化传输、网络带宽优化、数据压缩。
传输带宽压缩
28
状态容错
故障恢复、状态重建、副本机制。
容错重建副本
29
状态性能基准测试
吞吐量测试、延迟测试、资源消耗测试。
吞吐延迟资源
30
状态最佳实践
生产环境配置、常见问题排查、性能调优案例。
生产排查调优