Inspired by the approach of timely, add extension traits that can be implemented for various stream types. Makes things more extensible when we introduce other stream types (e.g., KeyedStream, ArrowStream).
Removes set_channel_kind for now, more partitioning schemes (e.g., broadcast) can be added to the PartitionExt trait.
Inspired by the approach of timely, add extension traits that can be implemented for various stream types. Makes things more extensible when we introduce other stream types (e.g., KeyedStream, ArrowStream).
Removes
set_channel_kindfor now, more partitioning schemes (e.g., broadcast) can be added to thePartitionExttrait.