Struct WindowStatefulTestHelper 

pub struct WindowStatefulTestHelper { /* private fields */ }

Test helper for FFIWindowStateful operators

Implementations

impl WindowStatefulTestHelper

pub fn new(layout: EncodedValuesLayout, window_size: i64) -> Self

Create a new window stateful test helper

pub fn time_window_counter(window_size_seconds: i64) -> Self

Create with a counter layout for time windows

pub fn count_window_sum(window_size_count: i64) -> Self

Create with a sum layout for count windows

pub fn set_window_state<K>(&mut self, window_id: i64, key: K, values: &[Value])

where K: IntoEncodedKey,

Set state for a window and key

pub fn get_window_state<K>(&self, window_id: i64, key: K) -> Option<Vec<Value>>

where K: IntoEncodedKey,

Get state for a window and key

pub fn assert_window_state<K>(&self, window_id: i64, key: K, expected: &[Value])

where K: IntoEncodedKey,

Assert state for a window and key

pub fn get_window( &self, window_id: i64, ) -> Option<&HashMap<EncodedKey, EncodedValues>>

Get all states for a window

pub fn remove_window( &mut self, window_id: i64, ) -> Option<HashMap<EncodedKey, EncodedValues>>

Remove a window

pub fn has_window(&self, window_id: i64) -> bool

Check if a window exists

pub fn window_count(&self) -> usize

Get the number of windows

pub fn window_key_count(&self, window_id: i64) -> usize

Get the number of keys in a window

pub fn clear(&mut self)

Clear all windows

pub fn window_ids(&self) -> Vec<i64>

Get all window IDs

pub fn assert_window_count(&self, expected: usize)

Assert the number of windows

pub fn window_for_timestamp(&self, timestamp: i64) -> i64

Calculate the window ID for a timestamp