Type Alias PbWatermark

pub type PbWatermark = Watermark;

Alias for Watermark.

Aliased Type

struct PbWatermark {
    pub column: Option<InputRef>,
    pub val: Option<Datum>,
}

Fields

column: Option<InputRef>

The reference to the watermark column in the stream’s schema.

val: Option<Datum>

The watermark value, there will be no record having a greater value in the watermark column.