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

x33g5p2x  于2022-01-25 转载在 其他  
字(11.6k)|赞(0)|评价(0)|浏览(126)

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

MetaData.builder介绍

暂无

代码示例

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

metaDataBuilder = MetaData.builder(oldMetaData);

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

/**
 * Loads the full state, which includes both the global state and all the indices
 * meta state.
 */
MetaData loadFullState() throws IOException {
  MetaData globalMetaData = loadGlobalState();
  MetaData.Builder metaDataBuilder;
  if (globalMetaData != null) {
    metaDataBuilder = MetaData.builder(globalMetaData);
  } else {
    metaDataBuilder = MetaData.builder();
  }
  for (String indexFolderName : nodeEnv.availableIndexFolders()) {
    IndexMetaData indexMetaData = IndexMetaData.FORMAT.loadLatestState(logger, namedXContentRegistry,
      nodeEnv.resolveIndexFolder(indexFolderName));
    if (indexMetaData != null) {
      metaDataBuilder.put(indexMetaData, false);
    } else {
      logger.debug("[{}] failed to find metadata for existing index location", indexFolderName);
    }
  }
  return metaDataBuilder.build();
}

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

/**
 * For interoperability with transport clients older than 6.3, we need to strip customs
 * from the cluster state that the client might not be able to deserialize
 *
 * @param clusterState the cluster state to filter the customs from
 * @return the adapted cluster state
 */
public static ClusterState filterCustomsForPre63Clients(ClusterState clusterState) {
  final ClusterState.Builder builder = ClusterState.builder(clusterState);
  clusterState.customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_CLUSTER_CUSTOMS_WHITE_LIST.contains(name) == false) {
      builder.removeCustom(name);
    }
  });
  final MetaData.Builder metaBuilder = MetaData.builder(clusterState.metaData());
  clusterState.metaData().customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_METADATA_CUSTOMS_WHITE_LIST.contains(name) == false) {
      metaBuilder.removeCustom(name);
    }
  });
  return builder.metaData(metaBuilder).build();
}

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

