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

IndexMetaData.getIndex介绍

暂无

代码示例

代码示例来源：origin: floragunncom/search-guard

Set<String> doubleIndices = lookup.get(al).getIndices().stream().map(a->a.getIndex().getName()).collect(Collectors.toSet());
_indices.removeAll(doubleIndices);

代码示例来源：origin: Netflix/conductor

private void deleteAllIndices() {
  ImmutableOpenMap<String, IndexMetaData> indices = elasticSearchClient.admin().cluster()
      .prepareState().get().getState()
      .getMetaData().getIndices();
  indices.forEach(cursor -> {
    try {
      elasticSearchClient.admin()
          .indices()
          .delete(new DeleteIndexRequest(cursor.value.getIndex().getName()))
          .get();
    } catch (InterruptedException | ExecutionException e) {
      throw new RuntimeException(e);
    }
  });
}

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

public static Set<Index> getRelevantIndicesForMasterEligibleNode(ClusterState state) {
  Set<Index> relevantIndices;
  relevantIndices = new HashSet<>();
  // we have to iterate over the metadata to make sure we also capture closed indices
  for (IndexMetaData indexMetaData : state.metaData()) {
    relevantIndices.add(indexMetaData.getIndex());
  }
  return relevantIndices;
}

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

public Builder updateBlocks(IndexMetaData indexMetaData) {
  // let's remove all blocks for this index and add them back -- no need to remove all individual blocks....
  indices.remove(indexMetaData.getIndex().getName());
  return addBlocks(indexMetaData);
}

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

private void rejectSingleIndexOperation(String aliasOrIndex, AliasOrIndex result) {
  String[] indexNames = new String[result.getIndices().size()];
  int i = 0;
  for (IndexMetaData indexMetaData : result.getIndices()) {
    indexNames[i++] = indexMetaData.getIndex().getName();
  }
  throw new IllegalArgumentException("Alias [" + aliasOrIndex + "] has more than one index associated with it [" +
    Arrays.toString(indexNames) + "], can't execute a single index op");
}

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

IndexMetaData archiveBrokenIndexSettings(IndexMetaData indexMetaData) {
    final Settings settings = indexMetaData.getSettings();
    final Settings upgrade = indexScopedSettings.archiveUnknownOrInvalidSettings(
      settings,
      e -> logger.warn("{} ignoring unknown index setting: [{}] with value [{}]; archiving",
        indexMetaData.getIndex(), e.getKey(), e.getValue()),
      (e, ex) -> logger.warn(() -> new ParameterizedMessage("{} ignoring invalid index setting: [{}] with value [{}]; archiving",
        indexMetaData.getIndex(), e.getKey(), e.getValue()), ex));
    if (upgrade != settings) {
      return IndexMetaData.builder(indexMetaData).settings(upgrade).build();
    } else {
      return indexMetaData;
    }
  }
}

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

/** Returns true iff existing index has the same {@link IndexMetaData} instance */
public boolean hasIndexMetaData(final IndexMetaData indexMetaData) {
  return indices.get(indexMetaData.getIndex().getName()) == indexMetaData;
}

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

/**
 * Elasticsearch v6.0 no longer supports indices created pre v5.0. All indices
 * that were created before Elasticsearch v5.0 should be re-indexed in Elasticsearch 5.x
 * before they can be opened by this version of elasticsearch.
 */
private void checkSupportedVersion(IndexMetaData indexMetaData, Version minimumIndexCompatibilityVersion) {
  if (indexMetaData.getState() == IndexMetaData.State.OPEN && isSupportedVersion(indexMetaData,
    minimumIndexCompatibilityVersion) == false) {
    throw new IllegalStateException("The index [" + indexMetaData.getIndex() + "] was created with version ["
      + indexMetaData.getCreationVersion() + "] but the minimum compatible version is ["
      + minimumIndexCompatibilityVersion + "]. It should be re-indexed in Elasticsearch " + minimumIndexCompatibilityVersion.major
      + ".x before upgrading to " + Version.CURRENT + ".");
  }
}

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

/**
 * Validate a proposed alias.
 */
public void validateAlias(String alias, String index, @Nullable String indexRouting, Function<String, IndexMetaData> indexLookup) {
  validateAliasStandalone(alias, indexRouting);
  if (!Strings.hasText(index)) {
    throw new IllegalArgumentException("index name is required");
  }
  IndexMetaData indexNamedSameAsAlias = indexLookup.apply(alias);
  if (indexNamedSameAsAlias != null) {
    throw new InvalidAliasNameException(indexNamedSameAsAlias.getIndex(), alias, "an index exists with the same name as the alias");
  }
}

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

