org.elasticsearch.common.settings.Settings.getGroups()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(11.1k)|赞(0)|评价(0)|浏览(166)

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

Settings.getGroups介绍

[英]Returns group settings for the given setting prefix.
[中]返回给定设置前缀的组设置。

代码示例

代码示例来源：origin: floragunncom/search-guard

final List<Destroyable> destroyableComponents0 = new LinkedList<>();
final Map<String, Settings> authzDyn = settings.getGroups("searchguard.dynamic.authz");
final Map<String, Settings> dyn = settings.getGroups("searchguard.dynamic.authc");

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

/**
 * Returns group settings for the given setting prefix.
 */
public Map<String, Settings> getGroups(String settingPrefix) throws SettingsException {
  return getGroups(settingPrefix, false);
}

代码示例来源：origin: floragunncom/search-guard

final Map<String, Settings> permittedAliasesIndices = sgRoleSettings.getGroups(".indices");

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

/**
 * Returns all profile settings for the given settings object
 */
public static Set<ProfileSettings> getProfileSettings(Settings settings) {
  HashSet<ProfileSettings> profiles = new HashSet<>();
  boolean isDefaultSet = false;
  for (String profile : settings.getGroups("transport.profiles.", true).keySet()) {
    profiles.add(new ProfileSettings(settings, profile));
    if (TransportSettings.DEFAULT_PROFILE.equals(profile)) {
      isDefaultSet = true;
    }
  }
  if (isDefaultSet == false) {
    profiles.add(new ProfileSettings(settings, TransportSettings.DEFAULT_PROFILE));
  }
  return Collections.unmodifiableSet(profiles);
}

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

public Map<String, AnalyzerProvider<?>> buildNormalizerFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> noralizersSettings = indexSettings.getSettings().getGroups("index.analysis.normalizer");
  // TODO: Have pre-built normalizers
  return buildMapping(Component.NORMALIZER, indexSettings, noralizersSettings, normalizers, Collections.emptyMap());
}

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

public Map<String, CharFilterFactory> buildCharFilterFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> charFiltersSettings = indexSettings.getSettings().getGroups(INDEX_ANALYSIS_CHAR_FILTER);
  return buildMapping(Component.CHAR_FILTER, indexSettings, charFiltersSettings, charFilters,
    prebuiltAnalysis.preConfiguredCharFilterFactories);
}

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

public Map<String, TokenizerFactory> buildTokenizerFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> tokenizersSettings = indexSettings.getSettings().getGroups(INDEX_ANALYSIS_TOKENIZER);
  return buildMapping(Component.TOKENIZER, indexSettings, tokenizersSettings, tokenizers, prebuiltAnalysis.preConfiguredTokenizers);
}

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

public Map<String, AnalyzerProvider<?>> buildAnalyzerFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> analyzersSettings = indexSettings.getSettings().getGroups("index.analysis.analyzer");
  return buildMapping(Component.ANALYZER, indexSettings, analyzersSettings, analyzers, prebuiltAnalysis.analyzerProviderFactories);
}

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

private static void addSocketPermissionForTribeNodes(final Permissions policy, final Settings settings) {
  for (final Settings tribeNodeSettings : settings.getGroups("tribe", true).values()) {
    // tribe nodes have HTTP disabled by default, so we check if HTTP is enabled before granting
    if (NetworkModule.HTTP_ENABLED.exists(tribeNodeSettings) && NetworkModule.HTTP_ENABLED.get(tribeNodeSettings)) {
      addSocketPermissionForHttp(policy, tribeNodeSettings);
    }
    addSocketPermissionForTransport(policy, tribeNodeSettings);
  }
}

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

super(indexSettings);
Map<String, Supplier<Similarity>> providers = new HashMap<>(similarities.size());
Map<String, Settings> similaritySettings = this.indexSettings.getSettings().getGroups(IndexModule.SIMILARITY_SETTINGS_PREFIX);

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

public Map<String, TokenFilterFactory> buildTokenFilterFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> tokenFiltersSettings = indexSettings.getSettings().getGroups(INDEX_ANALYSIS_FILTER);
  Map<String, AnalysisModule.AnalysisProvider<TokenFilterFactory>> tokenFilters = new HashMap<>(this.tokenFilters);
  /*
   * synonym and synonym_graph are different than everything else since they need access to the tokenizer factories for the index.
   * instead of building the infrastructure for plugins we rather make it a real exception to not pollute the general interface and
   * hide internal data-structures as much as possible.
   */
  tokenFilters.put("synonym", requiresAnalysisSettings((is, env, name, settings) ->
    new SynonymTokenFilterFactory(is, env, this, name, settings)));
  tokenFilters.put("synonym_graph", requiresAnalysisSettings((is, env, name, settings) ->
    new SynonymGraphTokenFilterFactory(is, env, this, name, settings)));
  return buildMapping(Component.FILTER, indexSettings, tokenFiltersSettings,
    Collections.unmodifiableMap(tokenFilters), prebuiltAnalysis.preConfiguredTokenFilters);
}

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

/**
 * Returns a registered {@link TokenizerFactory} provider by {@link IndexSettings}
 *  or a registered {@link TokenizerFactory} provider by predefined name
 *  or <code>null</code> if the tokenizer was not registered
 * @param tokenizer global or defined tokenizer name
 * @param indexSettings an index settings
 * @return {@link TokenizerFactory} provider or <code>null</code>
 */
