org.elasticsearch.cluster.ClusterState.toXContent()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(114)

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

ClusterState.toXContent介绍

暂无

代码示例

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

@Override
  protected void addCustomFields(XContentBuilder builder, Params params) throws IOException {
    builder.startObject("state");
    state.toXContent(builder, params);
    builder.endObject();
    if (params.paramAsBoolean("explain", false)) {
      explanations.toXContent(builder, ToXContent.EMPTY_PARAMS);
    }
  }
}

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

@Override
  protected void addCustomFields(XContentBuilder builder, Params params) throws IOException {
    builder.startObject("state");
    state.toXContent(builder, params);
    builder.endObject();
    if (params.paramAsBoolean("explain", false)) {
      explanations.toXContent(builder, ToXContent.EMPTY_PARAMS);
    }
  }
}

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

@Override
  protected void addCustomFields(XContentBuilder builder, Params params) throws IOException {
    builder.startObject("state");
    state.toXContent(builder, params);
    builder.endObject();
    if (params.paramAsBoolean("explain", false)) {
      explanations.toXContent(builder, ToXContent.EMPTY_PARAMS);
    }
  }
}

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

@Override
public String toString() {
  try {
    XContentBuilder builder = XContentFactory.jsonBuilder().prettyPrint();
    builder.startObject();
    toXContent(builder, EMPTY_PARAMS);
    builder.endObject();
    return builder.string();
  } catch (IOException e) {
    return "{ \"error\" : \"" + e.getMessage() + "\"}";
  }
}

代码示例来源:origin: javanna/elasticshell

@Override
  protected XContentBuilder toXContent(ClusterRerouteRequest request, ClusterRerouteResponse response, XContentBuilder builder) throws IOException {
    builder.startObject();
    builder.field(Fields.OK, true);
    builder.startObject("state");
    response.getState().settingsFilter(new SettingsFilter(ImmutableSettings.settingsBuilder().build())).toXContent(builder, ToXContent.EMPTY_PARAMS);
    builder.endObject();

    builder.endObject();

    return builder;
  }
}

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

@Override
  public RestResponse buildResponse(ClusterStateResponse response, XContentBuilder builder) throws Exception {
    builder.startObject();
    builder.field(Fields.CLUSTER_NAME, response.getClusterName().value());
    response.getState().toXContent(builder, request);
    builder.endObject();
    return new BytesRestResponse(RestStatus.OK, builder);
  }
});

代码示例来源:origin: com.scireum/sirius-search

private String getClusterState(ClusterStateResponse clusterStateResponse) {
  String state = "";
  try (XContentBuilder clusterStateBuilder = XContentFactory.jsonBuilder()) {
    clusterStateBuilder.humanReadable(true).prettyPrint().startObject();
    clusterStateResponse.getState().toXContent(clusterStateBuilder, ToXContent.EMPTY_PARAMS);
    clusterStateBuilder.endObject();
    state = clusterStateBuilder.string();
  } catch (IOException e) {
    Exceptions.handle(e);
  }
  return state;
}

代码示例来源:origin: javanna/elasticshell

@Override
  protected XContentBuilder toXContent(ClusterStateRequest request, ClusterStateResponse response, XContentBuilder builder) throws IOException {
    builder.startObject();
    builder.field(Fields.CLUSTER_NAME, response.getClusterName().value());
    response.getState().settingsFilter(new SettingsFilter(ImmutableSettings.settingsBuilder().build())).toXContent(builder, ToXContent.EMPTY_PARAMS);
    builder.endObject();
    return builder;
  }
}

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

@Override
  protected void addCustomFields(XContentBuilder builder, ClusterRerouteResponse response) throws IOException {
    builder.startObject("state");
    // by default, return everything but metadata
    if (request.param("metric") == null) {
      request.params().put("metric", DEFAULT_METRICS);
    }
    settingsFilter.addFilterSettingParams(request);
    response.getState().toXContent(builder, request);
    builder.endObject();
    if (clusterRerouteRequest.explain()) {
      assert response.getExplanations() != null;
      response.getExplanations().toXContent(builder, ToXContent.EMPTY_PARAMS);
    }
  }
});

代码示例来源:origin: jprante/elasticsearch-skywalker

@Override
  public RestResponse buildResponse(ConsistencyCheckResponse response) throws Exception {
    XContentBuilder builder = XContentFactory.jsonBuilder();
    builder.startObject();
    builder.field("ok", true);
    builder.startObject("state");
    response.getState().toXContent(builder, ToXContent.EMPTY_PARAMS);
    builder.startArray("files");
    for (File file : response.getFiles()) {
      Instant instant = new Instant(file.lastModified());
      builder.startObject()
          .field("path", file.getAbsolutePath())
          .field("lastmodified", instant.toDateTime().toString())
          .field("size", new SizeValue(file.length(), SizeUnit.SINGLE).toString())
          .field("totalspace", new SizeValue(file.getTotalSpace(), SizeUnit.SINGLE).toString())
          .field("usablespace", new SizeValue(file.getUsableSpace(), SizeUnit.SINGLE).toString())
          .field("freespace", new SizeValue(file.getFreeSpace(), SizeUnit.SINGLE).toString())
          .endObject();
    }
    builder.endArray();
    builder.endObject();
    return new BytesRestResponse(OK, builder);
  }
});

相关文章