org.elasticsearch.action.admin.cluster.node.stats.NodesStatsResponse.getNodes()方法的使用及代码示例

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

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

NodesStatsResponse.getNodes介绍

暂无

代码示例

代码示例来源：origin: SonarSource/sonarqube

private void completeNodeAttributes(ProtobufSystemInfo.Section.Builder protobuf) {
 NodesStatsResponse nodesStats = esClient.prepareNodesStats()
  .setFs(true)
  .setProcess(true)
  .setJvm(true)
  .setIndices(true)
  .setBreaker(true)
  .get();
 if (!nodesStats.getNodes().isEmpty()) {
  NodeStats stats = nodesStats.getNodes().get(0);
  toProtobuf(stats, protobuf);
 }
}

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

for (final NodeStats nodeStats : nodesStats.getNodes()) {
  for (final ThreadPoolStats.Stats threadPoolStats : nodeStats.getThreadPool()) {
    candidates.add(threadPoolStats.getName());

代码示例来源：origin: SonarSource/sonarqube

public Collection<NodeInfo> load() {
 NodesStatsResponse nodesStats = esClient.prepareNodesStats()
  .setFs(true)
  .setProcess(true)
  .setJvm(true)
  .setIndices(true)
  .setBreaker(true)
  .get();
 List<NodeInfo> result = new ArrayList<>();
 nodesStats.getNodes().forEach(nodeStat -> result.add(toNodeInfo(nodeStat)));
 return result;
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

private boolean isBulkProcessorAvailable() {
  NodesStatsResponse response = client.admin().cluster().prepareNodesStats().setThreadPool(true).get();
  for (NodeStats nodeStats : response.getNodes()) {
    Iterator<Stats> iterator = nodeStats.getThreadPool().iterator();
    while (iterator.hasNext()) {
      Stats stats = iterator.next();
      if ("bulk".equals(stats.getName())) {
        int queue = stats.getQueue();
        logger.trace("bulkQueueSize [{}] - queue [{}] - availability [{}]", bulkQueueSize, queue, 1 - (queue / bulkQueueSize));
        return 1 - (queue / bulkQueueSize) > 0.1;
      }
    }
  }
  return true;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject("nodes");
  for (NodeStats nodeStats : getNodes()) {
    builder.startObject(nodeStats.getNode().getId());
    builder.field("timestamp", nodeStats.getTimestamp());
    nodeStats.toXContent(builder, params);
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

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

@Override
public void onResponse(NodesStatsResponse nodeStatses) {
  ImmutableOpenMap.Builder<String, DiskUsage> newLeastAvaiableUsages = ImmutableOpenMap.builder();
  ImmutableOpenMap.Builder<String, DiskUsage> newMostAvaiableUsages = ImmutableOpenMap.builder();
  fillDiskUsagePerNode(logger, nodeStatses.getNodes(), newLeastAvaiableUsages, newMostAvaiableUsages);
  leastAvailableSpaceUsages = newLeastAvaiableUsages.build();
  mostAvailableSpaceUsages = newMostAvaiableUsages.build();
}

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

@Override
public void onResponse(NodesStatsResponse nodeStatses) {
  Map<String, DiskUsage> newLeastAvaiableUsages = new HashMap<>();
  Map<String, DiskUsage> newMostAvaiableUsages = new HashMap<>();
  fillDiskUsagePerNode(logger, nodeStatses.getNodes(), newLeastAvaiableUsages, newMostAvaiableUsages);
  leastAvailableSpaceUsages = Collections.unmodifiableMap(newLeastAvaiableUsages);
  mostAvailableSpaceUsages = Collections.unmodifiableMap(newMostAvaiableUsages);
}

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

private Table buildTable(final RestRequest request, final NodesStatsResponse nodeStatses) {
    Table table = getTableWithHeader(request);

    for (NodeStats nodeStats: nodeStatses.getNodes()) {
      if (nodeStats.getIndices().getFieldData().getFields() != null) {
        for (ObjectLongCursor<String> cursor : nodeStats.getIndices().getFieldData().getFields()) {
          table.startRow();
          table.addCell(nodeStats.getNode().getId());
          table.addCell(nodeStats.getNode().getHostName());
          table.addCell(nodeStats.getNode().getHostAddress());
          table.addCell(nodeStats.getNode().getName());
          table.addCell(cursor.key);
          table.addCell(new ByteSizeValue(cursor.value));
          table.endRow();
        }
      }
    }

    return table;
  }
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject("nodes");
  for (NodeStats nodeStats : getNodes()) {
    builder.startObject(nodeStats.getNode().getId());
    builder.field("timestamp", nodeStats.getTimestamp());
    nodeStats.toXContent(builder, params);
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject("nodes");
  for (NodeStats nodeStats : getNodes()) {
    builder.startObject(nodeStats.getNode().getId());
    builder.field("timestamp", nodeStats.getTimestamp());
    nodeStats.toXContent(builder, params);
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject("nodes");
  for (NodeStats nodeStats : getNodes()) {
    builder.startObject(nodeStats.getNode().getId());
    builder.field("timestamp", nodeStats.getTimestamp());
    nodeStats.toXContent(builder, params);
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

代码示例来源：origin: stackoverflow.com

final NodesStatsResponse response = client.admin().cluster().prepareNodesStats().setThreadPool(true).execute().actionGet();
 final NodeStats[] nodeStats2 = response.getNodes();
 for (NodeStats nodeStats3 : nodeStats2) {
   ThreadPoolStats stats = nodeStats3.getThreadPool();
   if (stats != null)
     for (ThreadPoolStats.Stats threadPoolStat : stats) {
       System.out.println("node `" + nodeStats3.getNode().getName() + "`" + " has pool `" + threadPoolStat.getName() + "` with current queue size " + threadPoolStat.getQueue());
     }
 }

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

private void completeNodeAttributes(ProtobufSystemInfo.Section.Builder protobuf) {
 NodesStatsResponse nodesStats = esClient.prepareNodesStats()
  .setFs(true)
  .setProcess(true)
  .setJvm(true)
  .setIndices(true)
  .setBreaker(true)
  .get();
 if (!nodesStats.getNodes().isEmpty()) {
  NodeStats stats = nodesStats.getNodes().get(0);
  toProtobuf(stats, protobuf);
 }
}

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

public Collection<NodeInfo> load() {
 NodesStatsResponse nodesStats = esClient.prepareNodesStats()
  .setFs(true)
  .setProcess(true)
  .setJvm(true)
  .setIndices(true)
  .setBreaker(true)
  .get();
 List<NodeInfo> result = new ArrayList<>();
 nodesStats.getNodes().forEach(nodeStat -> result.add(toNodeInfo(nodeStat)));
 return result;
}

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

private Map<String, String> getNodesStats(NodesStatsResponse nodesStatsResponse) {
  Map<String, String> nodeStatsMap = new HashMap<>();
  for (NodeStats stat : nodesStatsResponse.getNodes()) {
    try (XContentBuilder nodesStatsBuilder = XContentFactory.jsonBuilder()) {
      nodesStatsBuilder.humanReadable(true).prettyPrint().startObject();
      stat.toXContent(nodesStatsBuilder, ToXContent.EMPTY_PARAMS);
      nodesStatsBuilder.endObject();
      nodeStatsMap.put(stat.getNode().getName(), nodesStatsBuilder.string());
    } catch (IOException e) {
      Exceptions.handle(e);
    }
  }
  return nodeStatsMap;
}

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

@Override
public void onResponse(NodesStatsResponse nodeStatses) {
  ImmutableOpenMap.Builder<String, DiskUsage> newLeastAvaiableUsages = ImmutableOpenMap.builder();
  ImmutableOpenMap.Builder<String, DiskUsage> newMostAvaiableUsages = ImmutableOpenMap.builder();
  fillDiskUsagePerNode(logger, nodeStatses.getNodes(), newLeastAvaiableUsages, newMostAvaiableUsages);
  leastAvailableSpaceUsages = newLeastAvaiableUsages.build();
  mostAvailableSpaceUsages = newMostAvaiableUsages.build();
}

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

@Override
public void onResponse(NodesStatsResponse nodeStatses) {
  ImmutableOpenMap.Builder<String, DiskUsage> newLeastAvaiableUsages = ImmutableOpenMap.builder();
  ImmutableOpenMap.Builder<String, DiskUsage> newMostAvaiableUsages = ImmutableOpenMap.builder();
  fillDiskUsagePerNode(logger, nodeStatses.getNodes(), newLeastAvaiableUsages, newMostAvaiableUsages);
  leastAvailableSpaceUsages = newLeastAvaiableUsages.build();
  mostAvailableSpaceUsages = newMostAvaiableUsages.build();
}

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

@Override
public void onResponse(NodesStatsResponse nodeStatses) {
  ImmutableOpenMap.Builder<String, DiskUsage> newLeastAvaiableUsages = ImmutableOpenMap.builder();
  ImmutableOpenMap.Builder<String, DiskUsage> newMostAvaiableUsages = ImmutableOpenMap.builder();
  fillDiskUsagePerNode(logger, nodeStatses.getNodes(), newLeastAvaiableUsages, newMostAvaiableUsages);
  leastAvailableSpaceUsages = newLeastAvaiableUsages.build();
  mostAvailableSpaceUsages = newMostAvaiableUsages.build();
}

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

for (NodeStats nodeStats : stats.getNodes()) {
  DiscoveryNode node = nodeStats.getNode();

代码示例来源：origin: visallo/vertexium

private long getNumQueries() {
  Client client = elasticsearchResource.getRunner().client();
  NodesStatsResponse nodeStats = NodesStatsAction.INSTANCE.newRequestBuilder(client).get();
  List<NodeStats> nodes = nodeStats.getNodes();
  assertEquals(1, nodes.size());
  SearchStats searchStats = nodes.get(0).getIndices().getSearch();
  return searchStats.getTotal().getQueryCount();
}

内容来源于网络，如有侵权，请联系作者删除！

NodesStatsResponse

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com