public static void addColumnFamilies(String zkAddress, String zkNode, String namespace, String qualifier,
            List<HBaseColumnFamilyInfo> columnFamilies) throws Exception {
        TableName tableName = TableName.valueOf(namespace, qualifier);
        try (Connection conn = getConnection(zkAddress, zkNode)) {
            Admin admin = conn.getAdmin();
            admin.disableTable(tableName);
            try {
                for (HBaseColumnFamilyInfo info : columnFamilies) {
                    admin.addColumnFamily(tableName, ColumnFamilyDescriptorBuilder.of(info.getCfName()));
                }
            } finally {
                admin.enableTable(tableName);
            }
        }
    }
Add column families for hbase table
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hbase/HBaseApiUtils.java