source_add_partition_offset_cols

risingwave_connector::parser::additional_columns

Function source_add_partition_offset_cols 

Source 
pub fn source_add_partition_offset_cols(
    columns: &[ColumnCatalog],
    connector_name: &str,
    skip_col_id: bool,
) -> ([bool; 2], [ColumnDesc; 2])
Expand description

Utility function for adding partition and offset columns to the columns, if not specified by the user.

ยงReturns

  • columns_exist: whether 1. partition/file and 2. offset columns are included in columns.
  • additional_columns: The ColumnCatalog for partition/file and offset columns.