Struct KeyedStream 

pub struct KeyedStream<K>
where
    K: Hash + Eq,
{ /* private fields */ }

A stream of events keyed by a specific field

Implementations

impl<K> KeyedStream<K>

where K: Hash + Eq + Clone,

pub fn reduce<F>(self, reducer: F) -> HashMap<K, StreamEvent>

where F: Fn(StreamEvent, StreamEvent) -> StreamEvent,

Reduce events within each key

pub fn aggregate<A>(self, aggregator: A) -> HashMap<K, AggregateResult>

where A: Aggregation + Clone,

Apply aggregation to each key group

pub fn window(self, config: WindowConfig) -> KeyedWindowedStream<K>

Apply a window to each key group

pub fn count(self) -> HashMap<K, usize>

Count events per key

pub fn keys(&self) -> Vec<K>

Get all keys

pub fn flatten(self) -> DataStream

Flatten back to a regular stream