Module timely::dataflow::channels::pushers::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.