简介
Apache Paimon(原 Flink Table Store)是一款基于流批一体架构的 高性能数据湖存储框架,支持低延迟的数据更新、实时查询和高效的键值点查(Point Lookup)。
本文将深入解析 Paimon 的点查机制,并通过 Java API 代码案例演示如何实现数据的点查功能。
一、Paimon 点查的核心原理
1. 什么是点查?
点查(Point Lookup)是指通过 唯一键(Primary Key) 快速定位并返回单条或少量数据的查询模式。例如:根据用户 ID 查询用户信息、根据订单号查询订单详情等。
点查的核心诉求是 低延迟 和 高吞吐,适用于实时风控、在线分析等场景。
2. Paimon 如何优化点查?
Paimon 的点查能力基于以下技术实现:
- 主键索引(Primary Key Index):
所有写入数据按主键排序存储,形成 LSM(Log-Structured Merge-Tree)结构,支持高效