本文整理了Java中org.elasticsearch.client.node.NodeClient.execute()方法的一些代码示例，展示了NodeClient.execute()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。NodeClient.execute()方法的具体详情如下：
包路径：org.elasticsearch.client.node.NodeClient
类名称：NodeClient
方法名：execute

NodeClient.execute介绍

[英]Execute an Action locally, returning that Task used to track it, and linking an ActionListener. Prefer this method if you don't need access to the task when listening for the response. This is the method used to implement the Clientinterface.
[中]在本地执行操作，返回用于跟踪它的任务，并链接ActionListener。如果在监听响应时不需要访问任务，请选择此方法。这是用于实现Clientinterface的方法。

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  return channel -> client.execute(MainAction.INSTANCE, new MainRequest(), new RestBuilderListener<MainResponse>(channel) {
    @Override
    public RestResponse buildResponse(MainResponse mainResponse, XContentBuilder builder) throws Exception {
      return convertMainResponse(mainResponse, request, builder);
    }
  });
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client)
  throws IOException {
  return channel -> client.execute(RemoteInfoAction.INSTANCE, new RemoteInfoRequest(),
    new RestBuilderListener<RemoteInfoResponse>(channel) {
    @Override
    public RestResponse buildResponse(RemoteInfoResponse response, XContentBuilder builder) throws Exception {
      response.toXContent(builder, request);
      return new BytesRestResponse(RestStatus.OK, builder);
    }
  });
}
@Override

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  return channel -> client.execute(MainAction.INSTANCE, new MainRequest(), new RestBuilderListener<MainResponse>(channel) {
    @Override
    public RestResponse buildResponse(MainResponse mainResponse, XContentBuilder builder) throws Exception {
      return convertMainResponse(mainResponse, request, builder);
    }
  });
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  return channel -> client.execute(MainAction.INSTANCE, new MainRequest(), new RestBuilderListener<MainResponse>(channel) {
    @Override
    public RestResponse buildResponse(MainResponse mainResponse, XContentBuilder builder) throws Exception {
      return convertMainResponse(mainResponse, request, builder);
    }
  });
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  return channel -> client.execute(MainAction.INSTANCE, new MainRequest(), new RestBuilderListener<MainResponse>(channel) {
    @Override
    public RestResponse buildResponse(MainResponse mainResponse, XContentBuilder builder) throws Exception {
      return convertMainResponse(mainResponse, request, builder);
    }
  });
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client)
  throws IOException {
  return channel -> client.execute(RemoteInfoAction.INSTANCE, new RemoteInfoRequest(),
    new RestBuilderListener<RemoteInfoResponse>(channel) {
    @Override
    public RestResponse buildResponse(RemoteInfoResponse response, XContentBuilder builder) throws Exception {
      response.toXContent(builder, request);
      return new BytesRestResponse(RestStatus.OK, builder);
    }
  });
}
@Override

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client)
  throws IOException {
  return channel -> client.execute(RemoteInfoAction.INSTANCE, new RemoteInfoRequest(),
    new RestBuilderListener<RemoteInfoResponse>(channel) {
    @Override
    public RestResponse buildResponse(RemoteInfoResponse response, XContentBuilder builder) throws Exception {
      response.toXContent(builder, request);
      return new BytesRestResponse(RestStatus.OK, builder);
    }
  });
}
@Override

代码示例来源：origin: apache/servicemix-bundles

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client)
  throws IOException {
  return channel -> client.execute(RemoteInfoAction.INSTANCE, new RemoteInfoRequest(),
    new RestBuilderListener<RemoteInfoResponse>(channel) {
    @Override
    public RestResponse buildResponse(RemoteInfoResponse response, XContentBuilder builder) throws Exception {
      response.toXContent(builder, request);
      return new BytesRestResponse(RestStatus.OK, builder);
    }
  });
}
@Override

代码示例来源：origin: org.codelibs.elasticsearch.module/lang-mustache

@Override
public RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  MultiSearchTemplateRequest multiRequest = parseRequest(request, allowExplicitIndex);
  return channel -> client.execute(MultiSearchTemplateAction.INSTANCE, multiRequest, new RestToXContentListener<>(channel));
}

代码示例来源：origin: org.elasticsearch.plugin/lang-mustache-client

@Override
public RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  MultiSearchTemplateRequest multiRequest = parseRequest(request, allowExplicitIndex);
  return channel -> client.execute(MultiSearchTemplateAction.INSTANCE, multiRequest, new RestToXContentListener<>(channel));
}

