fn pk_column_comparisons_from_infos(
pk_infos: &[(String, ColumnType)],
pk_names: &[String],
) -> ConnectorResult<Vec<CdcKeyComparison>>fn pk_column_comparisons_from_infos(
pk_infos: &[(String, ColumnType)],
pk_names: &[String],
) -> ConnectorResult<Vec<CdcKeyComparison>>