Struct TumblingAssigner 

pub struct TumblingAssigner { /* private fields */ }

Assigner for tumbling windows.

Implementations

impl TumblingAssigner

pub fn new(size: Duration) -> Self

Create a new tumbling window assigner.

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

Create a new tumbling window assigner with offset.

Trait Implementations

impl WindowAssigner for TumblingAssigner

fn assign_windows(&self, element: &StreamElement) -> Result<Vec<Window>>

Assign an element to one or more windows.

fn assigner_type(&self) -> &str

Get the window assigner type name.