in src/main/java/com/aliyun/dts/subscribe/clients/record/DefaultRecordSchema.java [114:140]
public void ignoreField(RecordField field) {
String fieldName = field.getFieldName();
LOGGER.info("The field {} is ignored.", fieldName);
if (null != nameIndex.remove(fieldName)) {
recordFields.remove(field);
}
// check primary key
if (field.isPrimary()) {
List<RecordIndexInfo> newIndexInfo = removeFiledFromIndexInfoList(Arrays.asList(primaryIndexInfo), field);
if (null != newIndexInfo && !newIndexInfo.isEmpty()) {
primaryIndexInfo = newIndexInfo.get(0);
} else {
primaryIndexInfo = null;
}
}
// check unique key
if (field.isUnique()) {
uniqueIndexInfo = removeFiledFromIndexInfoList(uniqueIndexInfo, field);
}
// check normal index
if (field.isIndexed()) {
normalIndexInfo = removeFiledFromIndexInfoList(normalIndexInfo, field);
}
}