in src/main/java/com/aliyun/dts/subscribe/clients/record/AvroRecordParser.java [47:70]
private static Triple<String, String, String> getNames(String mixedNames) {
String dbName = null;
String schemaName = null;
String tableName = null;
String[] dbPair = ObjectNameUtils.uncompressionObjectName(mixedNames);
if (dbPair != null) {
if (dbPair.length == 2) {
dbName = dbPair[0];
tableName = dbPair[1];
schemaName = dbPair[0];
} else if (dbPair.length == 3) {
dbName = dbPair[0];
schemaName = dbPair[1];
tableName = dbPair[2];
} else if (dbPair.length == 1) {
dbName = dbPair[0];
} else {
throw new DTSBaseException("Invalid db table name pair for mixed [" + mixedNames + "]");
}
}
return Triple.of(dbName, schemaName, tableName);
}