fn get_source_and_resolved_table_name(
session: &Arc<SessionImpl>,
cdc_table: CdcTableInfo,
table_name: ObjectName,
) -> Result<(Arc<SourceCatalog>, String, u32, u32), RwError>
fn get_source_and_resolved_table_name(
session: &Arc<SessionImpl>,
cdc_table: CdcTableInfo,
table_name: ObjectName,
) -> Result<(Arc<SourceCatalog>, String, u32, u32), RwError>