ensureRepositoryNotInUse(currentState, request.name);
MetaData metaData = currentState.metaData();
MetaData.Builder mdBuilder = MetaData.builder(currentState.metaData());
RepositoriesMetaData repositories = metaData.custom(RepositoriesMetaData.TYPE);
if (repositories == null) {

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

@Override
public ClusterState execute(ClusterState currentState) {
  Set<String> templateNames = new HashSet<>();
  for (ObjectCursor<String> cursor : currentState.metaData().templates().keys()) {
    String templateName = cursor.value;
    if (Regex.simpleMatch(request.name, templateName)) {
      templateNames.add(templateName);
    }
  }
  if (templateNames.isEmpty()) {
    // if its a match all pattern, and no templates are found (we have none), don't
    // fail with index missing...
    if (Regex.isMatchAllPattern(request.name)) {
      return currentState;
    }
    throw new IndexTemplateMissingException(request.name);
  }
  MetaData.Builder metaData = MetaData.builder(currentState.metaData());
  for (String templateName : templateNames) {
    logger.info("removing template [{}]", templateName);
    metaData.removeTemplate(templateName);
  }
  return ClusterState.builder(currentState).metaData(metaData).build();
}

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

static ClusterState innerDelete(DeletePipelineRequest request, ClusterState currentState) {
  IngestMetadata currentIngestMetadata = currentState.metaData().custom(IngestMetadata.TYPE);
  if (currentIngestMetadata == null) {
    return currentState;
  }
  Map<String, PipelineConfiguration> pipelines = currentIngestMetadata.getPipelines();
  Set<String> toRemove = new HashSet<>();
  for (String pipelineKey : pipelines.keySet()) {
    if (Regex.simpleMatch(request.getId(), pipelineKey)) {
      toRemove.add(pipelineKey);
    }
  }
  if (toRemove.isEmpty() && Regex.isMatchAllPattern(request.getId()) == false) {
    throw new ResourceNotFoundException("pipeline [{}] is missing", request.getId());
  } else if (toRemove.isEmpty()) {
    return currentState;
  }
  final Map<String, PipelineConfiguration> pipelinesCopy = new HashMap<>(pipelines);
  for (String key : toRemove) {
    pipelinesCopy.remove(key);
  }
  ClusterState.Builder newState = ClusterState.builder(currentState);
  newState.metaData(MetaData.builder(currentState.getMetaData())
      .putCustom(IngestMetadata.TYPE, new IngestMetadata(pipelinesCopy))
      .build());
  return newState.build();
}

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

private static ClusterState update(ClusterState currentState, PersistentTasksCustomMetaData.Builder tasksInProgress) {
  if (tasksInProgress.isChanged()) {
    return ClusterState.builder(currentState).metaData(
        MetaData.builder(currentState.metaData()).putCustom(PersistentTasksCustomMetaData.TYPE, tasksInProgress.build())
    ).build();
  } else {
    return currentState;
  }
}

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

static ClusterState innerPut(PutPipelineRequest request, ClusterState currentState) {
  IngestMetadata currentIngestMetadata = currentState.metaData().custom(IngestMetadata.TYPE);
  Map<String, PipelineConfiguration> pipelines;
  if (currentIngestMetadata != null) {
    pipelines = new HashMap<>(currentIngestMetadata.getPipelines());
  } else {
    pipelines = new HashMap<>();
  }
  pipelines.put(request.getId(), new PipelineConfiguration(request.getId(), request.getSource(), request.getXContentType()));
  ClusterState.Builder newState = ClusterState.builder(currentState);
  newState.metaData(MetaData.builder(currentState.getMetaData())
    .putCustom(IngestMetadata.TYPE, new IngestMetadata(pipelines))
    .build());
  return newState.build();
}

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

@Override
  public ClusterState execute(ClusterState currentState) {
    MetaData.Builder metaDataBuilder = MetaData.builder(currentState.metaData());
    for (Map.Entry<String, Tuple<Version, String>> entry : request.versions().entrySet()) {
      String index = entry.getKey();
      IndexMetaData indexMetaData = metaDataBuilder.get(index);
      if (indexMetaData != null) {
        if (Version.CURRENT.equals(indexMetaData.getCreationVersion()) == false) {
          // no reason to pollute the settings, we didn't really upgrade anything
          metaDataBuilder.put(
              IndexMetaData
                  .builder(indexMetaData)
                  .settings(
                      Settings
                          .builder()
                          .put(indexMetaData.getSettings())
                          .put(IndexMetaData.SETTING_VERSION_UPGRADED, entry.getValue().v1()))
                  .settingsVersion(1 + indexMetaData.getSettingsVersion()));
        }
      }
    }
    return ClusterState.builder(currentState).metaData(metaDataBuilder).build();
  }
});

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

} else {
  final RoutingTable.Builder routingTableBuilder = RoutingTable.builder(clusterState.routingTable());
  final MetaData.Builder metaDataBuilder = MetaData.builder(clusterState.metaData());
  for (Map.Entry<Integer, List<String>> entry : autoExpandReplicaChanges.entrySet()) {
    final int numberOfReplicas = entry.getKey();

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

@Override
public ClusterState execute(ClusterState currentState) {
  ensureRepositoryNotInUse(currentState, request.name);
  MetaData metaData = currentState.metaData();
  MetaData.Builder mdBuilder = MetaData.builder(currentState.metaData());
  RepositoriesMetaData repositories = metaData.custom(RepositoriesMetaData.TYPE);
  if (repositories != null && repositories.repositories().size() > 0) {
    List<RepositoryMetaData> repositoriesMetaData = new ArrayList<>(repositories.repositories().size());
    boolean changed = false;
    for (RepositoryMetaData repositoryMetaData : repositories.repositories()) {
      if (Regex.simpleMatch(request.name, repositoryMetaData.name())) {
        logger.info("delete repository [{}]", repositoryMetaData.name());
        changed = true;
      } else {
        repositoriesMetaData.add(repositoryMetaData);
      }
    }
    if (changed) {
      repositories = new RepositoriesMetaData(repositoriesMetaData);
      mdBuilder.putCustom(RepositoriesMetaData.TYPE, repositories);
      return ClusterState.builder(currentState).metaData(mdBuilder).build();
    }
  }
  if (Regex.isMatchAllPattern(request.name)) { // we use a wildcard so we don't barf if it's not present.
    return currentState;
  }
  throw new RepositoryMissingException(request.name);
}

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

@Override
  public ClusterState execute(ClusterState currentState) throws Exception {
    ScriptMetaData smd = currentState.metaData().custom(ScriptMetaData.TYPE);
    smd = ScriptMetaData.putStoredScript(smd, request.id(), source);
    MetaData.Builder mdb = MetaData.builder(currentState.getMetaData()).putCustom(ScriptMetaData.TYPE, smd);
    return ClusterState.builder(currentState).metaData(mdb).build();
  }
});

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

