Struct SessionAssigner 

pub struct SessionAssigner { /* private fields */ }

Assigner for session windows.

Implementations

impl SessionAssigner

pub fn new(gap: Duration) -> Self

Create a new session window assigner.

pub fn with_max_duration(gap: Duration, max_duration: Duration) -> Self

Create a new session window assigner with maximum duration.

Trait Implementations

impl WindowAssigner for SessionAssigner

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.