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

x33g5p2x  于2022-01-25 转载在 其他  
字(7.6k)|赞(0)|评价(0)|浏览(88)

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

MetaData.findAliases介绍

[英]Finds the specific index aliases that match with the specified aliases directly or partially via wildcards and that point to the specified concrete indices or match partially with the indices via wildcards.
[中]查找直接或部分通过通配符与指定别名匹配、指向指定具体索引或部分通过通配符与索引匹配的特定索引别名。

代码示例

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

private static String[] concreteAliases(AliasActions action, MetaData metaData, String concreteIndex) {
    if (action.expandAliasesWildcards()) {
      //for DELETE we expand the aliases
      String[] indexAsArray = {concreteIndex};
      ImmutableOpenMap<String, List<AliasMetaData>> aliasMetaData = metaData.findAliases(action.aliases(), indexAsArray);
      List<String> finalAliases = new ArrayList<>();
      for (ObjectCursor<List<AliasMetaData>> curAliases : aliasMetaData.values()) {
        for (AliasMetaData aliasMeta: curAliases.value) {
          finalAliases.add(aliasMeta.alias());
        }
      }
      return finalAliases.toArray(new String[finalAliases.size()]);
    } else {
      //for ADD and REMOVE_INDEX we just return the current aliases
      return action.aliases();
    }
  }
}

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

@Override
protected void masterOperation(GetAliasesRequest request, ClusterState state, ActionListener<GetAliasesResponse> listener) {
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(state, request);
  ImmutableOpenMap<String, List<AliasMetaData>> aliases = state.metaData().findAliases(request.aliases(), concreteIndices);
  listener.onResponse(new GetAliasesResponse(postProcess(request, concreteIndices, aliases)));
}

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

case ALIASES:
    if (!doneAliases) {
      aliasesResult = state.metaData().findAliases(Strings.EMPTY_ARRAY, concreteIndices);
      doneAliases = true;

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

public String[] concreteAliases(MetaData metaData, String concreteIndex) {
  if (expandAliasesWildcards()) {
    //for DELETE we expand the aliases
    String[] indexAsArray = {concreteIndex};
    ImmutableOpenMap<String, List<AliasMetaData>> aliasMetaData = metaData.findAliases(aliases, indexAsArray);
    List<String> finalAliases = new ArrayList<>();
    for (ObjectCursor<List<AliasMetaData>> curAliases : aliasMetaData.values()) {
      for (AliasMetaData aliasMeta: curAliases.value) {
        finalAliases.add(aliasMeta.alias());
      }
    }
    return finalAliases.toArray(new String[finalAliases.size()]);
  } else {
    //for add we just return the current aliases
    return aliases;
  }
}
public AliasActions readFrom(StreamInput in) throws IOException {

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

private static String[] concreteAliases(AliasActions action, MetaData metaData, String concreteIndex) {
    if (action.expandAliasesWildcards()) {
      //for DELETE we expand the aliases
      String[] indexAsArray = {concreteIndex};
      ImmutableOpenMap<String, List<AliasMetaData>> aliasMetaData = metaData.findAliases(action.aliases(), indexAsArray);
      List<String> finalAliases = new ArrayList<>();
      for (ObjectCursor<List<AliasMetaData>> curAliases : aliasMetaData.values()) {
        for (AliasMetaData aliasMeta: curAliases.value) {
          finalAliases.add(aliasMeta.alias());
        }
      }
      return finalAliases.toArray(new String[finalAliases.size()]);
    } else {
      //for ADD and REMOVE_INDEX we just return the current aliases
      return action.aliases();
    }
  }
}

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

private static String[] concreteAliases(AliasActions action, MetaData metaData, String concreteIndex) {
    if (action.expandAliasesWildcards()) {
      //for DELETE we expand the aliases
      String[] indexAsArray = {concreteIndex};
      ImmutableOpenMap<String, List<AliasMetaData>> aliasMetaData = metaData.findAliases(action.aliases(), indexAsArray);
      List<String> finalAliases = new ArrayList<>();
      for (ObjectCursor<List<AliasMetaData>> curAliases : aliasMetaData.values()) {
        for (AliasMetaData aliasMeta: curAliases.value) {
          finalAliases.add(aliasMeta.alias());
        }
      }
      return finalAliases.toArray(new String[finalAliases.size()]);
    } else {
      //for ADD and REMOVE_INDEX we just return the current aliases
      return action.aliases();
    }
  }
}

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

