private Map<String, List<FieldRelation>> genColumnFamilyMapFieldRelations(
            Collection<FieldRelation> fieldRelations) {
        Map<String, List<FieldRelation>> columnFamilyMapFields = new LinkedHashMap<>(16);
        Set<String> nameSet = new HashSet<>();
        for (FieldRelation fieldRelation : fieldRelations) {
            String columnFamily = fieldRelation.getOutputField().getName().split(":")[0];
            if (nameSet.add(fieldRelation.getOutputField().getName())) {
                columnFamilyMapFields.computeIfAbsent(columnFamily, v -> new ArrayList<>())
                        .add(fieldRelation);
            }
        }
        return columnFamilyMapFields;
    }
Gen create table DDL for hbase load
inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/FlinkSqlParser.java