timely::dataflow::channels::pushers

Module counter

Source
Expand description

A wrapper which counts the number of records pushed past and updates a shared count map.

Structsยง

Counter
A wrapper which updates shared produced based on the number of records pushed.