timely::dataflow::operators::core

Module map

Source
Expand description

Extension methods for StreamCore based on record-by-record transformation.

Structs§

FlatMapBuilder
A stream wrapper that allows the accumulation of flatmap logic.

Traits§

Map
Extension trait for Stream.