Enum Msg 

pub enum Msg {
    Data(RecordBatch),
    Watermark {
        source: TaskId,
        ts: Option<i64>,
    },
    Barrier {
        epoch: u64,
    },
    Tick {
        now_ms: i64,
    },
    Eos,
}

What flows on an edge.

Variants

Data(RecordBatch)

Watermark

The time of source (a source task id) as seen by the sender; None = the source is idle.

Fields

source: TaskId

ts: Option<i64>

Barrier

Fields

epoch: u64

Tick

Processing time passes with nothing else to say: a source that polled nothing sends one (at most ten a second), and every task forwards at most ten a second. Operators with processing-time work (bounded idleness, ingest-time windows) advance on it.

Fields

now_ms: i64

Eos

The upstream is done (clean shutdown flows downstream in order).

Trait Implementations

impl Clone for Msg

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Msg

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

Formats the value using the given formatter.