pub type PbWatermark = Watermark;Aliased Type§
pub 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.