Enum EmitStrategy 

pub enum EmitStrategy {
    OnWatermark,
    OnWindowClose,
    Periodic(Duration),
    OnUpdate,
    Changelog,
    FinalOnly,
}

Emit strategy for runtime operator configuration.

This is the runtime representation that operators use.

Variants

OnWatermark

Emit when watermark passes window end

OnWindowClose

Emit only when window closes (no intermediate results)

Periodic(Duration)

Emit at fixed intervals

OnUpdate

Emit on every state change

Changelog

Emit changelog records with Z-set weights

FinalOnly

Emit only final results, suppress all intermediate

Trait Implementations

impl Clone for EmitStrategy

fn clone(&self) -> EmitStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EmitStrategy

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

Formats the value using the given formatter.

impl PartialEq for EmitStrategy

fn eq(&self, other: &EmitStrategy) -> 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 StructuralPartialEq for EmitStrategy