Apache Paimon Changelog Producer 详解 Apache Paimon Changelog Producer 详解 总结 更新时间:2026-06-18 本文档深入解析 Paimon 主键表的四种 Changelog Producer 模式(none / input / full-compaction / lookup)的工作机制与源码实现 2026-06-18 paimon 5 yoxih
Flink RowKind 详解 Flink RowKind 详解 总结 更新时间:2026-04-29 RowKind 是 Flink 流式处理中描述"一行数据发生了什么变化"的标记,每条流记录除字段值外都携带一个 RowKind 四种类型:+I(插入)、-U(更新前旧值)、+U(更新后新值)、-D(删除) -U 是流式算子实现" 2026-04-29 flink 11 yoxih
Paimon 分区过期机制详解 Paimon 分区过期机制详解 Paimon 分区过期机制详解 总结 更新时间:2026-03-03 本文档详细分析 Paimon 分区过期(Partition Expiration)的源码实现和测试验证 触发时机:每次 commit 后在 maintain 阶段检查,受 partition.expiration-check-in 2026-03-03 paimon 8 yoxih
Paimon Compaction 详解 Paimon Compaction 详解 总结 更新时间:2025-12-25 适用版本:Apache Paimon 1.3+(包含 0.8 vs 1.3 版本差异对比) 核心概念 Compaction 核心作用: 主键表:合并 LSM Tree 中的 Sorted Runs,防止查询性能下降和 O 2025-12-24 paimon 19 yoxih
Apache Paimon Partial-Update Apache Paimon Partial-Update 总结 更新时间:2025-12-12 本文档详细介绍 Paimon 的 partial-update 合并引擎和 sequence-group 机制 Sequence Group 核心规则: 配置了 sequence-group 的字段:只有 2025-12-12 paimon 17 yoxih
Apache Paimon 表模式(Table Mode)详解 Apache Paimon 表模式(Table Mode)详解 总结 更新时间:2025-12-04 主要修改内容: 新增了 MOR 模式的详细读写机制说明 补充了 MOR 模式中 Compaction 触发时机的详细解释(区分 Flink 和 Spark) 明确了读取时的数据合并是内存计算而非物理 2025-12-04 paimon 14 yoxih
Paimon 表 Index 文件详解 Paimon 表 Index 文件详解 总结 更新时间:2025-12-04 主要修改内容: 修复了所有 SQL 示例中的 PRIMARY KEY (id) NOT ENFORCED 语法错误(Spark 不支持在列定义中声明主键) 为所有已测试的 SQL 语句添加了 ✅ 已测试 (Spark 3. 2025-12-04 paimon 8 yoxih