Struct 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>>,
    pub pushed: Vec<bool>,
}

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.

pushed: Vec<bool>

Outputs on which a scope sent records this activation, before reporting them as produced.

Only scopes set this: a scope reports records leaving it as produced only once its own progress updates have been exchanged. This lets its parent schedule the recipients sooner, which changes no counts. Ordinary operators report produced records directly.

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.