risingwave_frontend::handler::create_source

Function bind_columns_from_source_for_cdc

source 
fn bind_columns_from_source_for_cdc(
    session: &SessionImpl,
    format_encode: &FormatEncodeOptions,
) -> Result<(Option<Vec<ColumnCatalog>>, StreamSourceInfo), RwError>