Enum EmitStrategy 

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

Strategy for when window results should be emitted.

Variants

OnWatermark

Emit when watermark passes window end (default, most efficient).

Periodic(Duration)

Emit intermediate results at fixed intervals, plus final on watermark.

OnUpdate

Emit after every state change (lowest latency, highest overhead).

OnWindowClose

Emit only when window closes. Append-only safe, no retractions. SQL: EMIT ON WINDOW CLOSE

Changelog

Emit changelog records with Z-set weights for CDC pipelines. SQL: EMIT CHANGES

Final

Suppress all intermediate results, emit only finalized. SQL: EMIT FINAL

Implementations

impl EmitStrategy

pub fn needs_periodic_timer(&self) -> bool

Returns true if this strategy requires periodic timer registration.

pub fn periodic_interval(&self) -> Option<Duration>

Returns the periodic interval if this is a periodic strategy.

pub fn emits_on_update(&self) -> bool

Returns true if results should be emitted on every update.

pub fn emits_intermediate(&self) -> bool

Returns true if this strategy emits intermediate results before window close.

pub fn requires_changelog(&self) -> bool

Returns true if this strategy requires changelog/Z-set support.

pub fn is_append_only_compatible(&self) -> bool

Returns true if safe for append-only sinks (no retractions).

pub fn generates_retractions(&self) -> bool

Returns true if late data should generate retractions.

pub fn suppresses_intermediate(&self) -> bool

Returns true if this strategy should suppress intermediate emissions.

pub fn drops_late_data(&self) -> bool

Returns true if late data should be dropped entirely.

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 Default for EmitStrategy

fn default() -> EmitStrategy

Returns the “default value” for a type.

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 Eq for EmitStrategy

impl StructuralPartialEq for EmitStrategy