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.