risingwave_frontend::handler::create_source

Function debezium_cdc_source_schema

source 
pub fn debezium_cdc_source_schema() -> Vec<ColumnCatalog>
Expand description

Note: these columns are added in SourceStreamChunkRowWriter::do_action. May also look for the usage of SourceColumnType.