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

NodeClient.executeLocally介绍

[英]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: floragunncom/search-guard

@Override
protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  LicenseInfoRequest licenseInfoRequest = new LicenseInfoRequest();
  return channel -> client.executeLocally(LicenseInfoAction.INSTANCE, licenseInfoRequest, new NodesResponseRestListener<>(channel));
}

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

@Override
public <    Request extends ActionRequest,
      Response extends ActionResponse,
      RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>
    > void doExecute(Action<Request, Response, RequestBuilder> action, Request request, ActionListener<Response> listener) {
  // Discard the task because the Client interface doesn't use it.
  executeLocally(action, request, listener);
}

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

@Override
public <    Request extends ActionRequest,
      Response extends ActionResponse,
      RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>
    > void doExecute(Action<Request, Response, RequestBuilder> action, Request request, ActionListener<Response> listener) {
  // Discard the task because the Client interface doesn't use it.
  executeLocally(action, request, listener);
}

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

@Override
public <    Request extends ActionRequest,
      Response extends ActionResponse,
      RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>
    > void doExecute(Action<Request, Response, RequestBuilder> action, Request request, ActionListener<Response> listener) {
  // Discard the task because the Client interface doesn't use it.
  executeLocally(action, request, listener);
}

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

@Override
  protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
    return channel -> client.executeLocally(INSTANCE, new Request(), new RestBuilderListener<Response>(channel) {
      @Override
      public RestResponse buildResponse(Response response, XContentBuilder builder) throws Exception {
        response.toXContent(builder, ToXContent.EMPTY_PARAMS);
        return new BytesRestResponse(OK, builder);
      }
    });
  }
}

代码示例来源：origin: com.floragunn/search-guard-6

@Override
protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
  LicenseInfoRequest licenseInfoRequest = new LicenseInfoRequest();
  return channel -> client.executeLocally(LicenseInfoAction.INSTANCE, licenseInfoRequest, new NodesResponseRestListener<>(channel));
}

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

@Override
  protected RestChannelConsumer prepareRequest(RestRequest restRequest, NodeClient client) throws IOException {
    final Request request = Request.parse(restRequest.contentOrSourceParamParser());
    return channel -> client.executeLocally(INSTANCE, request, new RestBuilderListener<Response>(channel) {
      @Override
      public RestResponse buildResponse(Response response, XContentBuilder builder) throws Exception {
        response.toXContent(builder, ToXContent.EMPTY_PARAMS);
        return new BytesRestResponse(OK, builder);
      }
    });
  }
}

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

protected RestChannelConsumer doPrepareRequest(RestRequest request, NodeClient client,
                        boolean includeCreated, boolean includeUpdated) throws IOException {
  // Build the internal request
  Request internal = setCommonOptions(request, buildRequest(request));
  // Executes the request and waits for completion
  if (request.paramAsBoolean("wait_for_completion", true)) {
    Map<String, String> params = new HashMap<>();
    params.put(BulkByScrollTask.Status.INCLUDE_CREATED, Boolean.toString(includeCreated));
    params.put(BulkByScrollTask.Status.INCLUDE_UPDATED, Boolean.toString(includeUpdated));
    return channel -> client.executeLocally(action, internal, new BulkIndexByScrollResponseContentListener(channel, params));
  } else {
    internal.setShouldStoreResult(true);
  }
  /*
   * Let's try and validate before forking so the user gets some error. The
   * task can't totally validate until it starts but this is better than
   * nothing.
   */
  ActionRequestValidationException validationException = internal.validate();
  if (validationException != null) {
    throw validationException;
  }
  return sendTask(client.getLocalNodeId(), client.executeLocally(action, internal, LoggingTaskListener.instance()));
}