org.elasticsearch.client.node.NodeClient.fieldCaps()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(4.2k)|赞(0)|评价(0)|浏览(108)

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

NodeClient.fieldCaps介绍

暂无

代码示例

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

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request,
                       final NodeClient client) throws IOException {
    if (request.hasContentOrSourceParam()) {
      deprecationLogger.deprecated("Specifying a request body is deprecated -- the" +
        " [fields] request parameter should be used instead.");
      if (request.hasParam("fields")) {
        throw new IllegalArgumentException("can't specify a request body and [fields]" +
          " request parameter, either specify a request body or the" +
          " [fields] request parameter");
      }
    }

    final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
    final FieldCapabilitiesRequest fieldRequest;
    if (request.hasContentOrSourceParam()) {
      try (XContentParser parser = request.contentOrSourceParamParser()) {
        fieldRequest = FieldCapabilitiesRequest.parseFields(parser);
      }
    } else {
      fieldRequest = new FieldCapabilitiesRequest();
      fieldRequest.fields(Strings.splitStringByCommaToArray(request.param("fields")));
    }
    fieldRequest.indices(indices);
    fieldRequest.indicesOptions(
      IndicesOptions.fromRequest(request, fieldRequest.indicesOptions())
    );
    return channel -> client.fieldCaps(fieldRequest, new RestToXContentListener<>(channel));
  }
}

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

IndicesOptions.fromRequest(request, fieldRequest.indicesOptions())
);
return channel -> client.fieldCaps(fieldRequest,
  new RestBuilderListener<FieldCapabilitiesResponse>(channel) {
  @Override

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

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request,
                       final NodeClient client) throws IOException {
    if (request.hasContentOrSourceParam()) {
      deprecationLogger.deprecated("Specifying a request body is deprecated -- the" +
        " [fields] request parameter should be used instead.");
      if (request.hasParam("fields")) {
        throw new IllegalArgumentException("can't specify a request body and [fields]" +
          " request parameter, either specify a request body or the" +
          " [fields] request parameter");
      }
    }

    final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
    final FieldCapabilitiesRequest fieldRequest;
    if (request.hasContentOrSourceParam()) {
      try (XContentParser parser = request.contentOrSourceParamParser()) {
        fieldRequest = FieldCapabilitiesRequest.parseFields(parser);
      }
    } else {
      fieldRequest = new FieldCapabilitiesRequest();
      fieldRequest.fields(Strings.splitStringByCommaToArray(request.param("fields")));
    }
    fieldRequest.indices(indices);
    fieldRequest.indicesOptions(
      IndicesOptions.fromRequest(request, fieldRequest.indicesOptions())
    );
    return channel -> client.fieldCaps(fieldRequest, new RestToXContentListener<>(channel));
  }
}

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

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request,
                       final NodeClient client) throws IOException {
    if (request.hasContentOrSourceParam()) {
      deprecationLogger.deprecated("Specifying a request body is deprecated -- the" +
        " [fields] request parameter should be used instead.");
      if (request.hasParam("fields")) {
        throw new IllegalArgumentException("can't specify a request body and [fields]" +
          " request parameter, either specify a request body or the" +
          " [fields] request parameter");
      }
    }

    final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
    final FieldCapabilitiesRequest fieldRequest;
    if (request.hasContentOrSourceParam()) {
      try (XContentParser parser = request.contentOrSourceParamParser()) {
        fieldRequest = FieldCapabilitiesRequest.parseFields(parser);
      }
    } else {
      fieldRequest = new FieldCapabilitiesRequest();
      fieldRequest.fields(Strings.splitStringByCommaToArray(request.param("fields")));
    }
    fieldRequest.indices(indices);
    fieldRequest.indicesOptions(
      IndicesOptions.fromRequest(request, fieldRequest.indicesOptions())
    );
    return channel -> client.fieldCaps(fieldRequest, new RestToXContentListener<>(channel));
  }
}

相关文章