Skip to main content

validate_row_lineage_column_names

risingwave_connector::sink::iceberg::create_table

Function validate_row_lineage_column_names 

Source 
pub fn validate_row_lineage_column_names(
    format_version: FormatVersion,
    columns: &[ColumnDesc],
) -> Result<()>
Expand description

Iceberg V3 stores row lineage in data files as the reserved _row_id and _last_updated_sequence_number columns. A table column with either name is ambiguous with the lineage metadata column, so reject it when creating a V3 table.