Struct WindowState 

pub struct WindowState {
    pub events: Vec<WindowEvent>,
    pub window_layout: Option<WindowLayout>,
    pub window_start: u64,
    pub event_count: u64,
    pub last_event_time: u64,
}

State for a single window

Fields

events: Vec<WindowEvent>

All events in this window (stored in insertion order)

window_layout: Option<WindowLayout>

RowSchema layout shared by all events (set on first event)

window_start: u64

Window creation timestamp

event_count: u64

Count of events in window (for count-based windows)

last_event_time: u64

Timestamp of last event (for session windows)

Implementations

impl WindowState

pub fn layout(&self) -> &WindowLayout

Get the layout, panics if not set (should always be set after first event)

Trait Implementations

impl Clone for WindowState

fn clone(&self) -> WindowState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowState

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

Formats the value using the given formatter.

impl Default for WindowState

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WindowState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WindowState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.