Struct coord::coord::arrangement_state::SinkWrites

pub struct SinkWrites<T: Timestamp> {
    pub frontier: MutableAntichain<T>,
    pub source_handles: Vec<AntichainToken<T>>,
}

Track sink state for which timestamps the sink has written out.

Fields

frontier: MutableAntichain<T>

The write frontier for the sink, ie all subsequent writes will be at timestamps that are at or in advance of this frontier.

source_handles: Vec<AntichainToken<T>>

Set of handles to sources that the sink transitively depends on. We hold back all of these sources’ since frontiers to trail the sink’s write frontier and allow the since frontier to advance as the sink’s write frontier advances.

Implementations

impl<T: Timestamp> SinkWrites<T>

pub fn new(source_handles: Vec<AntichainToken<T>>) -> Self

pub fn advance_source_handles(&mut self)

Allow all sources that the sink transitively depends on to advance their compaction/since frontiers up to the sink’s write frontier, if they so choose.

This function needs to be called periodically, otherwise sink’s source dependencies will never compact their timestamp bindings in memory or in the catalog. However, this doesn’t have to happen in lockstep with write frontier updates.