Struct timely::progress::reachability::PortInformation
source · pub struct PortInformation<T: Timestamp> {
pub pointstamps: MutableAntichain<T>,
pub implications: MutableAntichain<T>,
pub output_summaries: Vec<Antichain<T::Summary>>,
}
Expand description
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§
source§impl<T: Timestamp> PortInformation<T>
impl<T: Timestamp> PortInformation<T>
sourcepub fn is_global(&self, time: &T) -> bool
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§
source§impl<T: Clone + Timestamp> Clone for PortInformation<T>
impl<T: Clone + Timestamp> Clone for PortInformation<T>
source§fn clone(&self) -> PortInformation<T>
fn clone(&self) -> PortInformation<T>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl<T> Freeze for PortInformation<T>
impl<T> RefUnwindSafe for PortInformation<T>
impl<T> Send for PortInformation<T>
impl<T> Sync for PortInformation<T>
impl<T> Unpin for PortInformation<T>
impl<T> UnwindSafe for PortInformation<T>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)