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

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

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

MetaData.addDefaultUnitsIfNeeded介绍

[英]As of 2.0 we require units for time and byte-sized settings. This methods adds default units to any settings that are part of timeSettings or byteSettings and don't specify a unit.
[中]从2.0开始,我们需要时间单位和字节大小的设置。此方法将默认单位添加到属于timeSettings或byteSettings的任何设置中,并且不指定单位。

代码示例

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

/**
 * Decode global state from a string.
 * @param stringMetaData
 * @return
 * @throws Exception
 */
public MetaData loadGlobalState(String stringMetaData) throws Exception {
  MetaData globalState = MetaData.CASSANDRA_FORMAT.loadLatestState(logger, namedXContentRegistry, stringMetaData);
  // ES 2.0 now requires units for all time and byte-sized settings, so we add the default unit if it's missing
  // TODO: can we somehow only do this for pre-2.0 cluster state?
  if (globalState != null) {
    return MetaData.addDefaultUnitsIfNeeded(logger, globalState);
  } else {
    return null;
  }
}

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

/**
 * Loads the global state, *without* index state, see {@link #loadFullState()} for that.
 */
MetaData loadGlobalState() throws IOException {
  MetaData globalState = globalStateFormat.loadLatestState(logger, nodeEnv.nodeDataPaths());
  // ES 2.0 now requires units for all time and byte-sized settings, so we add the default unit if it's missing
  // TODO: can we somehow only do this for pre-2.0 cluster state?
  if (globalState != null) {
    return MetaData.addDefaultUnitsIfNeeded(logger, globalState);
  } else {
    return null;
  }
}

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

/**
 * Loads the global state, *without* index state, see {@link #loadFullState()} for that.
 */
MetaData loadGlobalState() throws IOException {
  MetaData globalState = MetaData.FORMAT.loadLatestState(logger, namedXContentRegistry, nodeEnv.nodeDataPaths());
  // ES 2.0 now requires units for all time and byte-sized settings, so we add the default unit if it's missing
  // TODO: can we somehow only do this for pre-2.0 cluster state?
  if (globalState != null) {
    return MetaData.addDefaultUnitsIfNeeded(logger, globalState);
  } else {
    return null;
  }
}

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

/**
 * Elasticsearch 2.0 requires units on byte/memory and time settings; this method adds the default unit to any such settings that are
 * missing units.
 */
private IndexMetaData addDefaultUnitsIfNeeded(IndexMetaData indexMetaData) {
  if (indexMetaData.getCreationVersion().before(Version.V_2_0_0_beta1)) {
    // TODO: can we somehow only do this *once* for a pre-2.0 index?  Maybe we could stuff a "fake marker setting" here?  Seems hackish...
    // Created lazily if we find any settings that are missing units:
    Settings settings = indexMetaData.getSettings();
    Settings newSettings = MetaData.addDefaultUnitsIfNeeded(
        INDEX_TIME_SETTINGS, INDEX_BYTES_SIZE_SETTINGS, logger, settings);
    if (newSettings != null) {
      // At least one setting was changed:
      return IndexMetaData.builder(indexMetaData)
        .version(indexMetaData.getVersion())
        .settings(newSettings)
        .build();
    }
  }
  // No changes:
  return indexMetaData;
}

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

if (snapshotInfo.version().before(Version.V_2_0_0_beta1)) {
  metaData = MetaData.addDefaultUnitsIfNeeded(logger, metaDataIn);
} else {

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

IndexTemplateMetaData templateMetaData = cursor.value;
Settings currentSettings = templateMetaData.getSettings();
Settings newSettings = addDefaultUnitsIfNeeded(
    MetaDataIndexUpgradeService.INDEX_TIME_SETTINGS,
    MetaDataIndexUpgradeService.INDEX_BYTES_SIZE_SETTINGS,

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

/** As of 2.0 we require units for time and byte-sized settings. This methods adds default units to any
 * persistent settings and template settings that don't specify a unit.
 **/
public static MetaData addDefaultUnitsIfNeeded(ESLogger logger, MetaData metaData) {
  Settings newPersistentSettings = addDefaultUnitsIfNeeded(
      CLUSTER_TIME_SETTINGS, CLUSTER_BYTES_SIZE_SETTINGS, logger, metaData.persistentSettings());
  ImmutableOpenMap<String, IndexTemplateMetaData> templates = updateTemplates(logger, metaData.getTemplates());
  if (newPersistentSettings != null || templates != null) {
    return new MetaData(
        metaData.clusterUUID(),
        metaData.version(),
        metaData.transientSettings(),
        MoreObjects.firstNonNull(newPersistentSettings, metaData.persistentSettings()),
        metaData.getIndices(),
        MoreObjects.firstNonNull(templates, metaData.getTemplates()),
        metaData.getCustoms(),
        metaData.concreteAllIndices(),
        metaData.concreteAllOpenIndices(),
        metaData.concreteAllClosedIndices(),
        metaData.getAliasAndIndexLookup());
  } else {
    // No changes:
    return metaData;
  }
}

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

if (snapshot.version().before(Version.V_2_0_0_beta1)) {
  metaData = MetaData.addDefaultUnitsIfNeeded(logger, metaDataIn);
} else {

相关文章

微信公众号

最新文章

更多