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

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

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

IndicesService.createIndexService介绍

[英]This creates a new IndexService without registering it
[中]这将创建一个新的IndexService而不注册它

代码示例

代码示例来源: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: org.elasticsearch/elasticsearch

finalListeners.add(oldShardsStats);
final IndexService indexService =
    createIndexService(
        "create index",
        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

finalListeners.add(onStoreClose);
finalListeners.add(oldShardsStats);
final IndexService indexService = createIndexService("create index", indexMetaData, indicesQueryCache, indicesFieldDataCache, finalListeners, indexingMemoryController);
boolean success = false;
try {

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

finalListeners.add(oldShardsStats);
final IndexService indexService =
    createIndexService(
        "create index",
        indexMetaData,

相关文章

微信公众号

最新文章

更多