Struct StatefulOperator 

pub struct StatefulOperator<F>
where
    F: Fn(&mut StateStore, &StreamEvent) -> StateResult<Option<Value>>,
{ /* private fields */ }

Stateful operator that maintains state across events

Implementations

impl<F> StatefulOperator<F>

where F: Fn(&mut StateStore, &StreamEvent) -> StateResult<Option<Value>>,

pub fn new(state: StateStore, process_fn: F) -> Self

Create a new stateful operator

pub fn process(&mut self, event: &StreamEvent) -> StateResult<Option<Value>>

Process an event through the stateful operator

pub fn state(&self) -> &StateStore

Get reference to state store

pub fn state_mut(&mut self) -> &mut StateStore

Get mutable reference to state store

pub fn checkpoint(&mut self, name: impl Into<String>) -> StateResult<String>

Create a checkpoint

pub fn restore(&mut self, checkpoint_id: &str) -> StateResult<()>

Restore from checkpoint