Struct PartitionedTumblingWindow 

pub struct PartitionedTumblingWindow { /* private fields */ }

A partitioned tumbling window that maintains separate windows per partition key

Implementations

impl PartitionedTumblingWindow

pub fn new(partition_key: String, duration: Duration) -> Self

pub fn add_shared(&mut self, event: SharedEvent) -> Option<Vec<SharedEvent>>

Add a shared event to the appropriate partition window.

pub fn add(&mut self, event: Event) -> Option<Vec<Event>>

Add an event (wraps in Arc).

pub fn flush_shared(&mut self) -> Vec<SharedEvent>

Flush all partition windows as SharedEvent references.

pub fn flush(&mut self) -> Vec<Event>

Flush all partition windows (clones for backward compatibility).

pub fn checkpoint(&self) -> WindowCheckpoint

Create a checkpoint of all partition windows.

pub fn restore(&mut self, cp: &WindowCheckpoint)

Restore partition windows from a checkpoint.

pub fn advance_watermark( &mut self, wm: DateTime<Utc>, ) -> Vec<(String, Vec<SharedEvent>)>

Advance watermark across all partitions.

Trait Implementations

impl Debug for PartitionedTumblingWindow

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.