Function mz_txn_wal::apply_caa

source · 
pub(crate) async fn apply_caa<K, V, T, D>(
    data_write: &mut DataWriteApply<K, V, T, D>,
    batch_raws: &Vec<&[u8]>,
    commit_ts: T,
)
where
    K: Debug + Codec,
    V: Debug + Codec,
    T: Timestamp + Lattice + TotalOrder + StepForward + Codec64 + Sync,
    D: Semigroup + Ord + Codec64 + Send + Sync,
Expand description

Ensures that a committed batch has been applied into a physical data shard, making it available for reads.

This process is definite work on top of definite input, so the implementation assumes that if the upper of the shard passes commit_ts then the work must have already been done by someone else. (Think how our compute replicas race to compute some MATERIALIZED VIEW, but they’re all guaranteed to get the same answer.)