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

x33g5p2x  于2022-01-17 转载在 其他  
字(9.9k)|赞(0)|评价(0)|浏览(64)

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

AliasMetaData.writeIndex介绍

暂无

代码示例

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

public void computeAndValidateWriteIndex() {
    List<IndexMetaData> writeIndices = referenceIndexMetaDatas.stream()
      .filter(idxMeta -> Boolean.TRUE.equals(idxMeta.getAliases().get(aliasName).writeIndex()))
      .collect(Collectors.toList());
    if (writeIndices.isEmpty() && referenceIndexMetaDatas.size() == 1
        && referenceIndexMetaDatas.get(0).getAliases().get(aliasName).writeIndex() == null) {
      writeIndices.add(referenceIndexMetaDatas.get(0));
    }
    if (writeIndices.size() == 1) {
      writeIndex.set(writeIndices.get(0));
    } else if (writeIndices.size() > 1) {
      List<String> writeIndicesStrings = writeIndices.stream()
        .map(i -> i.getIndex().getName()).collect(Collectors.toList());
      throw new IllegalStateException("alias [" + aliasName + "] has more than one write index [" +
        Strings.collectionToCommaDelimitedString(writeIndicesStrings) + "]");
    }
  }
}

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

private AliasMetaData(AliasMetaData aliasMetaData, String alias) {
  this(alias, aliasMetaData.filter(), aliasMetaData.indexRouting(), aliasMetaData.searchRouting(), aliasMetaData.writeIndex());
}

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

public Builder(AliasMetaData aliasMetaData) {
  this(aliasMetaData.alias());
  filter = aliasMetaData.filter();
  indexRouting = aliasMetaData.indexRouting();
  searchRouting = aliasMetaData.searchRouting();
  writeIndex = aliasMetaData.writeIndex();
}

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

public static void toXContent(AliasMetaData aliasMetaData, XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject(aliasMetaData.alias());
  boolean binary = params.paramAsBoolean("binary", false);
  if (aliasMetaData.filter() != null) {
    if (binary) {
      builder.field("filter", aliasMetaData.filter.compressed());
    } else {
      builder.field("filter", XContentHelper.convertToMap(new BytesArray(aliasMetaData.filter().uncompressed()), true).v2());
    }
  }
  if (aliasMetaData.indexRouting() != null) {
    builder.field("index_routing", aliasMetaData.indexRouting());
  }
  if (aliasMetaData.searchRouting() != null) {
    builder.field("search_routing", aliasMetaData.searchRouting());
  }
  if (aliasMetaData.writeIndex() != null) {
    builder.field("is_write_index", aliasMetaData.writeIndex());
  }
  builder.endObject();
}

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

final AliasOrIndex.Alias alias = (AliasOrIndex.Alias) metaData.getAliasAndIndexLookup().get(rolloverRequest.getAlias());
final IndexMetaData indexMetaData = alias.getWriteIndex();
final boolean explicitWriteIndex = Boolean.TRUE.equals(indexMetaData.getAliases().get(alias.getAliasName()).writeIndex());
final String sourceProvidedName = indexMetaData.getSettings().get(IndexMetaData.SETTING_INDEX_PROVIDED_NAME,
  indexMetaData.getIndex().getName());

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(alias());
  if (filter() != null) {
    out.writeBoolean(true);
    filter.writeTo(out);
  } else {
    out.writeBoolean(false);
  }
  if (indexRouting() != null) {
    out.writeBoolean(true);
    out.writeString(indexRouting());
  } else {
    out.writeBoolean(false);
  }
  if (searchRouting() != null) {
    out.writeBoolean(true);
    out.writeString(searchRouting());
  } else {
    out.writeBoolean(false);
  }
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    out.writeOptionalBoolean(writeIndex());
  }
}

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

public void computeAndValidateWriteIndex() {
    List<IndexMetaData> writeIndices = referenceIndexMetaDatas.stream()
      .filter(idxMeta -> Boolean.TRUE.equals(idxMeta.getAliases().get(aliasName).writeIndex()))
      .collect(Collectors.toList());
    if (writeIndices.isEmpty() && referenceIndexMetaDatas.size() == 1
        && referenceIndexMetaDatas.get(0).getAliases().get(aliasName).writeIndex() == null) {
      writeIndices.add(referenceIndexMetaDatas.get(0));
    }
    if (writeIndices.size() == 1) {
      writeIndex.set(writeIndices.get(0));
    } else if (writeIndices.size() > 1) {
      List<String> writeIndicesStrings = writeIndices.stream()
        .map(i -> i.getIndex().getName()).collect(Collectors.toList());
      throw new IllegalStateException("alias [" + aliasName + "] has more than one write index [" +
        Strings.collectionToCommaDelimitedString(writeIndicesStrings) + "]");
    }
  }
}

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

