Struct CountWindowAssigner 

pub struct CountWindowAssigner { /* private fields */ }

Count-based tumbling window assigner.

Creates windows based on element count rather than time.

Implementations

impl CountWindowAssigner

pub fn new(count: usize) -> Self

Creates a new count window assigner.

pub fn count(&self) -> usize

Returns the count per window.

Trait Implementations

impl Clone for CountWindowAssigner

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CountWindowAssigner

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

Formats the value using the given formatter.

impl WindowAssigner for CountWindowAssigner

type W = CountWindow

The window type produced by this assigner.

fn assign_windows(&self, _timestamp: DateTime<Utc>) -> Vec<Self::W>

Assign an element to zero or more windows.

fn default_trigger(&self) -> Box<dyn WindowTrigger<Self::W>>

Returns the default trigger for this assigner.

fn is_event_time(&self) -> bool

Returns true if this assigner produces event-time windows.