Skip to main content

META_PARTITION

Constant META_PARTITION 

Source
pub const META_PARTITION: &'static str;
Expand description

The meta column that carries a row’s origin: the Kafka partition it came from, or the id of the operator task that produced it. A stateful operator observes event time per origin — the min across origins is its watermark, exactly as one consumer thread’s operator observes per assigned partition.