public AnalysisProvider<TokenizerFactory> getTokenizerProvider(String tokenizer, IndexSettings indexSettings) {
  final Map<String, Settings> tokenizerSettings = indexSettings.getSettings().getGroups("index.analysis.tokenizer");
  if (tokenizerSettings.containsKey(tokenizer)) {
    Settings currentSettings = tokenizerSettings.get(tokenizer);
    return getAnalysisProvider(Component.TOKENIZER, tokenizers, tokenizer, currentSettings.get("type"));
  } else {
    return getTokenizerProvider(tokenizer);
  }
}

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

/**
 * Returns a registered {@link CharFilterFactory} provider by {@link IndexSettings}
 *  or a registered {@link CharFilterFactory} provider by predefined name
 *  or <code>null</code> if the charFilter was not registered
 * @param charFilter global or defined charFilter name
 * @param indexSettings an index settings
 * @return {@link CharFilterFactory} provider or <code>null</code>
 */
public AnalysisProvider<CharFilterFactory> getCharFilterProvider(String charFilter, IndexSettings indexSettings) {
  final Map<String, Settings> tokenFilterSettings = indexSettings.getSettings().getGroups("index.analysis.char_filter");
  if (tokenFilterSettings.containsKey(charFilter)) {
    Settings currentSettings = tokenFilterSettings.get(charFilter);
    return getAnalysisProvider(Component.CHAR_FILTER, charFilters, charFilter, currentSettings.get("type"));
  } else {
    return getCharFilterProvider(charFilter);
  }
}

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

final Map<String, Settings> tokenFilterSettings = indexSettings.getSettings().getGroups("index.analysis.filter");
if (tokenFilterSettings.containsKey(tokenFilter)) {
  Settings currentSettings = tokenFilterSettings.get(tokenFilter);

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

/**
 * Returns group settings for the given setting prefix.
 */
public Map<String, Settings> getGroups(String settingPrefix) throws SettingsException {
  return getGroups(settingPrefix, false);
}

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

/**
 * Returns group settings for the given setting prefix.
 */
public Map<String, Settings> getGroups(String settingPrefix) throws SettingsException {
  return getGroups(settingPrefix, false);
}

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

public Map<String, AnalyzerProvider<?>> buildNormalizerFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> noralizersSettings = indexSettings.getSettings().getGroups("index.analysis.normalizer");
  // TODO: Have pre-built normalizers
  return buildMapping(Component.NORMALIZER, indexSettings, noralizersSettings, normalizers, Collections.emptyMap());
}

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

public Map<String, TokenFilterFactory> buildTokenFilterFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> tokenFiltersSettings = indexSettings.getSettings().getGroups(INDEX_ANALYSIS_FILTER);
  Map<String, AnalysisModule.AnalysisProvider<TokenFilterFactory>> tokenFilters = new HashMap<>(this.tokenFilters);
  /*
   * synonym and synonym_graph are different than everything else since they need access to the tokenizer factories for the index.
   * instead of building the infrastructure for plugins we rather make it a real exception to not pollute the general interface and
   * hide internal data-structures as much as possible.
   */
  tokenFilters.put("synonym", requiresAnalysisSettings((is, env, name, settings) -> new SynonymTokenFilterFactory(is, env, this, name, settings)));
  tokenFilters.put("synonym_graph", requiresAnalysisSettings((is, env, name, settings) -> new SynonymGraphTokenFilterFactory(is, env, this, name, settings)));
  return buildMapping(Component.FILTER, indexSettings, tokenFiltersSettings, Collections.unmodifiableMap(tokenFilters), prebuiltAnalysis.preConfiguredTokenFilters);
}

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

public Map<String, TokenFilterFactory> buildTokenFilterFactories(IndexSettings indexSettings) throws IOException {
  final Map<String, Settings> tokenFiltersSettings = indexSettings.getSettings().getGroups(INDEX_ANALYSIS_FILTER);
  Map<String, AnalysisModule.AnalysisProvider<TokenFilterFactory>> tokenFilters = new HashMap<>(this.tokenFilters);
  /*
   * synonym and synonym_graph are different than everything else since they need access to the tokenizer factories for the index.
   * instead of building the infrastructure for plugins we rather make it a real exception to not pollute the general interface and
   * hide internal data-structures as much as possible.
   */
  tokenFilters.put("synonym", requiresAnalysisSettings((is, env, name, settings) -> new SynonymTokenFilterFactory(is, env, this, name, settings)));
  tokenFilters.put("synonym_graph", requiresAnalysisSettings((is, env, name, settings) -> new SynonymGraphTokenFilterFactory(is, env, this, name, settings)));
  return buildMapping(Component.FILTER, indexSettings, tokenFiltersSettings, Collections.unmodifiableMap(tokenFilters), prebuiltAnalysis.tokenFilterFactories);
}

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

private static void addSocketPermissionForTribeNodes(final Permissions policy, final Settings settings) {
  for (final Settings tribeNodeSettings : settings.getGroups("tribe", true).values()) {
    // tribe nodes have HTTP disabled by default, so we check if HTTP is enabled before granting
    if (NetworkModule.HTTP_ENABLED.exists(tribeNodeSettings) && NetworkModule.HTTP_ENABLED.get(tribeNodeSettings)) {
      addSocketPermissionForHttp(policy, tribeNodeSettings);
    }
    addSocketPermissionForTransport(policy, tribeNodeSettings);
  }
}

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

settings

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Settings类方法

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