How a write becomes durable

Follow a mutation from the query executor through in-memory staging, the single manifest-publish CAS fence, and crash recovery — the heart of Omnigraph's atomicity guarantee.

Strategy

Ordered, row-by-row cursor merge:

OrderedTableCursor scans each table sorted by id and supports peek/pop matching.
StagedTableWriter buffers MERGE_STAGE_BATCH_ROWS = 8192 rows into a temp Lance dataset (OMNIGRAPH_MERGE_STAGING_DIR).
The merge runs per sub-table; results are published as one atomic manifest update.