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

ClusterHealthResponse.<init>介绍

[英]For XContent Parser and serialization tests
[中]用于XContent解析器和序列化测试

代码示例

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

@Override
protected ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
public ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

public static ClusterHealthResponse readResponseFrom(StreamInput in) throws IOException {
  ClusterHealthResponse response = new ClusterHealthResponse();
  response.readFrom(in);
  return response;
}

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

private ClusterHealthResponse clusterHealth(ClusterHealthRequest request, ClusterState clusterState, int numberOfPendingTasks,
                        int numberOfInFlightFetch, TimeValue pendingTaskTimeInQueue) {
    if (logger.isTraceEnabled()) {
      logger.trace("Calculating health based on state version [{}]", clusterState.version());
    }

    String[] concreteIndices;
    try {
      concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
    } catch (IndexNotFoundException e) {
      // one of the specified indices is not there - treat it as RED.
      ClusterHealthResponse response = new ClusterHealthResponse(clusterState.getClusterName().value(), Strings.EMPTY_ARRAY,
        clusterState, numberOfPendingTasks, numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState),
        pendingTaskTimeInQueue);
      response.setStatus(ClusterHealthStatus.RED);
      return response;
    }

    return new ClusterHealthResponse(clusterState.getClusterName().value(), concreteIndices, clusterState, numberOfPendingTasks,
        numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState), pendingTaskTimeInQueue);
  }
}

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

@Override
public ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
protected ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
protected ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
public ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
protected ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
public ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
protected ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

@Override
public ClusterHealthResponse newResponse() {
  return new ClusterHealthResponse();
}

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

public static ClusterHealthResponse readResponseFrom(StreamInput in) throws IOException {
  ClusterHealthResponse response = new ClusterHealthResponse();
  response.readFrom(in);
  return response;
}

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

public static ClusterHealthResponse readResponseFrom(StreamInput in) throws IOException {
  ClusterHealthResponse response = new ClusterHealthResponse();
  response.readFrom(in);
  return response;
}

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

public static ClusterHealthResponse readResponseFrom(StreamInput in) throws IOException {
  ClusterHealthResponse response = new ClusterHealthResponse();
  response.readFrom(in);
  return response;
}

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

public static ClusterHealthResponse readResponseFrom(StreamInput in) throws IOException {
  ClusterHealthResponse response = new ClusterHealthResponse();
  response.readFrom(in);
  return response;
}

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

private ClusterHealthResponse clusterHealth(ClusterHealthRequest request, ClusterState clusterState, int numberOfPendingTasks, int numberOfInFlightFetch,
                        TimeValue pendingTaskTimeInQueue) {
    if (logger.isTraceEnabled()) {
      logger.trace("Calculating health based on state version [{}]", clusterState.version());
    }

    String[] concreteIndices;
    try {
      concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
    } catch (IndexNotFoundException e) {
      // one of the specified indices is not there - treat it as RED.
      ClusterHealthResponse response = new ClusterHealthResponse(clusterState.getClusterName().value(), Strings.EMPTY_ARRAY, clusterState,
          numberOfPendingTasks, numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState),
          pendingTaskTimeInQueue);
      response.setStatus(ClusterHealthStatus.RED);
      return response;
    }

    return new ClusterHealthResponse(clusterState.getClusterName().value(), concreteIndices, clusterState, numberOfPendingTasks,
        numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState), pendingTaskTimeInQueue);
  }
}

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

private ClusterHealthResponse clusterHealth(ClusterHealthRequest request, ClusterState clusterState, int numberOfPendingTasks, int numberOfInFlightFetch,
                        TimeValue pendingTaskTimeInQueue) {
    if (logger.isTraceEnabled()) {
      logger.trace("Calculating health based on state version [{}]", clusterState.version());
    }

    String[] concreteIndices;
    try {
      concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
    } catch (IndexNotFoundException e) {
      // one of the specified indices is not there - treat it as RED.
      ClusterHealthResponse response = new ClusterHealthResponse(clusterState.getClusterName().value(), Strings.EMPTY_ARRAY, clusterState,
          numberOfPendingTasks, numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState),
          pendingTaskTimeInQueue);
      response.setStatus(ClusterHealthStatus.RED);
      return response;
    }

    return new ClusterHealthResponse(clusterState.getClusterName().value(), concreteIndices, clusterState, numberOfPendingTasks,
        numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState), pendingTaskTimeInQueue);
  }
}

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

private ClusterHealthResponse clusterHealth(ClusterHealthRequest request, ClusterState clusterState, int numberOfPendingTasks, int numberOfInFlightFetch,
                        TimeValue pendingTaskTimeInQueue) {
    if (logger.isTraceEnabled()) {
      logger.trace("Calculating health based on state version [{}]", clusterState.version());
    }

    String[] concreteIndices;
    try {
      concreteIndices = indexNameExpressionResolver.concreteIndexNames(clusterState, request);
    } catch (IndexNotFoundException e) {
      // one of the specified indices is not there - treat it as RED.
      ClusterHealthResponse response = new ClusterHealthResponse(clusterState.getClusterName().value(), Strings.EMPTY_ARRAY, clusterState,
          numberOfPendingTasks, numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState),
          pendingTaskTimeInQueue);
      response.setStatus(ClusterHealthStatus.RED);
      return response;
    }

    return new ClusterHealthResponse(clusterState.getClusterName().value(), concreteIndices, clusterState, numberOfPendingTasks,
        numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState), pendingTaskTimeInQueue);
  }
}

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

private ClusterHealthResponse clusterHealth(ClusterHealthRequest request, ClusterState clusterState, int numberOfPendingTasks, int numberOfInFlightFetch,
                        TimeValue pendingTaskTimeInQueue) {
    if (logger.isTraceEnabled()) {
      logger.trace("Calculating health based on state version [{}]", clusterState.version());
    }

    String[] concreteIndices;
    try {
      concreteIndices = indexNameExpressionResolver.concreteIndices(clusterState, request);
    } catch (IndexNotFoundException e) {
      // one of the specified indices is not there - treat it as RED.
      ClusterHealthResponse response = new ClusterHealthResponse(clusterName.value(), Strings.EMPTY_ARRAY, clusterState,
          numberOfPendingTasks, numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState),
          pendingTaskTimeInQueue);
      response.setStatus(ClusterHealthStatus.RED);
      return response;
    }

    return new ClusterHealthResponse(clusterName.value(), concreteIndices, clusterState, numberOfPendingTasks,
        numberOfInFlightFetch, UnassignedInfo.getNumberOfDelayedUnassigned(clusterState), pendingTaskTimeInQueue);
  }
}