Struct mz_compute_client::service::TrackedFrontiers

struct TrackedFrontiers<T> {
    write_frontier: (MutableAntichain<T>, Vec<Antichain<T>>),
    input_frontier: (MutableAntichain<T>, Vec<Antichain<T>>),
    output_frontier: (MutableAntichain<T>, Vec<Antichain<T>>),
}

Tracked frontiers for an index or a sink collection.

Each frontier is maintained both as a MutableAntichain across all partitions and individually for each partition.

Fields

write_frontier: (MutableAntichain<T>, Vec<Antichain<T>>)

The tracked write frontier.

input_frontier: (MutableAntichain<T>, Vec<Antichain<T>>)

The tracked input frontier.

output_frontier: (MutableAntichain<T>, Vec<Antichain<T>>)

The tracked output frontier.

Implementations

impl<T> TrackedFrontiers<T>

where T: Timestamp + Lattice,

fn new(parts: usize) -> Self

Initializes frontier tracking state for a new collection.

fn all_empty(&self) -> bool

Returns whether all tracked frontiers have advanced to the empty frontier.

fn update_write_frontier( &mut self, shard_id: usize, new_shard_frontier: &Antichain<T>, ) -> Option<Antichain<T>>

Updates write frontier tracking with a new shard frontier.

If this causes the global write frontier to advance, the advanced frontier is returned.

fn update_input_frontier( &mut self, shard_id: usize, new_shard_frontier: &Antichain<T>, ) -> Option<Antichain<T>>

Updates input frontier tracking with a new shard frontier.

If this causes the global input frontier to advance, the advanced frontier is returned.

fn update_output_frontier( &mut self, shard_id: usize, new_shard_frontier: &Antichain<T>, ) -> Option<Antichain<T>>

Updates output frontier tracking with a new shard frontier.

If this causes the global output frontier to advance, the advanced frontier is returned.

fn update_frontier( entry: &mut (MutableAntichain<T>, Vec<Antichain<T>>), shard_id: usize, new_shard_frontier: &Antichain<T>, ) -> Option<Antichain<T>>

Updates the provided frontier entry with a new shard frontier.

Trait Implementations

impl<T: Debug> Debug for TrackedFrontiers<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.