risingwave_common::catalog

Function offset_column_desc

source 
pub fn offset_column_desc() -> ColumnDesc
Expand description

Creates a offset column for storing upstream offset Used in cdc source currently