Struct SlidingAssigner 

pub struct SlidingAssigner { /* private fields */ }

Assigner for sliding windows.

Implementations

impl SlidingAssigner

pub fn new(size: Duration, slide: Duration) -> Self

Create a new sliding window assigner.

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

Create a new sliding window assigner with offset.

Trait Implementations

impl WindowAssigner for SlidingAssigner

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.