import org.elasticsearch.action.support.nodes.BaseNodesResponse; //导入依赖的package包/类
/**
 * Create the XContent header for any {@link BaseNodesResponse}.
 *
 * @param builder XContent builder.
 * @param params XContent parameters.
 * @param response The response containing individual, node-level responses.
 * @see #buildNodesHeader(XContentBuilder, Params, int, int, int, List)
 */
public static <NodeResponse extends BaseNodeResponse> void buildNodesHeader(final XContentBuilder builder, final Params params,
                                                                            final BaseNodesResponse<NodeResponse> response)
        throws IOException {
    final int successful = response.getNodes().size();
    final int failed = response.failures().size();

    buildNodesHeader(builder, params, successful + failed, successful, failed, response.failures());
}
 

import org.elasticsearch.action.support.nodes.BaseNodesResponse; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected AsyncShardFetch(Logger logger, String type, ShardId shardId, Lister<? extends BaseNodesResponse<T>, T> action) {
    this.logger = logger;
    this.type = type;
    this.shardId = shardId;
    this.action = (Lister<BaseNodesResponse<T>, T>) action;
}
 

import org.elasticsearch.action.support.nodes.BaseNodesResponse; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected AsyncShardFetch(ESLogger logger, String type, ShardId shardId, List<? extends BaseNodesResponse<T>, T> action) {
    this.logger = logger;
    this.type = type;
    this.shardId = shardId;
    this.action = (List<BaseNodesResponse<T>, T>) action;
}
 

import org.elasticsearch.action.support.nodes.BaseNodesResponse; //导入依赖的package包/类
InternalAsyncFetch(Logger logger, String type, ShardId shardId, Lister<? extends BaseNodesResponse<T>, T> action) {
    super(logger, type, shardId, action);
}
 

import org.elasticsearch.action.support.nodes.BaseNodesResponse; //导入依赖的package包/类
public InternalAsyncFetch(ESLogger logger, String type, ShardId shardId, List<? extends BaseNodesResponse<T>, T> action) {
    super(logger, type, shardId, action);
}
 

import org.elasticsearch.action.support.nodes.BaseNodesResponse; //导入依赖的package包/类
/**
 * Automatically transform the {@link ToXContent}-compatible, nodes-level {@code response} into a a {@link BytesRestResponse}.
 * <p>
 * This looks like:
 * <code>
 * {
 *   "_nodes" : { ... },
 *   "cluster_name" : "...",
 *   ...
 * }
 * </code>
 *
 * @param builder XContent builder.
 * @param params XContent parameters.
 * @param response The nodes-level (plural) response.
 * @return Never {@code null}.
 * @throws IOException if building the response causes an issue
 */
public static <NodesResponse extends BaseNodesResponse & ToXContent> BytesRestResponse nodesResponse(final XContentBuilder builder,
                                                                                                     final Params params,
                                                                                                     final NodesResponse response)
        throws IOException {
    builder.startObject();
    RestActions.buildNodesHeader(builder, params, response);
    builder.field("cluster_name", response.getClusterName().value());
    response.toXContent(builder, params);
    builder.endObject();

    return new BytesRestResponse(RestStatus.OK, builder);
}