Enum Output 

pub enum Output {
    Event(Event),
    Watermark(i64),
    LateEvent(Event),
    SideOutput {
        name: String,
        event: Event,
    },
    Changelog(ChangelogRecord),
    CheckpointComplete {
        checkpoint_id: u64,
        operator_states: Vec<OperatorState>,
    },
}

Output from an operator

Variants

Event(Event)

Regular event output

Watermark(i64)

Watermark update

LateEvent(Event)

Late event that arrived after watermark (no side output configured)

SideOutput

Late event routed to a named side output

Fields

name: String

The name of the side output to route to

event: Event

The late event

Changelog(ChangelogRecord)

Changelog record with Z-set weight (F011B).

Used by EmitStrategy::Changelog to emit structured change records for CDC pipelines and cascading materialized views.

CheckpointComplete

Checkpoint completion with snapshotted operator states.

Emitted when a CheckpointRequest is processed by a core thread. Carries the checkpoint ID and all operator states for persistence by Ring 1.

Fields

checkpoint_id: u64

The checkpoint ID from the request

operator_states: Vec<OperatorState>

Snapshotted states from all operators on this core

Trait Implementations

impl Debug for Output

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

Formats the value using the given formatter.