public void addColumns(String tableName,
            List<KuduColumnInfo> needAddColumns)
            throws KuduException {
        // Create Kudu client and open table
        KuduTable table = client.openTable(tableName);

        // Add new column to table
        AlterTableOptions alterOptions = new AlterTableOptions();
        for (KuduColumnInfo columnInfo : needAddColumns) {
            String name = columnInfo.getFieldName();
            String type = columnInfo.getFieldType();
            String desc = columnInfo.getFieldComment();

            String kuduType = KuduType.forType(type).kuduType();
            Type typeForName = Type.getTypeForName(kuduType);

            ColumnSchema columnSchema = buildColumnSchema(name, desc, typeForName);

            alterOptions.addColumn(columnSchema);
        }
        client.alterTable(table.getName(), alterOptions);
    }
Create table with given tableName and tableInfo.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/kudu/KuduResourceClient.java