public Builder addAsRestore(IndexMetaData indexMetaData, SnapshotRecoverySource recoverySource) {
  IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetaData.getIndex())
      .initializeAsRestore(indexMetaData, recoverySource);
  add(indexRoutingBuilder);
  return this;
}

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

public Builder addAsNewRestore(IndexMetaData indexMetaData, SnapshotRecoverySource recoverySource, IntSet ignoreShards) {
  IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetaData.getIndex())
      .initializeAsNewRestore(indexMetaData, recoverySource, ignoreShards);
  add(indexRoutingBuilder);
  return this;
}

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

public Builder addAsFromCloseToOpen(IndexMetaData indexMetaData) {
  if (indexMetaData.getState() == IndexMetaData.State.OPEN) {
    IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetaData.getIndex())
        .initializeAsFromCloseToOpen(indexMetaData);
    add(indexRoutingBuilder);
  }
  return this;
}

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

public Builder addAsRecovery(IndexMetaData indexMetaData) {
  if (indexMetaData.getState() == IndexMetaData.State.OPEN) {
    IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetaData.getIndex())
        .initializeAsRecovery(indexMetaData);
    add(indexRoutingBuilder);
  }
  return this;
}

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

public Builder put(IndexMetaData indexMetaData, boolean incrementVersion) {
  if (indices.get(indexMetaData.getIndex().getName()) == indexMetaData) {
    return this;
  }
  // if we put a new index metadata, increment its version
  if (incrementVersion) {
    indexMetaData = IndexMetaData.builder(indexMetaData).version(indexMetaData.getVersion() + 1).build();
  }
  indices.put(indexMetaData.getIndex().getName(), indexMetaData);
  return this;
}

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

public Builder addAsNew(IndexMetaData indexMetaData) {
  if (indexMetaData.getState() == IndexMetaData.State.OPEN) {
    IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetaData.getIndex())
        .initializeAsNew(indexMetaData);
    add(indexRoutingBuilder);
  }
  return this;
}

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

public Builder addAsFromDangling(IndexMetaData indexMetaData) {
  if (indexMetaData.getState() == IndexMetaData.State.OPEN) {
    IndexRoutingTable.Builder indexRoutingBuilder = new IndexRoutingTable.Builder(indexMetaData.getIndex())
        .initializeAsFromDangling(indexMetaData);
    add(indexRoutingBuilder);
  }
  return this;
}

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

public ShardId shardId(ClusterState clusterState, String index, String id, @Nullable String routing) {
  IndexMetaData indexMetaData = indexMetaData(clusterState, index);
  return new ShardId(indexMetaData.getIndex(), generateShardId(indexMetaData, id, routing));
}

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

public Builder put(IndexMetaData.Builder indexMetaDataBuilder) {
  // we know its a new one, increment the version and store
  indexMetaDataBuilder.version(indexMetaDataBuilder.version() + 1);
  IndexMetaData indexMetaData = indexMetaDataBuilder.build();
  indices.put(indexMetaData.getIndex().getName(), indexMetaData);
  return this;
}

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

public boolean equalsAliases(MetaData other) {
  for (ObjectCursor<IndexMetaData> cursor : other.indices().values()) {
    IndexMetaData otherIndex = cursor.value;
    IndexMetaData thisIndex = index(otherIndex.getIndex());
    if (thisIndex == null) {
      return false;
    }
    if (otherIndex.getAliases().equals(thisIndex.getAliases()) == false) {
      return false;
    }
  }
  return true;
}

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

public Builder(IndexMetaData indexMetaData) {
  this.index = indexMetaData.getIndex().getName();
  this.state = indexMetaData.state;
  this.version = indexMetaData.version;
  this.mappingVersion = indexMetaData.mappingVersion;
  this.settingsVersion = indexMetaData.settingsVersion;
  this.settings = indexMetaData.getSettings();
  this.primaryTerms = indexMetaData.primaryTerms.clone();
  this.mappings = ImmutableOpenMap.builder(indexMetaData.mappings);
  this.aliases = ImmutableOpenMap.builder(indexMetaData.aliases);
  this.customMetaData = ImmutableOpenMap.builder(indexMetaData.customData);
  this.routingNumShards = indexMetaData.routingNumShards;
  this.inSyncAllocationIds = ImmutableOpenIntMap.builder(indexMetaData.inSyncAllocationIds);
  this.rolloverInfos = ImmutableOpenMap.builder(indexMetaData.rolloverInfos);
}