public void computeAndValidateWriteIndex() {
    List<IndexMetaData> writeIndices = referenceIndexMetaDatas.stream()
      .filter(idxMeta -> Boolean.TRUE.equals(idxMeta.getAliases().get(aliasName).writeIndex()))
      .collect(Collectors.toList());
    if (writeIndices.isEmpty() && referenceIndexMetaDatas.size() == 1
        && referenceIndexMetaDatas.get(0).getAliases().get(aliasName).writeIndex() == null) {
      writeIndices.add(referenceIndexMetaDatas.get(0));
    }
    if (writeIndices.size() == 1) {
      writeIndex.set(writeIndices.get(0));
    } else if (writeIndices.size() > 1) {
      List<String> writeIndicesStrings = writeIndices.stream()
        .map(i -> i.getIndex().getName()).collect(Collectors.toList());
      throw new IllegalStateException("alias [" + aliasName + "] has more than one write index [" +
        Strings.collectionToCommaDelimitedString(writeIndicesStrings) + "]");
    }
  }
}

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

private AliasMetaData(AliasMetaData aliasMetaData, String alias) {
  this(alias, aliasMetaData.filter(), aliasMetaData.indexRouting(), aliasMetaData.searchRouting(), aliasMetaData.writeIndex());
}

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

private AliasMetaData(AliasMetaData aliasMetaData, String alias) {
  this(alias, aliasMetaData.filter(), aliasMetaData.indexRouting(), aliasMetaData.searchRouting(), aliasMetaData.writeIndex());
}

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

public Builder(AliasMetaData aliasMetaData) {
  this(aliasMetaData.alias());
  filter = aliasMetaData.filter();
  indexRouting = aliasMetaData.indexRouting();
  searchRouting = aliasMetaData.searchRouting();
  writeIndex = aliasMetaData.writeIndex();
}

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

public Builder(AliasMetaData aliasMetaData) {
  this(aliasMetaData.alias());
  filter = aliasMetaData.filter();
  indexRouting = aliasMetaData.indexRouting();
  searchRouting = aliasMetaData.searchRouting();
  writeIndex = aliasMetaData.writeIndex();
}

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

public static void toXContent(AliasMetaData aliasMetaData, XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject(aliasMetaData.alias());
  boolean binary = params.paramAsBoolean("binary", false);
  if (aliasMetaData.filter() != null) {
    if (binary) {
      builder.field("filter", aliasMetaData.filter.compressed());
    } else {
      builder.field("filter", XContentHelper.convertToMap(new BytesArray(aliasMetaData.filter().uncompressed()), true).v2());
    }
  }
  if (aliasMetaData.indexRouting() != null) {
    builder.field("index_routing", aliasMetaData.indexRouting());
  }
  if (aliasMetaData.searchRouting() != null) {
    builder.field("search_routing", aliasMetaData.searchRouting());
  }
  if (aliasMetaData.writeIndex() != null) {
    builder.field("is_write_index", aliasMetaData.writeIndex());
  }
  builder.endObject();
}

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

public static void toXContent(AliasMetaData aliasMetaData, XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject(aliasMetaData.alias());
  boolean binary = params.paramAsBoolean("binary", false);
  if (aliasMetaData.filter() != null) {
    if (binary) {
      builder.field("filter", aliasMetaData.filter.compressed());
    } else {
      builder.field("filter", XContentHelper.convertToMap(new BytesArray(aliasMetaData.filter().uncompressed()), true).v2());
    }
  }
  if (aliasMetaData.indexRouting() != null) {
    builder.field("index_routing", aliasMetaData.indexRouting());
  }
  if (aliasMetaData.searchRouting() != null) {
    builder.field("search_routing", aliasMetaData.searchRouting());
  }
  if (aliasMetaData.writeIndex() != null) {
    builder.field("is_write_index", aliasMetaData.writeIndex());
  }
  builder.endObject();
}

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

final AliasOrIndex.Alias alias = (AliasOrIndex.Alias) metaData.getAliasAndIndexLookup().get(rolloverRequest.getAlias());
final IndexMetaData indexMetaData = alias.getWriteIndex();
final boolean explicitWriteIndex = Boolean.TRUE.equals(indexMetaData.getAliases().get(alias.getAliasName()).writeIndex());
final String sourceProvidedName = indexMetaData.getSettings().get(IndexMetaData.SETTING_INDEX_PROVIDED_NAME,
  indexMetaData.getIndex().getName());

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(alias());
  if (filter() != null) {
    out.writeBoolean(true);
    filter.writeTo(out);
  } else {
    out.writeBoolean(false);
  }
  if (indexRouting() != null) {
    out.writeBoolean(true);
    out.writeString(indexRouting());
  } else {
    out.writeBoolean(false);
  }
  if (searchRouting() != null) {
    out.writeBoolean(true);
    out.writeString(searchRouting());
  } else {
    out.writeBoolean(false);
  }
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    out.writeOptionalBoolean(writeIndex());
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  out.writeString(alias());
  if (filter() != null) {
    out.writeBoolean(true);
    filter.writeTo(out);
  } else {
    out.writeBoolean(false);
  }
  if (indexRouting() != null) {
    out.writeBoolean(true);
    out.writeString(indexRouting());
  } else {
    out.writeBoolean(false);
  }
  if (searchRouting() != null) {
    out.writeBoolean(true);
    out.writeString(searchRouting());
  } else {
    out.writeBoolean(false);
  }
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    out.writeOptionalBoolean(writeIndex());
  }
}

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

AliasMetaData

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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