Skip to main content

Module enrich

Module enrich 

Source

Structs§

RowHashContract
What a run’s COL_ROW_HASH column actually covers, travelling with the data in the run manifest and the journal.

Constants§

COL_EXPORTED_AT
COL_ROW_HASH
ROW_HASH_RENDER_ID
The identity of the row hash’s rendering, recorded next to the data.

Functions§

enrich_batch
Add rivet’s columns to a RecordBatch, in enrich_schema’s order. exported_at_us is a single microsecond-precision UTC timestamp shared by all rows.
enrich_schema
Extend an Arrow schema with the columns rivet adds.
row_hash_array
The _rivet_row_hash column for a batch, over an already-resolved column set. Both sinks compute it here so neither can drift from the other’s rendering — the value’s only guarantee is that one function produces it.
row_hash_columns
The columns _rivet_row_hash covers, resolved against a real schema.
row_hash_columns_of
row_hash_columns over a bare name list — for the CDC seam, where the DATA columns are known before any Arrow schema exists, and where “all columns” must mean all data columns.