Struct WindowMetadata 

pub struct WindowMetadata {
    pub window: Window,
    pub stats: WindowStats,
    pub triggered: bool,
}

Metadata for an active window

Fields

window: Window

The window definition

stats: WindowStats

Statistics for this window

triggered: bool

Whether this window has been triggered

Implementations

impl WindowMetadata

pub fn new(window: Window) -> Self

Create new window metadata

pub fn record_event(&mut self, event_time: DateTime<Utc>)

Update with a new event

pub fn check_trigger<T: WindowTrigger>( &mut self, trigger: &mut T, watermark: Option<DateTime<Utc>>, ) -> TriggerResult

Check if the window should be triggered

pub fn close(&mut self)

Close this window

Trait Implementations

impl Clone for WindowMetadata

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowMetadata

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

Formats the value using the given formatter.