Struct timely::progress::operate::SharedProgress

pub struct SharedProgress<T: Timestamp> {
    pub frontiers: Vec<ChangeBatch<T>>,
    pub consumeds: Vec<ChangeBatch<T>>,
    pub internals: Vec<ChangeBatch<T>>,
    pub produceds: Vec<ChangeBatch<T>>,
}

Progress information shared between parent and child.

Fields

frontiers: Vec<ChangeBatch<T>>

Frontier capability changes reported by the parent scope.

consumeds: Vec<ChangeBatch<T>>

Consumed message changes reported by the child operator.

internals: Vec<ChangeBatch<T>>

Internal capability changes reported by the child operator.

produceds: Vec<ChangeBatch<T>>

Produced message changes reported by the child operator.

Implementations

impl<T: Timestamp> SharedProgress<T>

pub fn new(inputs: usize, outputs: usize) -> Self

Allocates a new shared progress structure.

Trait Implementations

impl<T: Debug + Timestamp> Debug for SharedProgress<T>

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

Formats the value using the given formatter.