Struct StatefulOperator 

pub struct StatefulOperator { /* private fields */ }

Stateful operator for maintaining state across events

Implementations

impl StatefulOperator

pub fn new() -> Self

pub fn set_state(&self, key: String, value: JsonValue)

Store state value

pub fn get_state(&self, key: &str) -> Option<JsonValue>

Get state value

pub fn add_to_window( &self, window_key: &str, event: Event, timestamp: DateTime<Utc>, )

Add event to window

pub fn get_window(&self, window_key: &str) -> Vec<Event>

Get events in window

pub fn evict_window(&self, window_key: &str, cutoff: DateTime<Utc>)

Evict expired events from window

pub fn clear(&self)

Clear all state

Trait Implementations

impl Default for StatefulOperator

fn default() -> Self

Returns the “default value” for a type.