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

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

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

AliasMetaData.getAlias介绍

暂无

代码示例

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

public Alias(AliasMetaData aliasMetaData, IndexMetaData indexMetaData) {
  this.aliasName = aliasMetaData.getAlias();
  this.referenceIndexMetaDatas = new ArrayList<>();
  this.referenceIndexMetaDatas.add(indexMetaData);
}

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

private SortedMap<String, AliasOrIndex> buildAliasAndIndexLookup() {
  SortedMap<String, AliasOrIndex> aliasAndIndexLookup = new TreeMap<>();
  for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
    IndexMetaData indexMetaData = cursor.value;
    AliasOrIndex existing = aliasAndIndexLookup.put(indexMetaData.getIndex().getName(), new AliasOrIndex.Index(indexMetaData));
    assert existing == null : "duplicate for " + indexMetaData.getIndex();
    for (ObjectObjectCursor<String, AliasMetaData> aliasCursor : indexMetaData.getAliases()) {
      AliasMetaData aliasMetaData = aliasCursor.value;
      aliasAndIndexLookup.compute(aliasMetaData.getAlias(), (aliasName, alias) -> {
        if (alias == null) {
          return new AliasOrIndex.Alias(aliasMetaData, indexMetaData);
        } else {
          assert alias instanceof AliasOrIndex.Alias : alias.getClass().getName();
          ((AliasOrIndex.Alias) alias).addIndex(indexMetaData);
          return alias;
        }
      });
    }
  }
  aliasAndIndexLookup.values().stream().filter(AliasOrIndex::isAlias)
    .forEach(alias -> ((AliasOrIndex.Alias) alias).computeAndValidateWriteIndex());
  return aliasAndIndexLookup;
}

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

return filterParser.apply(alias.filter().uncompressed());
} catch (IOException ex) {
  throw new AliasFilterParsingException(index, alias.getAlias(), "Invalid alias filter", ex);

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

public Alias(AliasMetaData aliasMetaData, IndexMetaData indexMetaData) {
  this.aliasName = aliasMetaData.getAlias();
  this.referenceIndexMetaDatas = new ArrayList<>();
  this.referenceIndexMetaDatas.add(indexMetaData);
}

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

public Alias(AliasMetaData aliasMetaData, IndexMetaData indexMetaData) {
  this.aliasName = aliasMetaData.getAlias();
  this.referenceIndexMetaDatas = new ArrayList<>();
  this.referenceIndexMetaDatas.add(indexMetaData);
}

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

public Alias(AliasMetaData aliasMetaData, IndexMetaData indexMetaData) {
  this.aliasName = aliasMetaData.getAlias();
  this.referenceIndexMetaDatas = new ArrayList<>();
  this.referenceIndexMetaDatas.add(indexMetaData);
}

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

public Alias(AliasMetaData aliasMetaData, IndexMetaData indexMetaData) {
  this.aliasName = aliasMetaData.getAlias();
  this.referenceIndexMetaDatas = new ArrayList<>();
  this.referenceIndexMetaDatas.add(indexMetaData);
}

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

private SortedMap<String, AliasOrIndex> buildAliasAndIndexLookup() {
  SortedMap<String, AliasOrIndex> aliasAndIndexLookup = new TreeMap<>();
  for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
    IndexMetaData indexMetaData = cursor.value;
    AliasOrIndex existing = aliasAndIndexLookup.put(indexMetaData.getIndex().getName(), new AliasOrIndex.Index(indexMetaData));
    assert existing == null : "duplicate for " + indexMetaData.getIndex();
    for (ObjectObjectCursor<String, AliasMetaData> aliasCursor : indexMetaData.getAliases()) {
      AliasMetaData aliasMetaData = aliasCursor.value;
      aliasAndIndexLookup.compute(aliasMetaData.getAlias(), (aliasName, alias) -> {
        if (alias == null) {
          return new AliasOrIndex.Alias(aliasMetaData, indexMetaData);
        } else {
          assert alias instanceof AliasOrIndex.Alias : alias.getClass().getName();
          ((AliasOrIndex.Alias) alias).addIndex(indexMetaData);
          return alias;
        }
      });
    }
  }
  aliasAndIndexLookup.values().stream().filter(AliasOrIndex::isAlias)
    .forEach(alias -> ((AliasOrIndex.Alias) alias).computeAndValidateWriteIndex());
  return aliasAndIndexLookup;
}

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

