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

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

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

IndexMetaData.version介绍

暂无

代码示例

代码示例来源:origin: io.fabric8.insight/insight-elasticsearch

for (IndexMetaData indexMetaData : updatedState.metaData()) {
  IndexMetaData currentIndexMetaData = currentState.metaData().index(indexMetaData.index());
  if (currentIndexMetaData == null || currentIndexMetaData.version() != indexMetaData.version()) {
    metaDataBuilder.put(indexMetaData, false);
  } else {

代码示例来源:origin: io.fabric8.insight/insight-elasticsearch-discovery

for (IndexMetaData indexMetaData : updatedState.metaData()) {
  IndexMetaData currentIndexMetaData = currentState.metaData().index(indexMetaData.index());
  if (currentIndexMetaData == null || currentIndexMetaData.version() != indexMetaData.version()) {
    metaDataBuilder.put(indexMetaData, false);
  } else {

代码示例来源:origin: jboss-fuse/fabric8

for (IndexMetaData indexMetaData : updatedState.metaData()) {
  IndexMetaData currentIndexMetaData = currentState.metaData().index(indexMetaData.index());
  if (currentIndexMetaData == null || currentIndexMetaData.version() != indexMetaData.version()) {
    metaDataBuilder.put(indexMetaData, false);
  } else {

代码示例来源:origin: org.fusesource.insight/insight-elasticsearch

@Override
public ClusterState execute(ClusterState currentState) {
  latestDiscoNodes = newState.nodes();
  ClusterState.Builder builder = ClusterState.builder().state(newState);
  // if the routing table did not change, use the original one
  if (newState.routingTable().version() == currentState.routingTable().version()) {
    builder.routingTable(currentState.routingTable());
  }
  // same for metadata
  if (newState.metaData().version() == currentState.metaData().version()) {
    builder.metaData(currentState.metaData());
  } else {
    // if its not the same version, only copy over new indices or ones that changed the version
    MetaData.Builder metaDataBuilder = MetaData.builder().metaData(newState.metaData()).removeAllIndices();
    for (IndexMetaData indexMetaData : newState.metaData()) {
      IndexMetaData currentIndexMetaData = currentState.metaData().index(indexMetaData.index());
      if (currentIndexMetaData == null || currentIndexMetaData.version() != indexMetaData.version()) {
        metaDataBuilder.put(indexMetaData, false);
      } else {
        metaDataBuilder.put(currentIndexMetaData, false);
      }
    }
    builder.metaData(metaDataBuilder);
  }
  return builder.build();
}

相关文章

微信公众号

最新文章

更多

IndexMetaData类方法