Struct timely::progress::reachability::PortInformation

pub struct PortInformation<T: Timestamp> {
    pub pointstamps: MutableAntichain<T>,
    pub implications: MutableAntichain<T>,
    pub output_summaries: Vec<Antichain<T::Summary>>,
}

Per-port progress-tracking information.

Fields

pointstamps: MutableAntichain<T>

Current counts of active pointstamps.

implications: MutableAntichain<T>

Current implications of active pointstamps across the dataflow.

output_summaries: Vec<Antichain<T::Summary>>

Path summaries to each of the scope outputs.

Implementations

impl<T: Timestamp> PortInformation<T>

pub fn new() -> Self

Creates empty port information.

pub fn is_global(&self, time: &T) -> bool

True if updates at this pointstamp uniquely block progress.

This method returns true if the currently maintained pointstamp counts are such that zeroing out outstanding updates at this pointstamp would change the frontiers at this operator. When the method returns false it means that, temporarily at least, there are outstanding pointstamp updates that are strictly less than this pointstamp.

Trait Implementations

impl<T: Clone + Timestamp> Clone for PortInformation<T>

where T::Summary: Clone,

fn clone(&self) -> PortInformation<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Timestamp> Default for PortInformation<T>

fn default() -> Self

Returns the “default value” for a type.