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

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

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

IndexMetaData.getVersion介绍

暂无

代码示例

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

if (previouslyWrittenIndices.contains(index) == false || previousIndexMetaData == null) {
  writeReason = "freshly created";
} else if (previousIndexMetaData.getVersion() != newIndexMetaData.getVersion()) {
  writeReason = "version changed from [" + previousIndexMetaData.getVersion() + "] to [" +
    newIndexMetaData.getVersion() + "]";

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

for (IndexMetaData indexMetaData : metaData) {
  sb.append(TAB).append(indexMetaData.getIndex());
  sb.append(": v[").append(indexMetaData.getVersion())
      .append("], mv[").append(indexMetaData.getMappingVersion())
      .append("], sv[").append(indexMetaData.getSettingsVersion())

代码示例来源：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 static void toXContent(IndexMetaData indexMetaData, XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject(indexMetaData.getIndex().getName());
  builder.field(KEY_VERSION, indexMetaData.getVersion());
  builder.field(KEY_MAPPING_VERSION, indexMetaData.getMappingVersion());
  builder.field(KEY_SETTINGS_VERSION, indexMetaData.getSettingsVersion());

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

"upgraded to the latest version, adding as closed", indexMetaData.getIndex(), request.fromNode), ex);
upgradedIndexMetaData = IndexMetaData.builder(indexMetaData).state(IndexMetaData.State.CLOSE)
  .version(indexMetaData.getVersion() + 1).build();

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

} else if (indexMetaData.getVersion() > electedIndexMetaData.getVersion()) {
  electedIndexMetaData = indexMetaData;

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

indexMdBuilder.version(Math.max(snapshotIndexMetaData.getVersion(), currentIndexMetaData.getVersion() + 1));
indexMdBuilder.mappingVersion(Math.max(snapshotIndexMetaData.getMappingVersion(), currentIndexMetaData.getMappingVersion() + 1));
indexMdBuilder.settingsVersion(Math.max(snapshotIndexMetaData.getSettingsVersion(), currentIndexMetaData.getSettingsVersion() + 1));

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

/**
 * Loads the current meta state for each index in the new cluster state and checks if it has to be persisted.
 * Each index state that should be written to disk will be returned. This is only run for data only nodes.
 * It will return only the states for indices that actually have a shard allocated on the current node.
 *
 * @param previouslyWrittenIndices    A list of indices for which the state was already written before
 * @param potentiallyUnwrittenIndices The list of indices for which state should potentially be written
 * @param previousMetaData            The last meta data we know of. meta data for all indices in previouslyWrittenIndices list is persisted now
 * @param newMetaData                 The new metadata
 * @return iterable over all indices states that should be written to disk
 */
public static Iterable<GatewayMetaState.IndexMetaWriteInfo> resolveStatesToBeWritten(Set<Index> previouslyWrittenIndices, Set<Index> potentiallyUnwrittenIndices, MetaData previousMetaData, MetaData newMetaData) {
  List<GatewayMetaState.IndexMetaWriteInfo> indicesToWrite = new ArrayList<>();
  for (Index index : potentiallyUnwrittenIndices) {
    IndexMetaData newIndexMetaData = newMetaData.getIndexSafe(index);
    IndexMetaData previousIndexMetaData = previousMetaData == null ? null : previousMetaData.index(index);
    String writeReason = null;
    if (previouslyWrittenIndices.contains(index) == false || previousIndexMetaData == null) {
      writeReason = "freshly created";
    } else if (previousIndexMetaData.getVersion() != newIndexMetaData.getVersion()) {
      writeReason = "version changed from [" + previousIndexMetaData.getVersion() + "] to [" + newIndexMetaData.getVersion() + "]";
    }
    if (writeReason != null) {
      indicesToWrite.add(new GatewayMetaState.IndexMetaWriteInfo(newIndexMetaData, previousIndexMetaData, writeReason));
    }
  }
  return indicesToWrite;
}

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

/**
 * Loads the current meta state for each index in the new cluster state and checks if it has to be persisted.
 * Each index state that should be written to disk will be returned. This is only run for data only nodes.
 * It will return only the states for indices that actually have a shard allocated on the current node.
 *
 * @param previouslyWrittenIndices    A list of indices for which the state was already written before
 * @param potentiallyUnwrittenIndices The list of indices for which state should potentially be written
 * @param previousMetaData            The last meta data we know of. meta data for all indices in previouslyWrittenIndices list is persisted now
 * @param newMetaData                 The new metadata
 * @return iterable over all indices states that should be written to disk
 */
public static Iterable<GatewayMetaState.IndexMetaWriteInfo> resolveStatesToBeWritten(Set<Index> previouslyWrittenIndices, Set<Index> potentiallyUnwrittenIndices, MetaData previousMetaData, MetaData newMetaData) {
  List<GatewayMetaState.IndexMetaWriteInfo> indicesToWrite = new ArrayList<>();
  for (Index index : potentiallyUnwrittenIndices) {
    IndexMetaData newIndexMetaData = newMetaData.getIndexSafe(index);
    IndexMetaData previousIndexMetaData = previousMetaData == null ? null : previousMetaData.index(index);
    String writeReason = null;
    if (previouslyWrittenIndices.contains(index) == false || previousIndexMetaData == null) {
      writeReason = "freshly created";
    } else if (previousIndexMetaData.getVersion() != newIndexMetaData.getVersion()) {
      writeReason = "version changed from [" + previousIndexMetaData.getVersion() + "] to [" + newIndexMetaData.getVersion() + "]";
    }
    if (writeReason != null) {
      indicesToWrite.add(new GatewayMetaState.IndexMetaWriteInfo(newIndexMetaData, previousIndexMetaData, writeReason));
    }
  }
  return indicesToWrite;
}

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

/**
 * Loads the current meta state for each index in the new cluster state and checks if it has to be persisted.
 * Each index state that should be written to disk will be returned. This is only run for data only nodes.
 * It will return only the states for indices that actually have a shard allocated on the current node.
 *
 * @param previouslyWrittenIndices    A list of indices for which the state was already written before
 * @param potentiallyUnwrittenIndices The list of indices for which state should potentially be written
 * @param previousMetaData            The last meta data we know of. meta data for all indices in previouslyWrittenIndices list is persisted now
 * @param newMetaData                 The new metadata
 * @return iterable over all indices states that should be written to disk
 */
public static Iterable<GatewayMetaState.IndexMetaWriteInfo> resolveStatesToBeWritten(Set<Index> previouslyWrittenIndices, Set<Index> potentiallyUnwrittenIndices, MetaData previousMetaData, MetaData newMetaData) {
  List<GatewayMetaState.IndexMetaWriteInfo> indicesToWrite = new ArrayList<>();
  for (Index index : potentiallyUnwrittenIndices) {
    IndexMetaData newIndexMetaData = newMetaData.getIndexSafe(index);
    IndexMetaData previousIndexMetaData = previousMetaData == null ? null : previousMetaData.index(index);
    String writeReason = null;
    if (previouslyWrittenIndices.contains(index) == false || previousIndexMetaData == null) {
      writeReason = "freshly created";
    } else if (previousIndexMetaData.getVersion() != newIndexMetaData.getVersion()) {
      writeReason = "version changed from [" + previousIndexMetaData.getVersion() + "] to [" + newIndexMetaData.getVersion() + "]";
    }
    if (writeReason != null) {
      indicesToWrite.add(new GatewayMetaState.IndexMetaWriteInfo(newIndexMetaData, previousIndexMetaData, writeReason));
    }
  }
  return indicesToWrite;
}

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

/**
 * Loads the current meta state for each index in the new cluster state and checks if it has to be persisted.
 * Each index state that should be written to disk will be returned. This is only run for data only nodes.
 * It will return only the states for indices that actually have a shard allocated on the current node.
 *
 * @param previouslyWrittenIndices    A list of indices for which the state was already written before
 * @param potentiallyUnwrittenIndices The list of indices for which state should potentially be written
 * @param previousMetaData            The last meta data we know of. meta data for all indices in previouslyWrittenIndices list is persisted now
 * @param newMetaData                 The new metadata
 * @return iterable over all indices states that should be written to disk
 */
public static Iterable<GatewayMetaState.IndexMetaWriteInfo> resolveStatesToBeWritten(ImmutableSet<String> previouslyWrittenIndices, Set<String> potentiallyUnwrittenIndices, MetaData previousMetaData, MetaData newMetaData) {
  List<GatewayMetaState.IndexMetaWriteInfo> indicesToWrite = new ArrayList<>();
  for (String index : potentiallyUnwrittenIndices) {
    IndexMetaData newIndexMetaData = newMetaData.index(index);
    IndexMetaData previousIndexMetaData = previousMetaData == null ? null : previousMetaData.index(index);
    String writeReason = null;
    if (previouslyWrittenIndices.contains(index) == false || previousIndexMetaData == null) {
      writeReason = "freshly created";
    } else if (previousIndexMetaData.getVersion() != newIndexMetaData.getVersion()) {
      writeReason = "version changed from [" + previousIndexMetaData.getVersion() + "] to [" + newIndexMetaData.getVersion() + "]";
    }
    if (writeReason != null) {
      indicesToWrite.add(new GatewayMetaState.IndexMetaWriteInfo(newIndexMetaData, previousIndexMetaData, writeReason));
    }
  }
  return indicesToWrite;
}

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

for (IndexMetaData indexMetaData : metaData) {
  sb.append(TAB).append(indexMetaData.getIndex());
  sb.append(": v[").append(indexMetaData.getVersion()).append("]\n");
  for (int shard = 0; shard < indexMetaData.getNumberOfShards(); shard++) {
    sb.append(TAB).append(TAB).append(shard).append(": ");

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

public Builder put(IndexMetaData indexMetaData, boolean incrementVersion) {
  if (indices.get(indexMetaData.getIndex()) == 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(), indexMetaData);
  return this;
}

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

/**
 * Writes the index state.
 */
void writeIndex(String reason, IndexMetaData indexMetaData, @Nullable IndexMetaData previousIndexMetaData) throws Exception {
  logger.trace("[{}] writing state, reason [{}]", indexMetaData.getIndex(), reason);
  try {
    indexStateFormat.write(indexMetaData, indexMetaData.getVersion(),
        nodeEnv.indexPaths(new Index(indexMetaData.getIndex())));
  } catch (Throwable ex) {
    logger.warn("[{}]: failed to write index state", ex, indexMetaData.getIndex());
    throw new IOException("failed to write state for [" + indexMetaData.getIndex() + "]", ex);
  }
}

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

public static void toXContent(IndexMetaData indexMetaData, XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject(indexMetaData.getIndex(), XContentBuilder.FieldCaseConversion.NONE);
  builder.field("version", indexMetaData.getVersion());
  builder.field("state", indexMetaData.getState().toString().toLowerCase(Locale.ENGLISH));

代码示例来源：origin: com.strapdata.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.apache.servicemix.bundles/org.apache.servicemix.bundles.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: harbby/presto-connectors

/**
 * Elasticsearch 2.0 deprecated custom routing hash functions. So what we do here is that for old indices, we
 * move this old and deprecated node setting to an index setting so that we can keep things backward compatible.
 */
private IndexMetaData upgradeLegacyRoutingSettings(IndexMetaData indexMetaData) {
  if (indexMetaData.getSettings().get(IndexMetaData.SETTING_LEGACY_ROUTING_HASH_FUNCTION) == null
      && indexMetaData.getCreationVersion().before(Version.V_2_0_0_beta1)) {
    // these settings need an upgrade
    Settings indexSettings = Settings.builder().put(indexMetaData.getSettings())
        .put(IndexMetaData.SETTING_LEGACY_ROUTING_HASH_FUNCTION, pre20HashFunction)
        .put(IndexMetaData.SETTING_LEGACY_ROUTING_USE_TYPE, pre20UseType == null ? false : pre20UseType)
        .build();
    return IndexMetaData.builder(indexMetaData)
        .version(indexMetaData.getVersion())
        .settings(indexSettings)
        .build();
  } else if (indexMetaData.getCreationVersion().onOrAfter(Version.V_2_0_0_beta1)) {
    if (indexMetaData.getSettings().get(IndexMetaData.SETTING_LEGACY_ROUTING_HASH_FUNCTION) != null
        || indexMetaData.getSettings().get(IndexMetaData.SETTING_LEGACY_ROUTING_USE_TYPE) != null) {
      throw new IllegalStateException("Index [" + indexMetaData.getIndex() + "] created on or after 2.0 should NOT contain [" + IndexMetaData.SETTING_LEGACY_ROUTING_HASH_FUNCTION
          + "] + or [" + IndexMetaData.SETTING_LEGACY_ROUTING_USE_TYPE + "] in its index settings");
    }
  }
  return indexMetaData;
}

代码示例来源：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

IndexMetaData currentIndexMetaData = currentState.metaData().index(indexMetaData.getIndex());
if (currentIndexMetaData != null && currentIndexMetaData.isSameUUID(indexMetaData.getIndexUUID()) &&
    currentIndexMetaData.getVersion() == indexMetaData.getVersion()) {

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

IndexMetaData

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    IndexMetaData类方法

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