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

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

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

MetaData.getConcreteAllIndices介绍

[英]Returns all the concrete indices.
[中]返回所有具体的索引。

代码示例

代码示例来源:origin: SonarSource/sonarqube

public void clearIndexes() {
 Loggers.get(getClass()).info("Truncate Elasticsearch indices");
 try {
  esClient.prepareClearCache().get();
  for (String index : esClient.prepareState().get().getState().getMetaData().getConcreteAllIndices()) {
   clearIndex(new IndexType(index, index));
  }
 } catch (Exception e) {
  throw new IllegalStateException("Unable to clear indexes", e);
 }
}

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

/**
 * Creates a new <code>ClusterStateHealth</code> instance considering the current cluster state and all indices in the cluster.
 *
 * @param clusterState The current cluster state. Must not be null.
 */
public ClusterStateHealth(final ClusterState clusterState) {
  this(clusterState, clusterState.metaData().getConcreteAllIndices());
}

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

/**
 * Identifies whether the first argument (an array containing index names) is a pattern that matches all indices
 *
 * @param indicesOrAliases the array containing index names
 * @param concreteIndices  array containing the concrete indices that the first argument refers to
 * @return true if the first argument is a pattern that maps to all available indices, false otherwise
 */
boolean isPatternMatchingAllIndices(MetaData metaData, String[] indicesOrAliases, String[] concreteIndices) {
  // if we end up matching on all indices, check, if its a wildcard parameter, or a "-something" structure
  if (concreteIndices.length == metaData.getConcreteAllIndices().length && indicesOrAliases.length > 0) {
    //we might have something like /-test1,+test1 that would identify all indices
    //or something like /-test1 with test1 index missing and IndicesOptions.lenient()
    if (indicesOrAliases[0].charAt(0) == '-') {
      return true;
    }
    //otherwise we check if there's any simple regex
    for (String indexOrAlias : indicesOrAliases) {
      if (Regex.isSimpleMatchPattern(indexOrAlias)) {
        return true;
      }
    }
  }
  return false;
}

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

/**
 * Sets the same routing for all indices
 */
public Map<String, Set<String>> resolveSearchRoutingAllIndices(MetaData metaData, String routing) {
  if (routing != null) {
    Set<String> r = Sets.newHashSet(Strings.splitStringByCommaToArray(routing));
    Map<String, Set<String>> routings = new HashMap<>();
    String[] concreteIndices = metaData.getConcreteAllIndices();
    for (String index : concreteIndices) {
      routings.put(index, r);
    }
    return routings;
  }
  return null;
}

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

private static List<String> resolveEmptyOrTrivialWildcard(IndicesOptions options, MetaData metaData) {
    if (options.expandWildcardsOpen() && options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllIndices());
    } else if (options.expandWildcardsOpen()) {
      return Arrays.asList(metaData.getConcreteAllOpenIndices());
    } else if (options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllClosedIndices());
    } else {
      return Collections.emptyList();
    }
  }
}

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

/**
 * Creates a new <code>ClusterStateHealth</code> instance considering the current cluster state and all indices in the cluster.
 *
 * @param clusterState The current cluster state. Must not be null.
 */
public ClusterStateHealth(final ClusterState clusterState) {
  this(clusterState, clusterState.metaData().getConcreteAllIndices());
}

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

/**
 * Creates a new <code>ClusterStateHealth</code> instance considering the current cluster state and all indices in the cluster.
 *
 * @param clusterState The current cluster state. Must not be null.
 */
public ClusterStateHealth(final ClusterState clusterState) {
  this(clusterState, clusterState.metaData().getConcreteAllIndices());
}

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

/**
 * Creates a new <code>ClusterStateHealth</code> instance considering the current cluster state and all indices in the cluster.
 *
 * @param clusterState The current cluster state. Must not be null.
 */
public ClusterStateHealth(final ClusterState clusterState) {
  this(clusterState, clusterState.metaData().getConcreteAllIndices());
}

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

/**
 * Sets the same routing for all indices
 */
private Map<String, Set<String>> resolveSearchRoutingAllIndices(MetaData metaData, String routing) {
  if (routing != null) {
    Set<String> r = Strings.splitStringByCommaToSet(routing);
    Map<String, Set<String>> routings = new HashMap<>();
    String[] concreteIndices = metaData.getConcreteAllIndices();
    for (String index : concreteIndices) {
      routings.put(index, r);
    }
    return routings;
  }
  return null;
}

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

/**
 * Identifies whether the first argument (an array containing index names) is a pattern that matches all indices
 *
 * @param indicesOrAliases the array containing index names
 * @param concreteIndices  array containing the concrete indices that the first argument refers to
 * @return true if the first argument is a pattern that maps to all available indices, false otherwise
 */
boolean isPatternMatchingAllIndices(MetaData metaData, String[] indicesOrAliases, String[] concreteIndices) {
  // if we end up matching on all indices, check, if its a wildcard parameter, or a "-something" structure
  if (concreteIndices.length == metaData.getConcreteAllIndices().length && indicesOrAliases.length > 0) {
    //we might have something like /-test1,+test1 that would identify all indices
    //or something like /-test1 with test1 index missing and IndicesOptions.lenient()
    if (indicesOrAliases[0].charAt(0) == '-') {
      return true;
    }
    //otherwise we check if there's any simple regex
    for (String indexOrAlias : indicesOrAliases) {
      if (Regex.isSimpleMatchPattern(indexOrAlias)) {
        return true;
      }
    }
  }
  return false;
}

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

/**
 * Identifies whether the first argument (an array containing index names) is a pattern that matches all indices
 *
 * @param indicesOrAliases the array containing index names
 * @param concreteIndices  array containing the concrete indices that the first argument refers to
 * @return true if the first argument is a pattern that maps to all available indices, false otherwise
 */
