timely::dataflow::operators::core

Module inspect

Source
Expand description

Extension trait and implementation for observing and action on streamed data.

Traitsยง

Inspect
Methods to inspect records and batches of records on a stream.
InspectCore
Inspect containers