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

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

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

ClusterHealthResponse.getDelayedUnassignedShards介绍

[英]The number of unassigned shards that are currently being delayed (for example, due to node leaving the cluster and waiting for a timeout for the node to come back in order to allocate the shards back to it).
[中]当前被延迟的未分配碎片数(例如,由于节点离开群集并等待节点返回以将碎片分配回群集的超时)。

代码示例

代码示例来源: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: com.strapdata.elasticsearch/elasticsearch

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());

代码示例来源: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: 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: harbby/presto-connectors

builder.field(Fields.INITIALIZING_SHARDS, getInitializingShards());
builder.field(Fields.UNASSIGNED_SHARDS, getUnassignedShards());
builder.field(Fields.DELAYED_UNASSIGNED_SHARDS, getDelayedUnassignedShards());
builder.field(Fields.NUMBER_OF_PENDING_TASKS, getNumberOfPendingTasks());
builder.field(Fields.NUMBER_OF_IN_FLIGHT_FETCH, getNumberOfInFlightFetch());

相关文章

微信公众号

最新文章

更多