public List<KuduColumnInfo> getColumns(String tableName) throws KuduException {
        // Open table and get column information.
        KuduTable kuduTable = client.openTable(tableName);
        List<ColumnSchema> columns = kuduTable.getSchema().getColumns();
        return columns
                .stream()
                .map(columnSchema -> {
                    String comment = columnSchema.getComment();
                    Type type = columnSchema.getType();
                    String name = columnSchema.getName();

                    String javaType = KuduType.forKuduType(type.getName()).getType();

                    KuduColumnInfo columnInfo = new KuduColumnInfo();
                    columnInfo.setFieldName(name);
                    columnInfo.setFieldType(javaType);
                    columnInfo.setFieldComment(comment);

                    return columnInfo;
                })
                .collect(Collectors.toList());
    }
Create table with given tableName and tableInfo.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/kudu/KuduResourceClient.java