risingwave_pb::stream_plan::barrier

Type Alias PbBarrierKind

source
pub type PbBarrierKind = BarrierKind;
Expand description

Alias for BarrierKind.

Aliased Type§

enum PbBarrierKind {
    Unspecified = 0,
    Initial = 1,
    Barrier = 2,
    Checkpoint = 3,
}

Variants§

§

Unspecified = 0

§

Initial = 1

The first barrier after a fresh start or recovery. There will be no data associated with the previous epoch of the barrier.

§

Barrier = 2

A normal barrier. Data should be flushed locally.

§

Checkpoint = 3

A checkpoint barrier. Data should be synchorized to the shared storage.