feat(realtime): complete primary-key realtime writes and reads - #2

Draft

HaHaJeff wants to merge 33 commits into

mainfrom

codex/pk-realtime-write-prepare

Commits on Aug 15, 2026

refactor(read): accept generic sorted inputs in PK merge reads
zhoujianfeng.jeff
committed
12ebe02
feat(realtime): add spill-backed primary-key indexer
zhoujianfeng.jeff
committed
3d1d1db
feat(realtime): merge primary-key realtime reads
zhoujianfeng.jeff
committed
d241af2
refactor(realtime): centralize realtime scan setup
zhoujianfeng.jeff
committed
6e818f0
refactor(realtime): generalize indexer creation and harden PK contracts
zhoujianfeng.jeff
committed
f37f3f5
refactor(realtime): centralize PK option validation
zhoujianfeng.jeff
committed
6eb388d
feat(realtime): create PK indexers through factory
zhoujianfeng.jeff
committed
eb1956a
feat(realtime): expose PK query readers through MemIndexer
zhoujianfeng.jeff
committed
da151c4
fix(realtime): harden PK spill and memory lifecycle
zhoujianfeng.jeff
committed
749a009
test(realtime): cover PK recovery and union reads
zhoujianfeng.jeff
committed
6dddd7f
fix(realtime): keep PK indexers pluggable
zhoujianfeng.jeff
committed
d00cecf
fix(realtime): preserve scan validation errors
zhoujianfeng.jeff
committed
400ae71
fix(realtime): enforce PK contracts and cleanup lifecycle
zhoujianfeng.jeff
committed
8dd5ab0
fix(realtime): honor custom PK indexer factories
zhoujianfeng.jeff
committed
fe0a807
fix(realtime): separate PK commit and query readers
zhoujianfeng.jeff
committed
7bcadc9
fix(realtime): recover custom PK indexers
zhoujianfeng.jeff
committed
57d2dc2
refactor(realtime): unify primary key memory indexing
zhoujianfeng.jeff
committed
745e2d3
docs(realtime): clarify PK merge assumptions
zhoujianfeng.jeff
committed
ad2f494

Commits on Aug 16, 2026

fix(realtime): correct KeyValue forward declaration
zhoujianfeng.jeff
committed
b4911bb
refactor(realtime): minimize shared path changes
zhoujianfeng.jeff
committed
3b713e0
fix(io): retain pool for exported Arrow array
zhoujianfeng.jeff
committed
9f45a4c

Commits on Aug 17, 2026

fix(realtime): harden PK write and merge paths
zhoujianfeng.jeff
committed
1418a3e
fix(realtime): handle null realtime write batches
zhoujianfeng.jeff
committed
ef479fd
test(realtime): move PK concurrency coverage
zhoujianfeng.jeff
committed
4652778

Commits on Aug 18, 2026

test(realtime): cover PK spill threading modes
zhoujianfeng.jeff
committed
714e53d
test(realtime): cover commit and refresh with serialized prepare
zhoujianfeng.jeff
committed
6287f79
fix(realtime): disable internal PK compaction
zhoujianfeng.jeff
committed
97496d4
perf(realtime): preserve disk section merge for PK reads
zhoujianfeng.jeff
committed
23ee8af
feat(mergetree): add one-shot buffered read views
zhoujianfeng.jeff
committed
51d456c
fix(realtime): snapshot active PK writes without rotating
zhoujianfeng.jeff
committed
92dfb79
perf(realtime): merge PK inputs by key range
zhoujianfeng.jeff
committed
858c542
refactor(realtime): clarify active buffer read materialization
zhoujianfeng.jeff
committed
42b153b

Commits on Aug 19, 2026

fix(realtime): harden primary-key resource lifecycles
zhoujianfeng.jeff
committed
87956b6