@Override
  public ClusterState execute(ClusterState currentState) throws Exception {
    ScriptMetaData smd = currentState.metaData().custom(ScriptMetaData.TYPE);
    smd = ScriptMetaData.deleteStoredScript(smd, request.id());
    MetaData.Builder mdb = MetaData.builder(currentState.getMetaData()).putCustom(ScriptMetaData.TYPE, smd);
    return ClusterState.builder(currentState).metaData(mdb).build();
  }
});

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

@Override
  public MetaData apply(MetaData part) {
    Builder builder = builder();
    builder.clusterUUID(clusterUUID);
    builder.version(version);
    builder.transientSettings(transientSettings);
    builder.persistentSettings(persistentSettings);
    builder.indices(indices.apply(part.indices));
    builder.templates(templates.apply(part.templates));
    builder.customs(customs.apply(part.customs));
    return builder.build();
  }
}

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

@Override
public ClusterState execute(ClusterState currentState) throws Exception {
  if (request.create && currentState.metaData().templates().containsKey(request.name)) {
    throw new IllegalArgumentException("index_template [" + request.name + "] already exists");
  }
  validateAndAddTemplate(request, templateBuilder, indicesService, xContentRegistry);
  for (Alias alias : request.aliases) {
    AliasMetaData aliasMetaData = AliasMetaData.builder(alias.name()).filter(alias.filter())
      .indexRouting(alias.indexRouting()).searchRouting(alias.searchRouting()).build();
    templateBuilder.putAlias(aliasMetaData);
  }
  IndexTemplateMetaData template = templateBuilder.build();
  MetaData.Builder builder = MetaData.builder(currentState.metaData()).put(template);
  logger.info("adding template [{}] for index patterns {}", request.name, request.indexPatterns);
  return ClusterState.builder(currentState).metaData(builder).build();
}

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

final MetaData.Builder upgradedMetaData = MetaData.builder(metaData);
for (IndexMetaData indexMetaData : metaData) {
  IndexMetaData newMetaData = metaDataIndexUpgradeService.upgradeIndexMetaData(indexMetaData,

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

logger.info("closing indices [{}]", indicesAsString);
MetaData.Builder mdBuilder = MetaData.builder(currentState.metaData());
ClusterBlocks.Builder blocksBuilder = ClusterBlocks.builder()
  .blocks(currentState.blocks());

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

private ClusterState patchVersions(ClusterState previousClusterState, ClusterTasksResult<?> executionResult) {
  ClusterState newClusterState = executionResult.resultingState;
  if (previousClusterState != newClusterState) {
    // only the master controls the version numbers
    Builder builder = ClusterState.builder(newClusterState).incrementVersion();
    if (previousClusterState.routingTable() != newClusterState.routingTable()) {
      builder.routingTable(RoutingTable.builder(newClusterState.routingTable())
        .version(newClusterState.routingTable().version() + 1).build());
    }
    if (previousClusterState.metaData() != newClusterState.metaData()) {
      builder.metaData(MetaData.builder(newClusterState.metaData()).version(newClusterState.metaData().version() + 1));
    }
    newClusterState = builder.build();
  }
  return newClusterState;
}

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

MetaData.Builder mdBuilder = MetaData.builder(currentState.metaData());
ClusterBlocks.Builder blocksBuilder = ClusterBlocks.builder()
    .blocks(currentState.blocks());

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

.removeGlobalBlock(STATE_NOT_RECOVERED_BLOCK);
MetaData.Builder metaDataBuilder = MetaData.builder(recoveredState.metaData());

内容来源于网络，如有侵权，请联系作者删除！

Metadata

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    MetaData类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com