org.elasticsearch.cluster.metadata.IndexMetaData.getTotalNumberOfShards()方法的使用及代码示例

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

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

IndexMetaData.getTotalNumberOfShards介绍

暂无

代码示例

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

/**
 * Returns the average of shards per node for the given index
 */
public float avgShardsPerNode(String index) {
  return ((float) metaData.index(index).getTotalNumberOfShards()) / nodes.size();
}

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

int numberOfShards = 0;
for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
  totalNumberOfShards += cursor.value.getTotalNumberOfShards();
  numberOfShards += cursor.value.getNumberOfShards();
  if (IndexMetaData.State.OPEN.equals(cursor.value.getState())) {
    totalOpenIndexShards += cursor.value.getTotalNumberOfShards();

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

/**
 * Returns the average of shards per node for the given index
 */
public float avgShardsPerNode(String index) {
  return ((float) metaData.index(index).getTotalNumberOfShards()) / nodes.size();
}

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

/**
 * Returns the average of shards per node for the given index
 */
public float avgShardsPerNode(String index) {
  return ((float) metaData.index(index).getTotalNumberOfShards()) / nodes.size();
}

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

/**
 * Returns the average of shards per node for the given index
 */
public float avgShardsPerNode(String index) {
  return ((float) metaData.index(index).getTotalNumberOfShards()) / nodes.size();
}

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

/**
 * Returns the average of shards per node for the given index
 */
public float avgShardsPerNode(String index) {
  return ((float) metaData.index(index).getTotalNumberOfShards()) / nodes.size();
}

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

@SuppressWarnings("unchecked")
MetaData(String clusterUUID, long version, Settings transientSettings, Settings persistentSettings, ImmutableOpenMap<String, IndexMetaData> indices, ImmutableOpenMap<String, IndexTemplateMetaData> templates, ImmutableOpenMap<String, Custom> customs, String[] allIndices, String[] allOpenIndices, String[] allClosedIndices, SortedMap<String, AliasOrIndex> aliasAndIndexLookup) {
  this.clusterUUID = clusterUUID;
  this.version = version;
  this.transientSettings = transientSettings;
  this.persistentSettings = persistentSettings;
  this.settings = Settings.settingsBuilder().put(persistentSettings).put(transientSettings).build();
  this.indices = indices;
  this.customs = customs;
  this.templates = templates;
  int totalNumberOfShards = 0;
  int numberOfShards = 0;
  for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
    totalNumberOfShards += cursor.value.getTotalNumberOfShards();
    numberOfShards += cursor.value.getNumberOfShards();
  }
  this.totalNumberOfShards = totalNumberOfShards;
  this.numberOfShards = numberOfShards;
  this.allIndices = allIndices;
  this.allOpenIndices = allOpenIndices;
  this.allClosedIndices = allClosedIndices;
  this.aliasAndIndexLookup = aliasAndIndexLookup;
}

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

int numberOfShards = 0;
for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
  totalNumberOfShards += cursor.value.getTotalNumberOfShards();
  numberOfShards += cursor.value.getNumberOfShards();
  if (IndexMetaData.State.OPEN.equals(cursor.value.getState())) {
    totalOpenIndexShards += cursor.value.getTotalNumberOfShards();

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

@SuppressWarnings("unchecked")
MetaData(String clusterUUID, long version, Settings transientSettings, Settings persistentSettings,
     ImmutableOpenMap<String, IndexMetaData> indices, ImmutableOpenMap<String, IndexTemplateMetaData> templates,
     ImmutableOpenMap<String, Custom> customs, String[] allIndices, String[] allOpenIndices, String[] allClosedIndices,
     SortedMap<String, AliasOrIndex> aliasAndIndexLookup) {
  this.clusterUUID = clusterUUID;
  this.version = version;
  this.transientSettings = transientSettings;
  this.persistentSettings = persistentSettings;
  this.settings = Settings.builder().put(persistentSettings).put(transientSettings).build();
  this.indices = indices;
  this.customs = customs;
  this.templates = templates;
  int totalNumberOfShards = 0;
  int numberOfShards = 0;
  for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
    totalNumberOfShards += cursor.value.getTotalNumberOfShards();
    numberOfShards += cursor.value.getNumberOfShards();
  }
  this.totalNumberOfShards = totalNumberOfShards;
  this.numberOfShards = numberOfShards;
  this.allIndices = allIndices;
  this.allOpenIndices = allOpenIndices;
  this.allClosedIndices = allClosedIndices;
  this.aliasAndIndexLookup = aliasAndIndexLookup;
}

代码示例来源:origin: jprante/elasticsearch-skywalker

builder.field("numberOfReplicas", imd.getNumberOfReplicas());
builder.field("numberOfShards", imd.getNumberOfShards());
builder.field("totalNumberOfShards", imd.getTotalNumberOfShards());
builder.field("version", imd.getVersion());
builder.field("settings", imd.getSettings().getAsMap());

相关文章

微信公众号

最新文章

更多

IndexMetaData类方法