Struct timely::progress::nested::pointstamp_counter::PointstampCounter
[−]
[src]
pub struct PointstampCounter<T: Timestamp> {
pub source: Vec<Vec<ChangeBatch<T>>>,
pub target: Vec<Vec<ChangeBatch<T>>>,
pub pushed: Vec<Vec<ChangeBatch<T>>>,
}Represents changes to pointstamps before and after transmission along a scope's topology.
Fields
source: Vec<Vec<ChangeBatch<T>>>
timestamp updates indexed by (scope, output)
target: Vec<Vec<ChangeBatch<T>>>
timestamp updates indexed by (scope, input)
pushed: Vec<Vec<ChangeBatch<T>>>
pushed updates indexed by (scope, input)
Methods
impl<T: Timestamp> PointstampCounter<T>[src]
pub fn update_target(&mut self, target: Target, time: T, value: i64)[src]
Updates the count for a time at a target.
pub fn update_source(&mut self, source: Source, time: T, value: i64)[src]
Updates the count for a time at a source.
pub fn clear(&mut self)[src]
Clears the pointstamp counter.
pub fn allocate_for_operator(&mut self, inputs: usize, outputs: usize)[src]
Allocates internal state given an operator's inputs and outputs.
Trait Implementations
impl<T: Default + Timestamp> Default for PointstampCounter<T>[src]
fn default() -> PointstampCounter<T>[src]
Returns the "default value" for a type. Read more