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

IndicesService.indexShardStats介绍

暂无

代码示例

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

Map<Index, List<IndexShardStats>> statsByShard(final IndicesService indicesService, final CommonStatsFlags flags) {
  final Map<Index, List<IndexShardStats>> statsByShard = new HashMap<>();
  for (final IndexService indexService : indicesService) {
    for (final IndexShard indexShard : indexService) {
      try {
        final IndexShardStats indexShardStats = indicesService.indexShardStats(indicesService, indexShard, flags);
        if (indexShardStats == null) {
          continue;
        }
        if (statsByShard.containsKey(indexService.index()) == false) {
          statsByShard.put(indexService.index(), arrayAsArrayList(indexShardStats));
        } else {
          statsByShard.get(indexService.index()).add(indexShardStats);
        }
      } catch (IllegalIndexShardStateException | AlreadyClosedException e) {
        // we can safely ignore illegal state on ones that are closing for example
        logger.trace(() -> new ParameterizedMessage("{} ignoring shard stats", indexShard.shardId()), e);
      }
    }
  }
  return statsByShard;
}

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

Map<Index, List<IndexShardStats>> statsByShard(final IndicesService indicesService, final CommonStatsFlags flags) {
  final Map<Index, List<IndexShardStats>> statsByShard = new HashMap<>();
  for (final IndexService indexService : indicesService) {
    for (final IndexShard indexShard : indexService) {
      try {
        final IndexShardStats indexShardStats = indicesService.indexShardStats(indicesService, indexShard, flags);
        if (indexShardStats == null) {
          continue;
        }
        if (statsByShard.containsKey(indexService.index()) == false) {
          statsByShard.put(indexService.index(), arrayAsArrayList(indexShardStats));
        } else {
          statsByShard.get(indexService.index()).add(indexShardStats);
        }
      } catch (IllegalIndexShardStateException | AlreadyClosedException e) {
        // we can safely ignore illegal state on ones that are closing for example
        logger.trace(() -> new ParameterizedMessage("{} ignoring shard stats", indexShard.shardId()), e);
      }
    }
  }
  return statsByShard;
}

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

Map<Index, List<IndexShardStats>> statsByShard(final IndicesService indicesService, final CommonStatsFlags flags) {
  final Map<Index, List<IndexShardStats>> statsByShard = new HashMap<>();
  for (final IndexService indexService : indicesService) {
    for (final IndexShard indexShard : indexService) {
      try {
        final IndexShardStats indexShardStats = indicesService.indexShardStats(indicesService, indexShard, flags);
        if (indexShardStats == null) {
          continue;
        }
        if (statsByShard.containsKey(indexService.index()) == false) {
          statsByShard.put(indexService.index(), arrayAsArrayList(indexShardStats));
        } else {
          statsByShard.get(indexService.index()).add(indexShardStats);
        }
      } catch (IllegalIndexShardStateException | AlreadyClosedException e) {
        // we can safely ignore illegal state on ones that are closing for example
        logger.trace((Supplier<?>) () -> new ParameterizedMessage("{} ignoring shard stats", indexShard.shardId()), e);
      }
    }
  }
  return statsByShard;
}

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

Map<Index, List<IndexShardStats>> statsByShard(final IndicesService indicesService, final CommonStatsFlags flags) {
  final Map<Index, List<IndexShardStats>> statsByShard = new HashMap<>();
  for (final IndexService indexService : indicesService) {
    for (final IndexShard indexShard : indexService) {
      try {
        final IndexShardStats indexShardStats = indicesService.indexShardStats(indicesService, indexShard, flags);
        if (indexShardStats == null) {
          continue;
        }
        if (statsByShard.containsKey(indexService.index()) == false) {
          statsByShard.put(indexService.index(), arrayAsArrayList(indexShardStats));
        } else {
          statsByShard.get(indexService.index()).add(indexShardStats);
        }
      } catch (IllegalIndexShardStateException | AlreadyClosedException e) {
        // we can safely ignore illegal state on ones that are closing for example
        logger.trace(() -> new ParameterizedMessage("{} ignoring shard stats", indexShard.shardId()), e);
      }
    }
  }
  return statsByShard;
}