Struct ReduceOperator 

pub struct ReduceOperator<F>
where
    F: ReduceFunction,
{ /* private fields */ }

Reduce operator.

Implementations

impl<F> ReduceOperator<F>

where F: ReduceFunction,

pub fn new(reduce_fn: F) -> Self

Create a new reduce operator.

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

Process an element.

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

Get the current state for a key.

pub async fn clear(&self)

Clear all state.