org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse.getActiveShards()方法的使用及代码示例

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

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

ClusterHealthResponse.getActiveShards介绍

[英]The percentage of active shards, should be 100% in a green system
[中]在绿色系统中，活动碎片的百分比应为100%

代码示例

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

} else if (waitForActiveShards.enoughShardsActive(response.getActiveShards())) {

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(CLUSTER_NAME, getClusterName());
  builder.field(STATUS, getStatus().name().toLowerCase(Locale.ROOT));
  builder.field(TIMED_OUT, isTimedOut());
  builder.field(NUMBER_OF_NODES, getNumberOfNodes());
  builder.field(NUMBER_OF_DATA_NODES, getNumberOfDataNodes());
  builder.field(ACTIVE_PRIMARY_SHARDS, getActivePrimaryShards());
  builder.field(ACTIVE_SHARDS, getActiveShards());
  builder.field(RELOCATING_SHARDS, getRelocatingShards());
  builder.field(INITIALIZING_SHARDS, getInitializingShards());
  builder.field(UNASSIGNED_SHARDS, getUnassignedShards());
  builder.field(DELAYED_UNASSIGNED_SHARDS, getDelayedUnassignedShards());
  builder.field(NUMBER_OF_PENDING_TASKS, getNumberOfPendingTasks());
  builder.field(NUMBER_OF_IN_FLIGHT_FETCH, getNumberOfInFlightFetch());
  builder.humanReadableField(TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS, TASK_MAX_WAIT_TIME_IN_QUEUE, getTaskMaxWaitingTime());
  builder.percentageField(ACTIVE_SHARDS_PERCENT_AS_NUMBER, ACTIVE_SHARDS_PERCENT, getActiveShardsPercent());
  String level = params.param("level", "cluster");
  boolean outputIndices = "indices".equals(level) || "shards".equals(level);
  if (outputIndices) {
    builder.startObject(INDICES);
    for (ClusterIndexHealth indexHealth : clusterStateHealth.getIndices().values()) {
      indexHealth.toXContent(builder, params);
    }
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

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

private Table buildTable(final ClusterHealthResponse health, final RestRequest request) {
    Table t = getTableWithHeader(request);
    t.startRow();
    t.addCell(health.getClusterName());
    t.addCell(health.getStatus().name().toLowerCase(Locale.ROOT));
    t.addCell(health.getNumberOfNodes());
    t.addCell(health.getNumberOfDataNodes());
    t.addCell(health.getActiveShards());
    t.addCell(health.getActivePrimaryShards());
    t.addCell(health.getRelocatingShards());
    t.addCell(health.getInitializingShards());
    t.addCell(health.getUnassignedShards());
    t.addCell(health.getNumberOfPendingTasks());
    t.addCell(health.getTaskMaxWaitingTime().millis() == 0 ? "-" : health.getTaskMaxWaitingTime());
    t.addCell(String.format(Locale.ROOT, "%1.1f%%", health.getActiveShardsPercent()));
    t.endRow();
    return t;
  }
}

代码示例来源：origin: org.springframework.boot/spring-boot-actuator

@Override
protected void doHealthCheck(Health.Builder builder) throws Exception {
  ClusterHealthRequest request = Requests.clusterHealthRequest(
      ObjectUtils.isEmpty(this.indices) ? ALL_INDICES : this.indices);
  ClusterHealthResponse response = this.client.admin().cluster().health(request)
      .actionGet(this.responseTimeout);
  switch (response.getStatus()) {
  case GREEN:
  case YELLOW:
    builder.up();
    break;
  case RED:
  default:
    builder.down();
    break;
  }
  builder.withDetail("clusterName", response.getClusterName());
  builder.withDetail("numberOfNodes", response.getNumberOfNodes());
  builder.withDetail("numberOfDataNodes", response.getNumberOfDataNodes());
  builder.withDetail("activePrimaryShards", response.getActivePrimaryShards());
  builder.withDetail("activeShards", response.getActiveShards());
  builder.withDetail("relocatingShards", response.getRelocatingShards());
  builder.withDetail("initializingShards", response.getInitializingShards());
  builder.withDetail("unassignedShards", response.getUnassignedShards());
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(CLUSTER_NAME, getClusterName());
  builder.field(STATUS, getStatus().name().toLowerCase(Locale.ROOT));
  builder.field(TIMED_OUT, isTimedOut());
  builder.field(NUMBER_OF_NODES, getNumberOfNodes());
  builder.field(NUMBER_OF_DATA_NODES, getNumberOfDataNodes());
  builder.field(ACTIVE_PRIMARY_SHARDS, getActivePrimaryShards());
  builder.field(ACTIVE_SHARDS, getActiveShards());
  builder.field(RELOCATING_SHARDS, getRelocatingShards());
  builder.field(INITIALIZING_SHARDS, getInitializingShards());
  builder.field(UNASSIGNED_SHARDS, getUnassignedShards());
  builder.field(DELAYED_UNASSIGNED_SHARDS, getDelayedUnassignedShards());
  builder.field(NUMBER_OF_PENDING_TASKS, getNumberOfPendingTasks());
  builder.field(NUMBER_OF_IN_FLIGHT_FETCH, getNumberOfInFlightFetch());
  builder.humanReadableField(TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS, TASK_MAX_WAIT_TIME_IN_QUEUE, getTaskMaxWaitingTime());
  builder.percentageField(ACTIVE_SHARDS_PERCENT_AS_NUMBER, ACTIVE_SHARDS_PERCENT, getActiveShardsPercent());
  String level = params.param("level", "cluster");
  boolean outputIndices = "indices".equals(level) || "shards".equals(level);
  if (outputIndices) {
    builder.startObject(INDICES);
    for (ClusterIndexHealth indexHealth : clusterStateHealth.getIndices().values()) {
      indexHealth.toXContent(builder, params);
    }
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

代码示例来源：origin: fujitsu-pio/io

/**
 * Clusterの状態取得.
 * @return 状態Map
 */
public Map<String, Object> checkHealth() {
  ClusterHealthResponse clusterHealth;
  clusterHealth = esTransportClient.admin().cluster().health(new ClusterHealthRequest()).actionGet();
  HashMap<String, Object> map = new HashMap<String, Object>();
  map.put("cluster_name", clusterHealth.getClusterName());
  map.put("status", clusterHealth.getStatus().name());
  map.put("timed_out", clusterHealth.isTimedOut());
  map.put("number_of_nodes", clusterHealth.getNumberOfNodes());
  map.put("number_of_data_nodes", clusterHealth.getNumberOfDataNodes());
  map.put("active_primary_shards", clusterHealth.getActivePrimaryShards());
  map.put("active_shards", clusterHealth.getActiveShards());
  map.put("relocating_shards", clusterHealth.getRelocatingShards());
  map.put("initializing_shards", clusterHealth.getInitializingShards());
  map.put("unassigned_shards", clusterHealth.getUnassignedShards());
  return map;
}

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

builder.field(NUMBER_OF_DATA_NODES, getNumberOfDataNodes());
builder.field(ACTIVE_PRIMARY_SHARDS, getActivePrimaryShards());
builder.field(ACTIVE_SHARDS, getActiveShards());
builder.field(RELOCATING_SHARDS, getRelocatingShards());
builder.field(INITIALIZING_SHARDS, getInitializingShards());

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

waitForCounter++;
if (request.waitForActiveShards() != -1 && response.getActiveShards() >= request.waitForActiveShards()) {
  waitForCounter++;

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(CLUSTER_NAME, getClusterName());
  builder.field(STATUS, getStatus().name().toLowerCase(Locale.ROOT));
  builder.field(TIMED_OUT, isTimedOut());
  builder.field(NUMBER_OF_NODES, getNumberOfNodes());
  builder.field(NUMBER_OF_DATA_NODES, getNumberOfDataNodes());
  builder.field(ACTIVE_PRIMARY_SHARDS, getActivePrimaryShards());
  builder.field(ACTIVE_SHARDS, getActiveShards());
  builder.field(RELOCATING_SHARDS, getRelocatingShards());
  builder.field(INITIALIZING_SHARDS, getInitializingShards());
  builder.field(UNASSIGNED_SHARDS, getUnassignedShards());
  builder.field(DELAYED_UNASSIGNED_SHARDS, getDelayedUnassignedShards());
  builder.field(NUMBER_OF_PENDING_TASKS, getNumberOfPendingTasks());
  builder.field(NUMBER_OF_IN_FLIGHT_FETCH, getNumberOfInFlightFetch());
  builder.humanReadableField(TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS, TASK_MAX_WAIT_TIME_IN_QUEUE, getTaskMaxWaitingTime());
  builder.percentageField(ACTIVE_SHARDS_PERCENT_AS_NUMBER, ACTIVE_SHARDS_PERCENT, getActiveShardsPercent());
  String level = params.param("level", "cluster");
  boolean outputIndices = "indices".equals(level) || "shards".equals(level);
  if (outputIndices) {
    builder.startObject(INDICES);
    for (ClusterIndexHealth indexHealth : clusterStateHealth.getIndices().values()) {
      indexHealth.toXContent(builder, params);
    }
    builder.endObject();
  }
  builder.endObject();
  return builder;
}

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

} else if (waitForActiveShards.enoughShardsActive(response.getActiveShards())) {

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

builder.field(Fields.NUMBER_OF_DATA_NODES, getNumberOfDataNodes());
builder.field(Fields.ACTIVE_PRIMARY_SHARDS, getActivePrimaryShards());
builder.field(Fields.ACTIVE_SHARDS, getActiveShards());
builder.field(Fields.RELOCATING_SHARDS, getRelocatingShards());
builder.field(Fields.INITIALIZING_SHARDS, getInitializingShards());

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

} else if (waitForActiveShards.enoughShardsActive(response.getActiveShards())) {

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

private Table buildTable(final ClusterHealthResponse health, final RestRequest request) {
    long time = System.currentTimeMillis();
    Table t = getTableWithHeader(request);
    t.startRow();
    t.addCell(TimeUnit.SECONDS.convert(time, TimeUnit.MILLISECONDS));
    t.addCell(dateFormat.print(time));
    t.addCell(health.getClusterName());
    t.addCell(health.getStatus().name().toLowerCase(Locale.ROOT));
    t.addCell(health.getNumberOfNodes());
    t.addCell(health.getNumberOfDataNodes());
    t.addCell(health.getActiveShards());
    t.addCell(health.getActivePrimaryShards());
    t.addCell(health.getRelocatingShards());
    t.addCell(health.getInitializingShards());
    t.addCell(health.getUnassignedShards());
    t.addCell(health.getNumberOfPendingTasks());
    t.addCell(health.getTaskMaxWaitingTime().millis() == 0 ? "-" : health.getTaskMaxWaitingTime());
    t.addCell(String.format(Locale.ROOT, "%1.1f%%", health.getActiveShardsPercent()));
    t.endRow();
    return t;
  }
}

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

} else if (waitForActiveShards.enoughShardsActive(response.getActiveShards())) {

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

private Table buildTable(final ClusterHealthResponse health, final RestRequest request) {
    Table t = getTableWithHeader(request);
    t.startRow();
    t.addCell(health.getClusterName());
    t.addCell(health.getStatus().name().toLowerCase(Locale.ROOT));
    t.addCell(health.getNumberOfNodes());
    t.addCell(health.getNumberOfDataNodes());
    t.addCell(health.getActiveShards());
    t.addCell(health.getActivePrimaryShards());
    t.addCell(health.getRelocatingShards());
    t.addCell(health.getInitializingShards());
    t.addCell(health.getUnassignedShards());
    t.addCell(health.getNumberOfPendingTasks());
    t.addCell(health.getTaskMaxWaitingTime().millis() == 0 ? "-" : health.getTaskMaxWaitingTime());
    t.addCell(String.format(Locale.ROOT, "%1.1f%%", health.getActiveShardsPercent()));
    t.endRow();
    return t;
  }
}

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

builder.field(Fields.NUMBER_OF_DATA_NODES, response.getNumberOfDataNodes());
builder.field(Fields.ACTIVE_PRIMARY_SHARDS, response.getActivePrimaryShards());
builder.field(Fields.ACTIVE_SHARDS, response.getActiveShards());
builder.field(Fields.RELOCATING_SHARDS, response.getRelocatingShards());
builder.field(Fields.INITIALIZING_SHARDS, response.getInitializingShards());

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

private Table buildTable(final ClusterHealthResponse health, final RestRequest request) {
    Table t = getTableWithHeader(request);
    t.startRow();
    t.addCell(health.getClusterName());
    t.addCell(health.getStatus().name().toLowerCase(Locale.ROOT));
    t.addCell(health.getNumberOfNodes());
    t.addCell(health.getNumberOfDataNodes());
    t.addCell(health.getActiveShards());
    t.addCell(health.getActivePrimaryShards());
    t.addCell(health.getRelocatingShards());
    t.addCell(health.getInitializingShards());
    t.addCell(health.getUnassignedShards());
    t.addCell(health.getNumberOfPendingTasks());
    t.addCell(health.getTaskMaxWaitingTime().millis() == 0 ? "-" : health.getTaskMaxWaitingTime());
    t.addCell(String.format(Locale.ROOT, "%1.1f%%", health.getActiveShardsPercent()));
    t.endRow();
    return t;
  }
}

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

private Table buildTable(final ClusterHealthResponse health, final RestRequest request) {
    Table t = getTableWithHeader(request);
    t.startRow();
    t.addCell(health.getClusterName());
    t.addCell(health.getStatus().name().toLowerCase(Locale.ROOT));
    t.addCell(health.getNumberOfNodes());
    t.addCell(health.getNumberOfDataNodes());
    t.addCell(health.getActiveShards());
    t.addCell(health.getActivePrimaryShards());
    t.addCell(health.getRelocatingShards());
    t.addCell(health.getInitializingShards());
    t.addCell(health.getUnassignedShards());
    t.addCell(health.getNumberOfPendingTasks());
    t.addCell(health.getTaskMaxWaitingTime().millis() == 0 ? "-" : health.getTaskMaxWaitingTime());
    t.addCell(String.format(Locale.ROOT, "%1.1f%%", health.getActiveShardsPercent()));
    t.endRow();
    return t;
  }
}

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

ClusterHealthResponse

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    ClusterHealthResponse类方法

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