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

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

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

AliasMetaData.indexRouting介绍

暂无

代码示例

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

public String getIndexRouting() {
  return indexRouting();
}

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

/**
 * Allows to validate an {@link org.elasticsearch.cluster.metadata.AliasMetaData} and make sure
 * it's valid before it gets added to the index metadata. Doesn't validate the alias filter.
 * @throws IllegalArgumentException if the alias is not valid
 */
public void validateAliasMetaData(AliasMetaData aliasMetaData, String index, MetaData metaData) {
  validateAlias(aliasMetaData.alias(), index, aliasMetaData.indexRouting(), metaData::index);
}

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

if (aliasMd.indexRouting() != null) {
  if (aliasMd.indexRouting().indexOf(',') != -1) {
    throw new IllegalArgumentException("index/alias [" + aliasOrIndex + "] provided with routing value [" +
      aliasMd.getIndexRouting() + "] that resolved to several routing values, rejecting operation");
    if (!routing.equals(aliasMd.indexRouting())) {
      throw new IllegalArgumentException("Alias [" + aliasOrIndex + "] has index routing associated with it [" +
        aliasMd.indexRouting() + "], and was provided with routing value [" + routing + "], rejecting operation");
  return aliasMd.indexRouting();

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

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

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

if (aliasMd.indexRouting() != null) {
  if (aliasMd.indexRouting().indexOf(',') != -1) {
    throw new IllegalArgumentException("index/alias [" + aliasOrIndex + "] provided with routing value ["
      + aliasMd.getIndexRouting() + "] that resolved to several routing values, rejecting operation");
    if (!routing.equals(aliasMd.indexRouting())) {
      throw new IllegalArgumentException("Alias [" + aliasOrIndex + "] has index routing associated with it ["
        + aliasMd.indexRouting() + "], and was provided with routing value [" + routing + "], rejecting operation");
  return aliasMd.indexRouting();

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

private Table buildTable(RestRequest request, GetAliasesResponse response) {
  Table table = getTableWithHeader(request);
  for (ObjectObjectCursor<String, List<AliasMetaData>> cursor : response.getAliases()) {
    String indexName = cursor.key;
    for (AliasMetaData aliasMetaData : cursor.value) {
      table.startRow();
      table.addCell(aliasMetaData.alias());
      table.addCell(indexName);
      table.addCell(aliasMetaData.filteringRequired() ? "*" : "-");
      String indexRouting = Strings.hasLength(aliasMetaData.indexRouting()) ? aliasMetaData.indexRouting() : "-";
      table.addCell(indexRouting);
      String searchRouting = Strings.hasLength(aliasMetaData.searchRouting()) ? aliasMetaData.searchRouting() : "-";
      table.addCell(searchRouting);
      table.endRow();
    }
  }
  return table;
}

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

public String getIndexRouting() {
  return indexRouting();
}

代码示例来源: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: apache/servicemix-bundles

/**
 * Allows to validate an {@link org.elasticsearch.cluster.metadata.AliasMetaData} and make sure
 * it's valid before it gets added to the index metadata. Doesn't validate the alias filter.
 * @throws IllegalArgumentException if the alias is not valid
 */
public void validateAliasMetaData(AliasMetaData aliasMetaData, String index, MetaData metaData) {
  validateAlias(aliasMetaData.alias(), index, aliasMetaData.indexRouting(), metaData::index);
}

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

/**
 * Allows to validate an {@link org.elasticsearch.cluster.metadata.AliasMetaData} and make sure
 * it's valid before it gets added to the index metadata. Doesn't validate the alias filter.
 * @throws IllegalArgumentException if the alias is not valid
 */
public void validateAliasMetaData(AliasMetaData aliasMetaData, String index, MetaData metaData) {
  validateAlias(aliasMetaData.alias(), index, aliasMetaData.indexRouting(), metaData::index);
}

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

/**
 * Allows to validate an {@link org.elasticsearch.cluster.metadata.AliasMetaData} and make sure
 * it's valid before it gets added to the index metadata. Doesn't validate the alias filter.
 * @throws IllegalArgumentException if the alias is not valid
 */
public void validateAliasMetaData(AliasMetaData aliasMetaData, String index, MetaData metaData) {
  validateAlias(aliasMetaData.alias(), index, aliasMetaData.indexRouting(), metaData);
}

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

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

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

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

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

/**
 * Allows to validate an {@link org.elasticsearch.cluster.metadata.AliasMetaData} and make sure
 * it's valid before it gets added to the index metadata. Doesn't validate the alias filter.
 * @throws IllegalArgumentException if the alias is not valid
 */
public void validateAliasMetaData(AliasMetaData aliasMetaData, String index, MetaData metaData) {
  validateAlias(aliasMetaData.alias(), index, aliasMetaData.indexRouting(), name -> metaData.index(name));
}

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

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

代码示例来源: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: 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();
}

相关文章