Struct timely::dataflow::channels::pullers::counter::Counter

pub struct Counter<T: Ord + Clone + 'static, D, P: Pull<(T, Content<D>)>> { /* fields omitted */ }

A wrapper which accounts records pulled past in a shared count map.

Methods

impl<T: Ord + Clone + 'static, D, P: Pull<(T, Content<D>)>> Counter<T, D, P>

pub fn next(&mut self) -> Option<(&T, &mut Content<D>)>

Retrieves the next timestamp and batch of data.

impl<T: Ord + Clone + 'static, D, P: Pull<(T, Content<D>)>> Counter<T, D, P>

pub fn new(pullable: P) -> Self

Allocates a new Counter from a boxed puller.

pub fn consumed(&self) -> &Rc<RefCell<ChangeBatch<T>>>

A references to shared changes in counts, for cloning or draining.