代码示例来源：origin: NLPchina/elasticsearch-analysis-ansj

@Override
protected RestChannelConsumer doCatRequest(RestRequest request, NodeClient client) {
  AnsjRequest ansjRequest = new AnsjRequest(request.path());
  ansjRequest.asMap().putAll(request.params());
  return channel -> client.execute(AnsjAction.INSTANCE, ansjRequest, new RestResponseListener<AnsjResponse>(channel) {
    @Override
    public RestResponse buildResponse(final AnsjResponse ansjResponse) throws Exception {
      return ChineseRestTable.response(channel, ansjResponse.asMap());
    }
  });
}

代码示例来源：origin: NLPchina/elasticsearch-analysis-ansj

@Override
protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  AnsjRequest ansjRequest = new AnsjRequest();
  ansjRequest.asMap().putAll(request.params());
  return channel -> client.execute(AnsjAction.INSTANCE, ansjRequest, new RestToXContentListener<>(channel));
}

代码示例来源：origin: org.elasticsearch.plugin/reindex-client

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
    RethrottleRequest internalRequest = new RethrottleRequest();
    internalRequest.setTaskId(new TaskId(request.param("taskId")));
    Float requestsPerSecond = AbstractBaseReindexRestHandler.parseRequestsPerSecond(request);
    if (requestsPerSecond == null) {
      throw new IllegalArgumentException("requests_per_second is a required parameter");
    }
    internalRequest.setRequestsPerSecond(requestsPerSecond);
    final String groupBy = request.param("group_by", "nodes");
    return channel ->
      client.execute(RethrottleAction.INSTANCE, internalRequest, listTasksResponseListener(nodesInCluster, groupBy, channel));
  }
}

代码示例来源：origin: org.codelibs.elasticsearch.module/lang-mustache

@Override
  public RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
    // Creates the render template request
    SearchTemplateRequest renderRequest;
    try (XContentParser parser = request.contentOrSourceParamParser()) {
      renderRequest = SearchTemplateRequest.fromXContent(parser);
    }
    renderRequest.setSimulate(true);

    String id = request.param("id");
    if (id != null) {
      renderRequest.setScriptType(ScriptType.STORED);
      renderRequest.setScript(id);
    }

    return channel -> client.execute(SearchTemplateAction.INSTANCE, renderRequest, new RestToXContentListener<>(channel));
  }
}

代码示例来源：origin: org.elasticsearch.plugin/lang-mustache-client

@Override
  public RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
    // Creates the render template request
    SearchTemplateRequest renderRequest;
    try (XContentParser parser = request.contentOrSourceParamParser()) {
      renderRequest = SearchTemplateRequest.fromXContent(parser);
    }
    renderRequest.setSimulate(true);

    String id = request.param("id");
    if (id != null) {
      renderRequest.setScriptType(ScriptType.STORED);
      renderRequest.setScript(id);
    }

    return channel -> client.execute(SearchTemplateAction.INSTANCE, renderRequest, new RestToXContentListener<>(channel));
  }
}

代码示例来源：origin: org.elasticsearch.plugin/lang-mustache-client

@Override
public RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  // Creates the search request with all required params
  SearchRequest searchRequest = new SearchRequest();
  RestSearchAction.parseSearchRequest(searchRequest, request, null, size -> searchRequest.source().size(size));
  // Creates the search template request
  SearchTemplateRequest searchTemplateRequest;
  try (XContentParser parser = request.contentOrSourceParamParser()) {
    searchTemplateRequest = SearchTemplateRequest.fromXContent(parser);
  }
  searchTemplateRequest.setRequest(searchRequest);
  return channel -> client.execute(SearchTemplateAction.INSTANCE, searchTemplateRequest, new RestStatusToXContentListener<>(channel));
}

代码示例来源：origin: org.codelibs.elasticsearch.module/lang-mustache

@Override
public RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  // Creates the search request with all required params
  SearchRequest searchRequest = new SearchRequest();
  RestSearchAction.parseSearchRequest(searchRequest, request, null, size -> searchRequest.source().size(size));
  // Creates the search template request
  SearchTemplateRequest searchTemplateRequest;
  try (XContentParser parser = request.contentOrSourceParamParser()) {
    searchTemplateRequest = SearchTemplateRequest.fromXContent(parser);
  }
  searchTemplateRequest.setRequest(searchRequest);
  return channel -> client.execute(SearchTemplateAction.INSTANCE, searchTemplateRequest, new RestStatusToXContentListener<>(channel));
}