timely::dataflow::operators

Module branch

Source
Expand description

Operators that separate one stream into two streams based on some condition

Traitsยง

Branch
Extension trait for Stream.
BranchWhen
Extension trait for Stream.