从java更新elasticsearch中嵌套类型内的字段

import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.index.VersionType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.script.Script;
import org.elasticsearch.script.ScriptType;
import org.elasticsearch.script.mustache.SearchTemplateRequestBuilder;
import org.elasticsearch.script.mustache.SearchTemplateResponse;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class ElasticsearchUpdateNestedFieldExample {

    public static void main(String[] args) throws IOException {
        // 创建RestHighLevelClient连接到Elasticsearch集群
        RestHighLevelClient client = new RestHighLevelClient();

        // 构建UpdateRequest对象
        UpdateRequest request = new UpdateRequest("index_name", "document_type", "document_id");

        // 构建更新脚本
        String script = "ctx._source.nested_field.field_name = params.new_value";
        Map<String, Object> params = new HashMap<>();
        params.put("new_value", "new_field_value");
        request.script(new Script(ScriptType.INLINE, "painless", script, params));

        // 设置upsert选项和retryOnConflict选项
        request.upsert(getUpsertRequest());
        request.retryOnConflict(3);

        // 执行更新操作
        UpdateResponse response = client.update(request, RequestOptions.DEFAULT);

        // 处理更新结果
        if (response.getResult() == DocWriteResponse.Result.UPDATED) {
            System.out.println("Field updated successfully");
        } else if (response.getResult() == DocWriteResponse.Result.CREATED) {
            System.out.println("Field created successfully");
        } else if (response.getResult() == DocWriteResponse.Result.NOOP) {
            System.out.println("No changes made to the field");
        }

        // 关闭RestHighLevelClient连接
        client.close();
    }

    private static IndexRequest getUpsertRequest() throws IOException {
        XContentBuilder builder = XContentFactory.jsonBuilder();
        builder.startObject();
        {
            builder.field("nested_field");
            builder.startObject();
            {
                builder.field("field_name", "default_value");
            }
            builder.endObject();
        }
        builder.endObject();

        IndexRequest request = new IndexRequest("index_name", "document_type", "document_id");
        request.source(builder);
        request.versionType(VersionType.EXTERNAL);
        request.opType(DocWriteRequest.OpType.CREATE);

        return request;
    }
}