Struct TumblingWindow 

pub struct TumblingWindow { /* private fields */ }

Tumbling window (fixed, non-overlapping windows).

Implementations

impl TumblingWindow

pub fn new(size: Duration) -> Self

Create a new tumbling window.

pub fn with_offset(size: Duration, offset: Duration) -> Self

Create a new tumbling window with offset.

pub fn get_window(&self, timestamp: DateTime<Utc>) -> Result<Window>

Get the window for a given timestamp.

Trait Implementations

impl Clone for TumblingWindow

fn clone(&self) -> TumblingWindow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TumblingWindow

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

Formats the value using the given formatter.