Struct WindowFunction 

pub struct WindowFunction;

Stateless windowing utility.

Implementations

impl WindowFunction

pub fn apply(data: &[DataPoint], window_type: &WindowType) -> WindowResult

Apply the specified WindowType to data and return the result.

pub fn tumbling(data: &[DataPoint], size_ms: i64) -> Vec<Window>

Compute non-overlapping (tumbling) windows of size_ms milliseconds.

Windows are aligned to multiples of size_ms from epoch 0. Empty windows between the first and last occupied window are included.

pub fn sliding(data: &[DataPoint], size_ms: i64, step_ms: i64) -> Vec<Window>

Compute overlapping (sliding) windows of size_ms, advanced by step_ms.

A window [t, t+size_ms) is created for every t = floor(first/step)*step, ... up to the last timestamp. If step_ms >= size_ms the windows do not overlap.

pub fn session(data: &[DataPoint], gap_ms: i64) -> Vec<Window>

Compute session windows: a new window opens on each point and closes when the gap to the next point exceeds gap_ms.

pub fn aggregate(window: &Window) -> WindowAggregation

Compute aggregated statistics for a single window.

pub fn aggregate_all(result: &WindowResult) -> Vec<WindowAggregation>

Aggregate every window in a WindowResult.

pub fn by_key( data: &[DataPoint], window_type: &WindowType, ) -> HashMap<String, WindowResult>

Group data by DataPoint::key, apply the window type to each group, and return a map of key → WindowResult.

Points with key = None are grouped under the empty string "".