private List<HBaseColumnFamilyInfo> getColumnFamilies(SinkInfo sinkInfo) {
        List<StreamSinkFieldEntity> fieldList = sinkFieldMapper.selectBySinkId(sinkInfo.getId());
        Set<String> seen = new HashSet<>();

        List<HBaseColumnFamilyInfo> columnFamilies = new ArrayList<>();
        for (StreamSinkFieldEntity field : fieldList) {
            HBaseColumnFamilyInfo columnFamily = HBaseColumnFamilyInfo.getFromJson(field.getExtParams());
            if (seen.contains(columnFamily.getCfName())) {
                continue;
            }
            seen.add(columnFamily.getCfName());
            columnFamilies.add(columnFamily);
        }

        return columnFamilies;
    }
Create hbase table according to the sink config
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hbase/HBaseResourceOperator.java