Struct WindowStatefulTestHelper 

pub struct WindowStatefulTestHelper { /* private fields */ }

Implementations

impl WindowStatefulTestHelper

pub fn new(shape: RowShape, window_size: i64) -> Self

pub fn time_window_counter(window_size_seconds: i64) -> Self

pub fn count_window_sum(window_size_count: i64) -> Self

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

where K: IntoEncodedKey,

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

where K: IntoEncodedKey,

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

where K: IntoEncodedKey,

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

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

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

pub fn window_count(&self) -> usize

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

pub fn clear(&mut self)

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

pub fn assert_window_count(&self, expected: usize)

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