boolean isPatternMatchingAllIndices(MetaData metaData, String[] indicesOrAliases, String[] concreteIndices) {
  // if we end up matching on all indices, check, if its a wildcard parameter, or a "-something" structure
  if (concreteIndices.length == metaData.getConcreteAllIndices().length && indicesOrAliases.length > 0) {
    //we might have something like /-test1,+test1 that would identify all indices
    //or something like /-test1 with test1 index missing and IndicesOptions.lenient()
    if (indicesOrAliases[0].charAt(0) == '-') {
      return true;
    }
    //otherwise we check if there's any simple regex
    for (String indexOrAlias : indicesOrAliases) {
      if (Regex.isSimpleMatchPattern(indexOrAlias)) {
        return true;
      }
    }
  }
  return false;
}

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

/**
 * Identifies whether the first argument (an array containing index names) is a pattern that matches all indices
 *
 * @param indicesOrAliases the array containing index names
 * @param concreteIndices  array containing the concrete indices that the first argument refers to
 * @return true if the first argument is a pattern that maps to all available indices, false otherwise
 */
boolean isPatternMatchingAllIndices(MetaData metaData, String[] indicesOrAliases, String[] concreteIndices) {
  // if we end up matching on all indices, check, if its a wildcard parameter, or a "-something" structure
  if (concreteIndices.length == metaData.getConcreteAllIndices().length && indicesOrAliases.length > 0) {
    //we might have something like /-test1,+test1 that would identify all indices
    //or something like /-test1 with test1 index missing and IndicesOptions.lenient()
    if (indicesOrAliases[0].charAt(0) == '-') {
      return true;
    }
    //otherwise we check if there's any simple regex
    for (String indexOrAlias : indicesOrAliases) {
      if (Regex.isSimpleMatchPattern(indexOrAlias)) {
        return true;
      }
    }
  }
  return false;
}

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

/**
 * Sets the same routing for all indices
 */
public Map<String, Set<String>> resolveSearchRoutingAllIndices(MetaData metaData, String routing) {
  if (routing != null) {
    Set<String> r = Sets.newHashSet(Strings.splitStringByCommaToArray(routing));
    Map<String, Set<String>> routings = new HashMap<>();
    String[] concreteIndices = metaData.getConcreteAllIndices();
    for (String index : concreteIndices) {
      routings.put(index, r);
    }
    return routings;
  }
  return null;
}

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

/**
 * Sets the same routing for all indices
 */
public Map<String, Set<String>> resolveSearchRoutingAllIndices(MetaData metaData, String routing) {
  if (routing != null) {
    Set<String> r = Sets.newHashSet(Strings.splitStringByCommaToArray(routing));
    Map<String, Set<String>> routings = new HashMap<>();
    String[] concreteIndices = metaData.getConcreteAllIndices();
    for (String index : concreteIndices) {
      routings.put(index, r);
    }
    return routings;
  }
  return null;
}

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

private static List<String> resolveEmptyOrTrivialWildcard(IndicesOptions options, MetaData metaData) {
    if (options.expandWildcardsOpen() && options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllIndices());
    } else if (options.expandWildcardsOpen()) {
      return Arrays.asList(metaData.getConcreteAllOpenIndices());
    } else if (options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllClosedIndices());
    } else {
      return Collections.emptyList();
    }
  }
}

代码示例来源:origin: com.blossom-project/blossom-core-common

private void cleanOrphanIndex() {
 String[] indices = client.admin().cluster().prepareState().execute().actionGet().getState()
  .getMetaData().getConcreteAllIndices();
 List<String> orphans = Stream.of(indices)
  .filter(i -> i.startsWith(this.configuration.getAlias()))
  .filter(i -> 0 == client.admin().indices().getAliases(new GetAliasesRequest().indices(i))
   .actionGet().getAliases().size())
  .collect(Collectors.toList());
 for (String orphan : orphans) {
  client.admin().indices().delete(new DeleteIndexRequest(orphan)).actionGet();
 }
}

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

private static List<String> resolveEmptyOrTrivialWildcard(IndicesOptions options, MetaData metaData) {
    if (options.expandWildcardsOpen() && options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllIndices());
    } else if (options.expandWildcardsOpen()) {
      return Arrays.asList(metaData.getConcreteAllOpenIndices());
    } else if (options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllClosedIndices());
    } else {
      return Collections.emptyList();
    }
  }
}

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

private List<String> resolveEmptyOrTrivialWildcard(IndicesOptions options, MetaData metaData, boolean assertEmpty) {
    if (options.expandWildcardsOpen() && options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllIndices());
    } else if (options.expandWildcardsOpen()) {
      return Arrays.asList(metaData.getConcreteAllOpenIndices());
    } else if (options.expandWildcardsClosed()) {
      return Arrays.asList(metaData.getConcreteAllClosedIndices());
    } else {
      assert assertEmpty : "Shouldn't end up here";
      return Collections.emptyList();
    }
  }
}

代码示例来源:origin: org.sonarsource.sonarqube/sonar-server

public void clearIndexes() {
 Loggers.get(getClass()).info("Truncate Elasticsearch indices");
 try {
  esClient.prepareClearCache().get();
  for (String index : esClient.prepareState().get().getState().getMetaData().getConcreteAllIndices()) {
   clearIndex(new IndexType(index, index));
  }
 } catch (Exception e) {
  throw new IllegalStateException("Unable to clear indexes", e);
 }
}

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

metaData.getTemplates(),
metaData.getCustoms(),
metaData.getConcreteAllIndices(),
metaData.getConcreteAllOpenIndices(),
metaData.getConcreteAllClosedIndices(),

相关文章

微信公众号

最新文章

更多