private static String[] concreteAliases(AliasActions action, MetaData metaData, String concreteIndex) {
    if (action.expandAliasesWildcards()) {
      //for DELETE we expand the aliases
      String[] indexAsArray = {concreteIndex};
      ImmutableOpenMap<String, List<AliasMetaData>> aliasMetaData = metaData.findAliases(action.aliases(), indexAsArray);
      List<String> finalAliases = new ArrayList<>();
      for (ObjectCursor<List<AliasMetaData>> curAliases : aliasMetaData.values()) {
        for (AliasMetaData aliasMeta: curAliases.value) {
          finalAliases.add(aliasMeta.alias());
        }
      }
      return finalAliases.toArray(new String[finalAliases.size()]);
    } else {
      //for ADD and REMOVE_INDEX we just return the current aliases
      return action.aliases();
    }
  }
}

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

@Override
protected void masterOperation(GetAliasesRequest request, ClusterState state, ActionListener<GetAliasesResponse> listener) {
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(state, request);
  @SuppressWarnings("unchecked")
      ImmutableOpenMap<String, List<AliasMetaData>> result = (ImmutableOpenMap) state.metaData().findAliases(request.aliases(), concreteIndices);
  listener.onResponse(new GetAliasesResponse(result));
}

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

@Override
protected void masterOperation(GetAliasesRequest request, ClusterState state, ActionListener<GetAliasesResponse> listener) {
  String[] concreteIndices = indexNameExpressionResolver.concreteIndices(state, request);
  @SuppressWarnings("unchecked")
      ImmutableOpenMap<String, List<AliasMetaData>> result = (ImmutableOpenMap) state.metaData().findAliases(request.aliases(), concreteIndices);
  listener.onResponse(new GetAliasesResponse(result));
}

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

@Override
protected void masterOperation(GetAliasesRequest request, ClusterState state, ActionListener<GetAliasesResponse> listener) {
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(state, request);
  ImmutableOpenMap<String, List<AliasMetaData>> aliases = state.metaData().findAliases(request.aliases(), concreteIndices);
  listener.onResponse(new GetAliasesResponse(postProcess(request, concreteIndices, aliases)));
}

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

@Override
protected void masterOperation(GetAliasesRequest request, ClusterState state, ActionListener<GetAliasesResponse> listener) {
  String[] concreteIndices = indexNameExpressionResolver.concreteIndexNames(state, request);
  ImmutableOpenMap<String, List<AliasMetaData>> aliases = state.metaData().findAliases(request.aliases(), concreteIndices);
  listener.onResponse(new GetAliasesResponse(postProcess(request, concreteIndices, aliases)));
}

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

case ALIASES:
    if (!doneAliases) {
      aliasesResult = state.metaData().findAliases(Strings.EMPTY_ARRAY, concreteIndices);
      doneAliases = true;

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

case ALIASES:
    if (!doneAliases) {
      aliasesResult = state.metaData().findAliases(Strings.EMPTY_ARRAY, concreteIndices);
      doneAliases = true;

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

case ALIASES:
    if (!doneAliases) {
      aliasesResult = state.metaData().findAliases(Strings.EMPTY_ARRAY, concreteIndices);
      doneAliases = true;

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

case ALIASES:
    if (!doneAliases) {
      aliasesResult = state.metaData().findAliases(Strings.EMPTY_ARRAY, concreteIndices);
      doneAliases = true;

相关文章

微信公众号

最新文章

更多