AliasOrIndex aliasOrIndex = aliasAndIndexLookup.get(aliasMetaData.getAlias());
if (aliasOrIndex == null) {
  aliasOrIndex = new AliasOrIndex.Alias(aliasMetaData, indexMetaData);
  aliasAndIndexLookup.put(aliasMetaData.getAlias(), aliasOrIndex);
} else if (aliasOrIndex instanceof AliasOrIndex.Alias) {
  AliasOrIndex.Alias alias = (AliasOrIndex.Alias) aliasOrIndex;
} else if (aliasOrIndex instanceof AliasOrIndex.Index) {
  AliasOrIndex.Index index = (AliasOrIndex.Index) aliasOrIndex;
  throw new IllegalStateException("index and alias names need to be unique, but alias [" + aliasMetaData.getAlias() + "] and index [" + index.getIndex().getIndex() + "] have the same name");
} else {
  throw new IllegalStateException("unexpected alias [" + aliasMetaData.getAlias() + "][" + aliasOrIndex + "]");

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

private SortedMap<String, AliasOrIndex> buildAliasAndIndexLookup() {
  SortedMap<String, AliasOrIndex> aliasAndIndexLookup = new TreeMap<>();
  for (ObjectCursor<IndexMetaData> cursor : indices.values()) {
    IndexMetaData indexMetaData = cursor.value;
    AliasOrIndex existing = aliasAndIndexLookup.put(indexMetaData.getIndex().getName(), new AliasOrIndex.Index(indexMetaData));
    assert existing == null : "duplicate for " + indexMetaData.getIndex();
    for (ObjectObjectCursor<String, AliasMetaData> aliasCursor : indexMetaData.getAliases()) {
      AliasMetaData aliasMetaData = aliasCursor.value;
      aliasAndIndexLookup.compute(aliasMetaData.getAlias(), (aliasName, alias) -> {
        if (alias == null) {
          return new AliasOrIndex.Alias(aliasMetaData, indexMetaData);
        } else {
          assert alias instanceof AliasOrIndex.Alias : alias.getClass().getName();
          ((AliasOrIndex.Alias) alias).addIndex(indexMetaData);
          return alias;
        }
      });
    }
  }
  aliasAndIndexLookup.values().stream().filter(AliasOrIndex::isAlias)
    .forEach(alias -> ((AliasOrIndex.Alias) alias).computeAndValidateWriteIndex());
  return aliasAndIndexLookup;
}

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

AliasOrIndex aliasOrIndex = aliasAndIndexLookup.get(aliasMetaData.getAlias());
if (aliasOrIndex == null) {
  aliasOrIndex = new AliasOrIndex.Alias(aliasMetaData, indexMetaData);
  aliasAndIndexLookup.put(aliasMetaData.getAlias(), aliasOrIndex);
} else if (aliasOrIndex instanceof AliasOrIndex.Alias) {
  AliasOrIndex.Alias alias = (AliasOrIndex.Alias) aliasOrIndex;
} else if (aliasOrIndex instanceof AliasOrIndex.Index) {
  AliasOrIndex.Index index = (AliasOrIndex.Index) aliasOrIndex;
  throw new IllegalStateException("index and alias names need to be unique, but alias [" + aliasMetaData.getAlias() + "] and index " + index.getIndex().getIndex() + " have the same name");
} else {
  throw new IllegalStateException("unexpected alias [" + aliasMetaData.getAlias() + "][" + aliasOrIndex + "]");

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

Query parse(AliasMetaData alias) {
  if (alias.filter() == null) {
    return null;
  }
  try {
    byte[] filterSource = alias.filter().uncompressed();
    try (XContentParser parser = XContentFactory.xContent(filterSource).createParser(filterSource)) {
      ParsedQuery parsedFilter = indexQueryParser.parseInnerFilter(parser);
      return parsedFilter == null ? null : parsedFilter.query();
    }
  } catch (IOException ex) {
    throw new AliasFilterParsingException(index, alias.getAlias(), "Invalid alias filter", ex);
  }
}

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

return filterParser.apply(alias.filter().uncompressed()).orElse(null);
} catch (IOException ex) {
  throw new AliasFilterParsingException(index, alias.getAlias(), "Invalid alias filter", ex);

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

return filterParser.apply(alias.filter().uncompressed());
} catch (IOException ex) {
  throw new AliasFilterParsingException(index, alias.getAlias(), "Invalid alias filter", ex);

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

return filterParser.apply(alias.filter().uncompressed());
} catch (IOException ex) {
  throw new AliasFilterParsingException(index, alias.getAlias(), "Invalid alias filter", ex);

代码示例来源:origin: jprante/elasticsearch-skywalker

builder.startObject();
AliasMetaData amd = aliases.get(alias.value).get(s.value);
builder.field("alias", amd.getAlias());
builder.field("filter", amd.getFilter().string());
builder.field("indexRouting", amd.getIndexRouting());

相关文章