private static Triple getNames()

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);
    }