Java BaseNodesResponse类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.elasticsearch.action.support.nodes.BaseNodesResponse类的典型用法代码示例。如果您正苦于以下问题：Java BaseNodesResponse类的具体用法？Java BaseNodesResponse怎么用？Java BaseNodesResponse使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

BaseNodesResponse类属于org.elasticsearch.action.support.nodes包，在下文中一共展示了BaseNodesResponse类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: buildNodesHeader

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

开发者ID:justor，项目名称:elasticsearch_my，代码行数:17，代码来源:RestActions.java

示例2: AsyncShardFetch

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;
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:8，代码来源:AsyncShardFetch.java

示例3: AsyncShardFetch

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;
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:8，代码来源:AsyncShardFetch.java

示例4: InternalAsyncFetch

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

开发者ID:justor，项目名称:elasticsearch_my，代码行数:4，代码来源:GatewayAllocator.java

示例5: InternalAsyncFetch

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

开发者ID:baidu，项目名称:Elasticsearch，代码行数:4，代码来源:GatewayAllocator.java

示例6: nodesResponse

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

开发者ID:justor，项目名称:elasticsearch_my，代码行数:31，代码来源:RestActions.java

注：本文中的org.elasticsearch.action.support.nodes.BaseNodesResponse类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。