Struct AggregateOperator 

pub struct AggregateOperator<F>
where
    F: AggregateFunction,
{ /* private fields */ }

Aggregate operator.

Implementations

impl<F> AggregateOperator<F>

where F: AggregateFunction,

pub fn new(aggregate_fn: F) -> Self

Create a new aggregate operator.

pub async fn process(&self, element: StreamElement) -> Result<StreamElement>

Process an element.

pub async fn get_result(&self, key: Option<Vec<u8>>) -> Vec<u8>

Get the current result for a key.

pub async fn clear(&self)

Clear all state.