Skip to main content

WindowAssigner

laminar_core::operator::window

Trait WindowAssigner 

Source 
pub trait WindowAssigner: Send {
    // Required method
    fn assign_windows(&self, timestamp: i64) -> WindowIdVec;

    // Provided method
    fn max_timestamp(&self, window_end: i64) -> i64 { ... }
}
Expand description

Trait for assigning events to windows.

Required Methods§

Source

fn assign_windows(&self, timestamp: i64) -> WindowIdVec

Assigns a timestamp to one or more windows.

Provided Methods§

Source

fn max_timestamp(&self, window_end: i64) -> i64

Maximum timestamp assignable to a window ending at window_end.

Implementors§