org.elasticsearch.indices.IndicesService.getIndicesQueryCache()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(5.4k)|赞(0)|评价(0)|浏览(63)

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

IndicesService.getIndicesQueryCache介绍

暂无

代码示例

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

indexShard.routingEntry(),
indexShard.shardPath(),
new CommonStats(indicesService.getIndicesQueryCache(), indexShard, SHARD_STATS_FLAGS),
commitStats,
seqNoStats));

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

IndexShardStats indexShardStats(final IndicesService indicesService, final IndexShard indexShard, final CommonStatsFlags flags) {
  if (indexShard.routingEntry() == null) {
    return null;
  }
  CommitStats commitStats;
  SeqNoStats seqNoStats;
  try {
    commitStats = indexShard.commitStats();
    seqNoStats = indexShard.seqNoStats();
  } catch (AlreadyClosedException e) {
    // shard is closed - no stats is fine
    commitStats = null;
    seqNoStats = null;
  }
  return new IndexShardStats(indexShard.shardId(),
                new ShardStats[] {
                  new ShardStats(indexShard.routingEntry(),
                         indexShard.shardPath(),
                         new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags),
                         commitStats,
                         seqNoStats)
                });
}

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

@Override
protected ClusterStatsNodeResponse nodeOperation(ClusterStatsNodeRequest nodeRequest) {
  NodeInfo nodeInfo = nodeService.info(true, true, false, true, false, true, false, true, false, false);
  NodeStats nodeStats = nodeService.stats(CommonStatsFlags.NONE, true, true, true, false, true, false, false, false, false, false, false);
  List<ShardStats> shardsStats = new ArrayList<>();
  for (IndexService indexService : indicesService) {
    for (IndexShard indexShard : indexService) {
      if (indexShard.routingEntry() != null && indexShard.routingEntry().active()) {
        // only report on fully started shards
        shardsStats.add(new ShardStats(indexShard.routingEntry(), indexShard.shardPath(), new CommonStats(indicesService.getIndicesQueryCache(), indexShard, SHARD_STATS_FLAGS), indexShard.commitStats()));
      }
    }
  }
  ClusterHealthStatus clusterStatus = null;
  if (clusterService.state().nodes().isLocalNodeElectedMaster()) {
    clusterStatus = new ClusterStateHealth(clusterService.state()).getStatus();
  }
  return new ClusterStatsNodeResponse(nodeInfo.getNode(), clusterStatus, nodeInfo, nodeStats, shardsStats.toArray(new ShardStats[shardsStats.size()]));
}

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

IndexShardStats indexShardStats(final IndicesService indicesService, final IndexShard indexShard, final CommonStatsFlags flags) {
  if (indexShard.routingEntry() == null) {
    return null;
  }
  CommitStats commitStats;
  SeqNoStats seqNoStats;
  try {
    commitStats = indexShard.commitStats();
    seqNoStats = indexShard.seqNoStats();
  } catch (AlreadyClosedException e) {
    // shard is closed - no stats is fine
    commitStats = null;
    seqNoStats = null;
  }
  return new IndexShardStats(indexShard.shardId(),
                new ShardStats[] {
                  new ShardStats(indexShard.routingEntry(),
                         indexShard.shardPath(),
                         new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags),
                         commitStats,
                         seqNoStats)
                });
}

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

indexShard.routingEntry(),
indexShard.shardPath(),
new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags), commitStats, seqNoStats);

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

IndexShardStats indexShardStats(final IndicesService indicesService, final IndexShard indexShard, final CommonStatsFlags flags) {
  if (indexShard.routingEntry() == null) {
    return null;
  }
  return new IndexShardStats(indexShard.shardId(),
                new ShardStats[] {
                  new ShardStats(indexShard.routingEntry(),
                         indexShard.shardPath(),
                         new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags),
                         indexShard.commitStats())
                });
}

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

indexShard.routingEntry(),
indexShard.shardPath(),
new CommonStats(indicesService.getIndicesQueryCache(), indexShard, SHARD_STATS_FLAGS),
commitStats,
seqNoStats));

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

indexShard.routingEntry(),
indexShard.shardPath(),
new CommonStats(indicesService.getIndicesQueryCache(), indexShard, SHARD_STATS_FLAGS),
commitStats,
seqNoStats));

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

IndexShardStats indexShardStats(final IndicesService indicesService, final IndexShard indexShard, final CommonStatsFlags flags) {
  if (indexShard.routingEntry() == null) {
    return null;
  }
  CommitStats commitStats;
  SeqNoStats seqNoStats;
  try {
    commitStats = indexShard.commitStats();
    seqNoStats = indexShard.seqNoStats();
  } catch (AlreadyClosedException e) {
    // shard is closed - no stats is fine
    commitStats = null;
    seqNoStats = null;
  }
  return new IndexShardStats(indexShard.shardId(),
                new ShardStats[] {
                  new ShardStats(indexShard.routingEntry(),
                         indexShard.shardPath(),
                         new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags),
                         commitStats,
                         seqNoStats)
                });
}

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

return new ShardStats(indexShard.routingEntry(), indexShard.shardPath(), new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags), indexShard.commitStats());

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

indexShard.routingEntry(),
indexShard.shardPath(),
new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags), commitStats, seqNoStats);

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

indexShard.routingEntry(),
indexShard.shardPath(),
new CommonStats(indicesService.getIndicesQueryCache(), indexShard, flags), commitStats, seqNoStats);

相关文章

微信公众号

最新文章

更多