Enum StreamWindow 

pub enum StreamWindow {
    Count(usize),
    Duration(Duration),
}

Tumbling-window trigger: how often flush_window fires and how much the driver buffers. Defaults to per-item (Count(1)); larger windows amortise flush + checkpoint cost.

Variants

Count(usize)

Flush after this many successfully processed items (clamped to a minimum of 1). The cursor committed for this window is the Cursor of the last item processed in the batch.

Duration(Duration)

Flush after this much wall-clock elapses, tumbling — clamped to a minimum of 1ms (a zero duration would otherwise starve the source; see the clamp in the driver). Empty windows are skipped (no flush_window call) so an idle source does not emit spurious empty flushes. When the window finally contains items, the cursor committed is the Cursor of the last item processed during that interval. Unlike Count, buffering is bounded only by what the source yields during the interval.

Trait Implementations

impl Clone for StreamWindow

fn clone(&self) -> StreamWindow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamWindow

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

Formats the value using the given formatter.

impl Eq for StreamWindow

impl PartialEq for StreamWindow

fn eq(&self, other: &StreamWindow) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamWindow