Incremental sink reads: per-row ingest-seq watermark for forward + blob sinks (LLP 0039/0040)#159

Draft

philcunliffe wants to merge 18 commits into

integration/incremental-sink-reads

Commits on Jun 25, 2026

Design: incremental sink reads (LLP 0040)

philcunliffe
and
claude
committed
Plan: incremental sink reads (LLP 0042)

philcunliffe
and
claude
committed
T1: stamp internal monotonic _hyp_ingest_seq at the decorateRow flush chokepoint

philcunliffe
and
claude
committed
Merge remote-tracking branch 'origin/task/incremental-sink-reads/T1' into integration/incremental-sink-reads
philcunliffe
committed
T2: extend storage read contract with cursor-aware incremental reads

philcunliffe
and
claude
committed
Merge remote-tracking branch 'origin/task/incremental-sink-reads/T2' into integration/incremental-sink-reads
philcunliffe
committed
T3: persisted per-(sink,partition) watermark store keyed by logical path

philcunliffe
and
claude
committed
Merge remote-tracking branch 'origin/task/incremental-sink-reads/T3' into integration/incremental-sink-reads
philcunliffe
committed
Wire central forward sink to incremental readRowsSince watermark

philcunliffe
and
claude
committed

Commits on Jun 26, 2026

Commits on Jun 29, 2026