Skip to main content

Module correction

mz_compute::sink

Module correction 

Source
Expand description

The Correction data structure used by persist_sink::write_batches to stash updates before they are written into batches.

Structs§

ConsolidatingVec 🔒
A vector that consolidates its contents.
CorrectionV1 🔒
A collection holding persist_sink updates.
LengthAndCapacity 🔒
Helper type for convenient tracking of length and capacity together.
Logging 🔒
Helper for correction buffer logging.
LoggingInner 🔒
Inner state for correction buffer logging.
SizeMetrics 🔒
Helper type for convenient tracking of various size metrics together.

Enums§

Correction 🔒
A data structure suitable for storing updates in a self-correcting persist sink.