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

IndexMetaData.equals介绍

暂无

代码示例

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

@Override
public boolean equals(Object o) {
  if (this == o) return true;
  if (o == null || getClass() != o.getClass()) return false;
  ShardSplittingQuery that = (ShardSplittingQuery) o;
  if (shardId != that.shardId) return false;
  return indexMetaData.equals(that.indexMetaData);
}

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

/**
 * This method verifies that the given {@code metaData} holds sane values to create an {@link IndexService}.
 * This method tries to update the meta data of the created {@link IndexService} if the given {@code metaDataUpdate}
 * is different from the given {@code metaData}.
 * This method will throw an exception if the creation or the update fails.
 * The created {@link IndexService} will not be registered and will be closed immediately.
 */
public synchronized void verifyIndexMetadata(IndexMetaData metaData, IndexMetaData metaDataUpdate) throws IOException {
  final List<Closeable> closeables = new ArrayList<>();
  try {
    IndicesFieldDataCache indicesFieldDataCache = new IndicesFieldDataCache(settings, new IndexFieldDataCache.Listener() {});
    closeables.add(indicesFieldDataCache);
    IndicesQueryCache indicesQueryCache = new IndicesQueryCache(settings);
    closeables.add(indicesQueryCache);
    // this will also fail if some plugin fails etc. which is nice since we can verify that early
    final IndexService service =
      createIndexService("metadata verification", metaData, indicesQueryCache, indicesFieldDataCache, emptyList());
    closeables.add(() -> service.close("metadata verification", false));
    service.mapperService().merge(metaData, MapperService.MergeReason.MAPPING_RECOVERY, true);
    if (metaData.equals(metaDataUpdate) == false) {
      service.updateMetaData(metaData, metaDataUpdate);
    }
  } finally {
    IOUtils.close(closeables);
  }
}

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

@Override
public boolean equals(Object o) {
  if (this == o) return true;
  if (o == null || getClass() != o.getClass()) return false;
  ShardSplittingQuery that = (ShardSplittingQuery) o;
  if (shardId != that.shardId) return false;
  return indexMetaData.equals(that.indexMetaData);
}

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

@Override
public boolean equals(Object o) {
  if (this == o) return true;
  if (o == null || getClass() != o.getClass()) return false;
  ShardSplittingQuery that = (ShardSplittingQuery) o;
  if (shardId != that.shardId) return false;
  return indexMetaData.equals(that.indexMetaData);
}

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

/**
 * This method verifies that the given {@code metaData} holds sane values to create an {@link IndexService}.
 * This method tries to update the meta data of the created {@link IndexService} if the given {@code metaDataUpdate} is different from the given {@code metaData}.
 * This method will throw an exception if the creation or the update fails.
 * The created {@link IndexService} will not be registered and will be closed immediately.
 */
public synchronized void verifyIndexMetadata(IndexMetaData metaData, IndexMetaData metaDataUpdate) throws IOException {
  final List<Closeable> closeables = new ArrayList<>();
  try {
    IndicesFieldDataCache indicesFieldDataCache = new IndicesFieldDataCache(settings, new IndexFieldDataCache.Listener() {});
    closeables.add(indicesFieldDataCache);
    IndicesQueryCache indicesQueryCache = new IndicesQueryCache(settings);
    closeables.add(indicesQueryCache);
    // this will also fail if some plugin fails etc. which is nice since we can verify that early
    final IndexService service = createIndexService("metadata verification", metaData, indicesQueryCache, indicesFieldDataCache,
        emptyList());
    closeables.add(() -> service.close("metadata verification", false));
    service.mapperService().merge(metaData, MapperService.MergeReason.MAPPING_RECOVERY, true);
    if (metaData.equals(metaDataUpdate) == false) {
      service.updateMetaData(metaDataUpdate);
    }
  } finally {
    IOUtils.close(closeables);
  }
}

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

/**
 * This method verifies that the given {@code metaData} holds sane values to create an {@link IndexService}.
 * This method tries to update the meta data of the created {@link IndexService} if the given {@code metaDataUpdate} is different from the given {@code metaData}.
 * This method will throw an exception if the creation or the update fails.
 * The created {@link IndexService} will not be registered and will be closed immediately.
 */
public synchronized void verifyIndexMetadata(IndexMetaData metaData, IndexMetaData metaDataUpdate) throws IOException {
  final List<Closeable> closeables = new ArrayList<>();
  try {
    IndicesFieldDataCache indicesFieldDataCache = new IndicesFieldDataCache(settings, new IndexFieldDataCache.Listener() {});
    closeables.add(indicesFieldDataCache);
    IndicesQueryCache indicesQueryCache = new IndicesQueryCache(settings);
    closeables.add(indicesQueryCache);
    // this will also fail if some plugin fails etc. which is nice since we can verify that early
    final IndexService service =
      createIndexService("metadata verification", metaData, indicesQueryCache, indicesFieldDataCache, emptyList());
    closeables.add(() -> service.close("metadata verification", false));
    service.mapperService().merge(metaData, MapperService.MergeReason.MAPPING_RECOVERY, true);
    if (metaData.equals(metaDataUpdate) == false) {
      service.updateMetaData(metaData, metaDataUpdate);
    }
  } finally {
    IOUtils.close(closeables);
  }
}

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

if (indexMetaData.keyspace().equals(this.baseCfs.metadata.ksName) && 
  indexMetaData.mapping(ClusterService.cfNameToType(this.baseCfs.name)) != null &&
  !indexMetaData.equals(event.previousState().metaData().index(indexMetaData.getIndex().getName()))) {
  updateMapping = true;
  break;