derive_with_options_for_cdc_table

risingwave_frontend::handler::create_table

Function derive_with_options_for_cdc_table 

Source 
fn derive_with_options_for_cdc_table(
    source_with_properties: &WithOptionsSecResolved,
    external_table_name: String,
) -> Result<(WithOptionsSecResolved, String)>
Expand description

Derive connector properties and normalize external_table_name for CDC tables.

Returns (connector_properties, normalized_external_table_name) where:

  • For SQL Server: Normalizes ‘db.schema.table’ (3 parts) to ‘schema.table’ (2 parts), because users can optionally include database name for verification, but it needs to be stripped to match the format returned by Debezium’s extract_table_name().
  • For MySQL/Postgres: Returns the original external_table_name unchanged.