org.elasticsearch.client.IndicesAdminClient.getFieldMappings()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(126)

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

IndicesAdminClient.getFieldMappings介绍

[英]Get the mappings of specific fields
[中]获取特定字段的映射

代码示例

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
  final String[] fields = Strings.splitStringByCommaToArray(request.param("fields"));
  GetFieldMappingsRequest getMappingsRequest = new GetFieldMappingsRequest();
  getMappingsRequest.indices(indices).types(types).fields(fields).includeDefaults(request.paramAsBoolean("include_defaults", false));
  getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
  getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
  return channel ->
      client.admin().indices().getFieldMappings(getMappingsRequest, new RestBuilderListener<GetFieldMappingsResponse>(channel) {
        @Override
        public RestResponse buildResponse(GetFieldMappingsResponse response, XContentBuilder builder) throws Exception {
          Map<String, Map<String, Map<String, FieldMappingMetaData>>> mappingsByIndex = response.mappings();
          boolean isPossibleSingleFieldRequest = indices.length == 1 && types.length == 1 && fields.length == 1;
          if (isPossibleSingleFieldRequest && isFieldMappingMissingField(mappingsByIndex)) {
            return new BytesRestResponse(OK, builder.startObject().endObject());
          }
          RestStatus status = OK;
          if (mappingsByIndex.isEmpty() && fields.length > 0) {
            status = NOT_FOUND;
          }
          response.toXContent(builder, request);
          return new BytesRestResponse(status, builder);
        }
      });
}

代码示例来源:origin: harbby/presto-connectors

@Override
public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {
  final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
  final String[] fields = Strings.splitStringByCommaToArray(request.param("fields"));
  GetFieldMappingsRequest getMappingsRequest = new GetFieldMappingsRequest();
  getMappingsRequest.indices(indices).types(types).fields(fields).includeDefaults(request.paramAsBoolean("include_defaults", false));
  getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
  getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
  client.admin().indices().getFieldMappings(getMappingsRequest, new RestBuilderListener<GetFieldMappingsResponse>(channel) {
    @SuppressWarnings("unchecked")
    @Override
    public RestResponse buildResponse(GetFieldMappingsResponse response, XContentBuilder builder) throws Exception {
      ImmutableMap<String, ImmutableMap<String, ImmutableMap<String, FieldMappingMetaData>>> mappingsByIndex = response.mappings();
      boolean isPossibleSingleFieldRequest = indices.length == 1 && types.length == 1 && fields.length == 1;
      if (isPossibleSingleFieldRequest && isFieldMappingMissingField(mappingsByIndex)) {
        return new BytesRestResponse(OK, builder.startObject().endObject());
      }
      RestStatus status = OK;
      if (mappingsByIndex.isEmpty() && fields.length > 0) {
        status = NOT_FOUND;
      }
      builder.startObject();
      response.toXContent(builder, request);
      builder.endObject();
      return new BytesRestResponse(status, builder);
    }
  });
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
  final String[] fields = Strings.splitStringByCommaToArray(request.param("fields"));
  GetFieldMappingsRequest getMappingsRequest = new GetFieldMappingsRequest();
  getMappingsRequest.indices(indices).types(types).fields(fields).includeDefaults(request.paramAsBoolean("include_defaults", false));
  getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
  getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
  return channel ->
      client.admin().indices().getFieldMappings(getMappingsRequest, new RestBuilderListener<GetFieldMappingsResponse>(channel) {
        @Override
        public RestResponse buildResponse(GetFieldMappingsResponse response, XContentBuilder builder) throws Exception {
          Map<String, Map<String, Map<String, FieldMappingMetaData>>> mappingsByIndex = response.mappings();
          boolean isPossibleSingleFieldRequest = indices.length == 1 && types.length == 1 && fields.length == 1;
          if (isPossibleSingleFieldRequest && isFieldMappingMissingField(mappingsByIndex)) {
            return new BytesRestResponse(OK, builder.startObject().endObject());
          }
          RestStatus status = OK;
          if (mappingsByIndex.isEmpty() && fields.length > 0) {
            status = NOT_FOUND;
          }
          response.toXContent(builder, request);
          return new BytesRestResponse(status, builder);
        }
      });
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
  final String[] fields = Strings.splitStringByCommaToArray(request.param("fields"));
  GetFieldMappingsRequest getMappingsRequest = new GetFieldMappingsRequest();
  getMappingsRequest.indices(indices).types(types).fields(fields).includeDefaults(request.paramAsBoolean("include_defaults", false));
  getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
  getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
  return channel ->
      client.admin().indices().getFieldMappings(getMappingsRequest, new RestBuilderListener<GetFieldMappingsResponse>(channel) {
        @Override
        public RestResponse buildResponse(GetFieldMappingsResponse response, XContentBuilder builder) throws Exception {
          Map<String, Map<String, Map<String, FieldMappingMetaData>>> mappingsByIndex = response.mappings();
          boolean isPossibleSingleFieldRequest = indices.length == 1 && types.length == 1 && fields.length == 1;
          if (isPossibleSingleFieldRequest && isFieldMappingMissingField(mappingsByIndex)) {
            return new BytesRestResponse(OK, builder.startObject().endObject());
          }
          RestStatus status = OK;
          if (mappingsByIndex.isEmpty() && fields.length > 0) {
            status = NOT_FOUND;
          }
          response.toXContent(builder, request);
          return new BytesRestResponse(status, builder);
        }
      });
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  final String[] types = request.paramAsStringArrayOrEmptyIfAll("type");
  final String[] fields = Strings.splitStringByCommaToArray(request.param("fields"));
  GetFieldMappingsRequest getMappingsRequest = new GetFieldMappingsRequest();
  getMappingsRequest.indices(indices).types(types).fields(fields).includeDefaults(request.paramAsBoolean("include_defaults", false));
  getMappingsRequest.indicesOptions(IndicesOptions.fromRequest(request, getMappingsRequest.indicesOptions()));
  getMappingsRequest.local(request.paramAsBoolean("local", getMappingsRequest.local()));
  return channel ->
      client.admin().indices().getFieldMappings(getMappingsRequest, new RestBuilderListener<GetFieldMappingsResponse>(channel) {
        @Override
        public RestResponse buildResponse(GetFieldMappingsResponse response, XContentBuilder builder) throws Exception {
          Map<String, Map<String, Map<String, FieldMappingMetaData>>> mappingsByIndex = response.mappings();
          boolean isPossibleSingleFieldRequest = indices.length == 1 && types.length == 1 && fields.length == 1;
          if (isPossibleSingleFieldRequest && isFieldMappingMissingField(mappingsByIndex)) {
            return new BytesRestResponse(OK, builder.startObject().endObject());
          }
          RestStatus status = OK;
          if (mappingsByIndex.isEmpty() && fields.length > 0) {
            status = NOT_FOUND;
          }
          builder.startObject();
          response.toXContent(builder, request);
          builder.endObject();
          return new BytesRestResponse(status, builder);
        }
      });
}

相关文章

微信公众号

最新文章

更多

IndicesAdminClient类方法