本文整理了Java中org.elasticsearch.cluster.ClusterState.toXContent()
方法的一些代码示例,展示了ClusterState.toXContent()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ClusterState.toXContent()
方法的具体详情如下:
包路径:org.elasticsearch.cluster.ClusterState
类名称: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);
}
});
内容来源于网络,如有侵权,请联系作者删除!