Enum WindowPolicy 

pub enum WindowPolicy {
    Tumbling {
        size: Duration,
    },
    Sliding {
        size: Duration,
        slide: Duration,
    },
    Session {
        idle: Duration,
    },
}

Available on crate feature std only.

Window emission strategy.

Pass to crate::PipelineBuilder::window to install a windowing stage. The carrier type changes from T to Window<T> after the call.

Variants

Tumbling

Fixed-width, non-overlapping windows. The first window starts when the first item arrives; subsequent windows are anchored at multiples of size from that point.

Fields

size: Duration

Width of each window.

Sliding

Overlapping windows of width size. A new window starts every slide interval. Each item is duplicated into every active window, so the item type must be Clone.

Fields

size: Duration

Width of each window.

slide: Duration

Time between successive window starts.

Session

Adaptive window that stays open as long as new items arrive within idle. Closes (and emits) on the next item arriving after idle has elapsed since the last item, or at end-of-stream.

Fields

idle: Duration

Idle gap after which the window closes.

Trait Implementations

impl Clone for WindowPolicy

fn clone(&self) -> WindowPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowPolicy

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

Formats the value using the given formatter.

impl PartialEq for WindowPolicy

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for WindowPolicy

impl Eq for WindowPolicy

impl StructuralPartialEq for WindowPolicy