Struct WindowState 

pub struct WindowState<W: Window, T> {
    pub window: W,
    pub elements: Vec<(DateTime<Utc>, T)>,
    pub count: usize,
    pub triggered: bool,
    pub last_watermark: Option<Watermark>,
}

Tracks the state of a window including its watermark context.

Fields

window: W

The window this state belongs to.

elements: Vec<(DateTime<Utc>, T)>

Elements currently in the window.

count: usize

Count of elements.

triggered: bool

Whether the window has been triggered.

last_watermark: Option<Watermark>

Last watermark that affected this window.

Implementations

impl<W: Window, T: Clone> WindowState<W, T>

pub fn new(window: W) -> Self

Creates a new window state.

pub fn add(&mut self, timestamp: DateTime<Utc>, element: T)

Adds an element to the window.

pub fn update_watermark(&mut self, watermark: Watermark)

Updates the watermark for this window.

pub fn can_be_gc( &self, current_watermark: &Watermark, allowed_lateness: ChronoDuration, ) -> bool

Returns true if the window should be garbage collected.

A window can be GC’d if it has been triggered and the watermark has passed the window’s end time plus allowed lateness.

pub fn clear(&mut self)

Clears all elements from the window.

pub fn mark_triggered(&mut self)

Marks the window as triggered.

pub fn elements(&self) -> &[(DateTime<Utc>, T)]

Returns the elements as a slice.

pub fn values(&self) -> Vec<T>

Extracts the element values without timestamps.

Trait Implementations

impl<W: Window, T: Clone> Clone for WindowState<W, T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<W: Debug + Window, T: Debug> Debug for WindowState<W, T>

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

Formats the value using the given formatter.