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

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

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

MetaData.settings介绍

[英]Returns the merged transient and persistent settings.
[中]返回合并的瞬时和持久设置。

代码示例

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

Settings theseSettings = state.metaData().settings();
int nodeCount = state.getNodes().getDataNodes().size();

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

private void applyChanges(UpdateTask task, ClusterState previousClusterState, ClusterState newClusterState) {
  ClusterChangedEvent clusterChangedEvent = new ClusterChangedEvent(task.source, newClusterState, previousClusterState);
  // new cluster state, notify all listeners
  final DiscoveryNodes.Delta nodesDelta = clusterChangedEvent.nodesDelta();
  if (nodesDelta.hasChanges() && logger.isInfoEnabled()) {
    String summary = nodesDelta.shortSummary();
    if (summary.length() > 0) {
      logger.info("{}, reason: {}", summary, task.source);
    }
  }
  nodeConnectionsService.connectToNodes(newClusterState.nodes());
  logger.debug("applying cluster state version {}", newClusterState.version());
  try {
    // nothing to do until we actually recover from the gateway or any other block indicates we need to disable persistency
    if (clusterChangedEvent.state().blocks().disableStatePersistence() == false && clusterChangedEvent.metaDataChanged()) {
      final Settings incomingSettings = clusterChangedEvent.state().metaData().settings();
      clusterSettings.applySettings(incomingSettings);
    }
  } catch (Exception ex) {
    logger.warn("failed to apply cluster settings", ex);
  }
  logger.debug("apply cluster state with version {}", newClusterState.version());
  callClusterStateAppliers(clusterChangedEvent);
  nodeConnectionsService.disconnectFromNodesExcept(newClusterState.nodes());
  logger.debug("set locally applied cluster state to version {}", newClusterState.version());
  state.set(newClusterState);
  callClusterStateListeners(clusterChangedEvent);
  task.listener.onSuccess(task.source);
}

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

static ClusterGetSettingsResponse response(
    final ClusterState state,
    final boolean renderDefaults,
    final SettingsFilter settingsFilter,
    final ClusterSettings clusterSettings,
    final Settings settings) {
  return new ClusterGetSettingsResponse(
      settingsFilter.filter(state.metaData().persistentSettings()),
      settingsFilter.filter(state.metaData().transientSettings()),
      renderDefaults ? settingsFilter.filter(clusterSettings.diff(state.metaData().settings(), settings)) : Settings.EMPTY);
}

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

if (MetaData.SETTING_READ_ONLY_SETTING.get(recoveredState.metaData().settings())
  || MetaData.SETTING_READ_ONLY_SETTING.get(currentState.metaData().settings())) {
  blocks.addGlobalBlock(MetaData.CLUSTER_READ_ONLY_BLOCK);
if (MetaData.SETTING_READ_ONLY_ALLOW_DELETE_SETTING.get(recoveredState.metaData().settings())
  || MetaData.SETTING_READ_ONLY_ALLOW_DELETE_SETTING.get(currentState.metaData().settings())) {
  blocks.addGlobalBlock(MetaData.CLUSTER_READ_ONLY_ALLOW_DELETE_BLOCK);

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

final Settings settings = clusterState.metaData().settings();
clusterSettings.validateUpdate(settings);

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

public ImmutableIndexInfo(String name, IndexService indexService, MappingMetaData mappingMetaData, MetaData metadata, boolean versionLessEngine) throws IOException {
  this.name = name;
  this.versionLessEngine = versionLessEngine;
  this.indexService = indexService;
  this.mapping = mappingMetaData.sourceAsMap();
  this.type = mappingMetaData.type();
  
  Map<String,Object> mappingMap = (Map<String,Object>)mappingMetaData.getSourceAsMap();
  Map<String,Object> metaMap = (mappingMap == null) ? null : (Map<String,Object>)mappingMap.get("_meta");
  
  this.refresh = getMetaSettings(metadata.settings(), indexService.getIndexSettings(), metaMap, IndexMetaData.INDEX_SYNCHRONOUS_REFRESH_SETTING);
  this.snapshot = getMetaSettings(metadata.settings(), indexService.getIndexSettings(), metaMap, IndexMetaData.INDEX_SNAPSHOT_WITH_SSTABLE_SETTING);
  this.includeNodeId = getMetaSettings(metadata.settings(), indexService.getIndexSettings(), metaMap, IndexMetaData.INDEX_INCLUDE_NODE_ID_SETTING);
  
  this.index_on_compaction = getMetaSettings(metadata.settings(), indexService.getIndexSettings(), metaMap, IndexMetaData.INDEX_INDEX_ON_COMPACTION_SETTING);
  this.index_static_columns = getMetaSettings(metadata.settings(), indexService.getIndexSettings(), metaMap, IndexMetaData.INDEX_INDEX_STATIC_COLUMNS_SETTING);
  this.index_static_only = getMetaSettings(metadata.settings(), indexService.getIndexSettings(), metaMap, IndexMetaData.INDEX_INDEX_STATIC_ONLY_SETTING);
}

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

private XContentBuilder renderResponse(ClusterState state, boolean renderDefaults, XContentBuilder builder, ToXContent.Params params)
      throws IOException {
    builder.startObject();

    builder.startObject("persistent");
    state.metaData().persistentSettings().toXContent(builder, params);
    builder.endObject();

    builder.startObject("transient");
    state.metaData().transientSettings().toXContent(builder, params);
    builder.endObject();

    if (renderDefaults) {
      builder.startObject("defaults");
      settingsFilter.filter(clusterSettings.diff(state.metaData().settings(), this.settings)).toXContent(builder, params);
      builder.endObject();
    }

    builder.endObject();
    return builder;
  }
}

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

public Class<AbstractSearchStrategy> searchStrategyClass(IndexMetaData indexMetaData, ClusterState state) {
  return AbstractSearchStrategy.getSearchStrategyClass( 
      indexMetaData.getSettings().get(IndexMetaData.SETTING_SEARCH_STRATEGY_CLASS, 
      state.metaData().settings().get(ClusterService.SETTING_CLUSTER_SEARCH_STRATEGY_CLASS,PrimaryFirstSearchStrategy.class.getName()))
      );
}

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

if (lastSettingsApplied != null && event.state().metaData().settings().equals(lastSettingsApplied)) {
    listener.onRefreshSettings(event.state().metaData().settings());
  } catch (Exception e) {
    logger.warn("failed to refresh settings for [{}]", e, listener);
  for (Map.Entry<String, String> entry : event.state().metaData().settings().getAsMap().entrySet()) {
    if (entry.getKey().startsWith("logger.")) {
      String component = entry.getKey().substring("logger.".length());
lastSettingsApplied = event.state().metaData().settings();
globalSettings = lastSettingsApplied;

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

Settings theseSettings = state.metaData().settings();
int nodeCount = state.getNodes().getDataNodes().size();

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

private void applyChanges(UpdateTask task, ClusterState previousClusterState, ClusterState newClusterState) {
  ClusterChangedEvent clusterChangedEvent = new ClusterChangedEvent(task.source, newClusterState, previousClusterState);
  // new cluster state, notify all listeners
  final DiscoveryNodes.Delta nodesDelta = clusterChangedEvent.nodesDelta();
  if (nodesDelta.hasChanges() && logger.isInfoEnabled()) {
    String summary = nodesDelta.shortSummary();
    if (summary.length() > 0) {
      logger.info("{}, reason: {}", summary, task.source);
    }
  }
  nodeConnectionsService.connectToNodes(newClusterState.nodes());
  logger.debug("applying cluster state version {}", newClusterState.version());
  try {
    // nothing to do until we actually recover from the gateway or any other block indicates we need to disable persistency
    if (clusterChangedEvent.state().blocks().disableStatePersistence() == false && clusterChangedEvent.metaDataChanged()) {
      final Settings incomingSettings = clusterChangedEvent.state().metaData().settings();
      clusterSettings.applySettings(incomingSettings);
    }
  } catch (Exception ex) {
    logger.warn("failed to apply cluster settings", ex);
  }
  logger.debug("apply cluster state with version {}", newClusterState.version());
  callClusterStateAppliers(clusterChangedEvent);
  nodeConnectionsService.disconnectFromNodesExcept(newClusterState.nodes());
  logger.debug("set locally applied cluster state to version {}", newClusterState.version());
  state.set(newClusterState);
  callClusterStateListeners(clusterChangedEvent);
  task.listener.onSuccess(task.source);
}

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

@Override
protected PrimaryResult shardOperationOnPrimary(ShardRebuildRequest shardRequest, IndexShard primary) throws IOException {
  IndexService indexService = indicesService.indexServiceSafe(shardRequest.shardId().getIndex());
  List<String> tables = new ArrayList<String>();
  List<String> indexes = new ArrayList<String>();
  MetaData metaData = clusterService.state().metaData();
  IndexMetaData indexMetaData = metaData.index(shardRequest.shardId().getIndex());
  String secondaryIndexClass = indexMetaData.getSettings().get(IndexMetaData.SETTING_SECONDARY_INDEX_CLASS, 
      metaData.settings().get(org.elasticsearch.cluster.service.ClusterService.SETTING_CLUSTER_SECONDARY_INDEX_CLASS, org.elasticsearch.cluster.service.ClusterService.defaultSecondaryIndexClass.getName()));
  for(ObjectCursor<MappingMetaData> it : indexMetaData.getMappings().values()) {
    MappingMetaData mapping = it.value;
    String table = org.elasticsearch.cluster.service.ClusterService.typeToCfName(mapping.type());
    tables.add(table);
    CFMetaData cfMetadata = org.elasticsearch.cluster.service.ClusterService.getCFMetaData(indexService.keyspace(), table);
    for(IndexMetadata index : cfMetadata.getIndexes()) {
      if (index.isCustom() && secondaryIndexClass.equals(index.options.get("class_name"))) {
        indexes.add(index.name);
        break;
      }
    }
  }
  
  // Cassandra flush and rebuild_index for all mapped tables.
  StorageService.instance.forceKeyspaceFlush(indexService.keyspace(), tables.toArray(new String[tables.size()]));
  for(int i=0; i < tables.size(); i++)
    StorageService.instance.rebuildSecondaryIndex(shardRequest.getRequest().numThreads(), indexService.keyspace(), tables.get(i), indexes.get(i));
  
  logger.trace("index=[{}] rebuild request executed on keyspace=[{}] tables={} with numThreads={}", shardRequest.shardId().getIndex(), indexService.mapperService().keyspace(), tables, shardRequest.getRequest().numThreads());
  return new PrimaryResult(shardRequest, new ReplicationResponse());
}

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

@Override
public void applyClusterState(ClusterChangedEvent event) {
  
  // create cassandra 2i on coordinator node only.
  for(Pair<String,MappingMetaData> mapping : updatedMapping) {
    String index = mapping.left;
    IndexMetaData indexMetaData = event.state().metaData().index(index);
    if (indexMetaData != null) {
      try {
        String clazz = indexMetaData.getSettings().get(IndexMetaData.SETTING_SECONDARY_INDEX_CLASS, event.state().metaData().settings().get(ClusterService.SETTING_CLUSTER_SECONDARY_INDEX_CLASS, ClusterService.defaultSecondaryIndexClass.getName()));
        logger.debug("Creating secondary indices for table={}.{} with class={}", indexMetaData.keyspace(), mapping.right.type(),clazz);
        this.clusterService.createSecondaryIndex(indexMetaData.keyspace(), mapping.right, clazz);
      } catch (IOException e) {
        logger.error("Failed to create secondary indices for table={}.{}", e, indexMetaData.keyspace(), mapping.right.type());
      }
    } else {
      logger.warn("Index [{}] not found in new state metadata version={}", index, event.state().metaData().version());
    }
  }
  if (updatedMapping.size() > 0)
    updatedMapping.clear();
}

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

static ClusterGetSettingsResponse response(
    final ClusterState state,
    final boolean renderDefaults,
    final SettingsFilter settingsFilter,
    final ClusterSettings clusterSettings,
    final Settings settings) {
  return new ClusterGetSettingsResponse(
      settingsFilter.filter(state.metaData().persistentSettings()),
      settingsFilter.filter(state.metaData().transientSettings()),
      renderDefaults ? settingsFilter.filter(clusterSettings.diff(state.metaData().settings(), settings)) : Settings.EMPTY);
}

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

static ClusterGetSettingsResponse response(
    final ClusterState state,
    final boolean renderDefaults,
    final SettingsFilter settingsFilter,
    final ClusterSettings clusterSettings,
    final Settings settings) {
  return new ClusterGetSettingsResponse(
      settingsFilter.filter(state.metaData().persistentSettings()),
      settingsFilter.filter(state.metaData().transientSettings()),
      renderDefaults ? settingsFilter.filter(clusterSettings.diff(state.metaData().settings(), settings)) : Settings.EMPTY);
}

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

private void applyChanges(UpdateTask task, ClusterState previousClusterState, ClusterState newClusterState) {
  ClusterChangedEvent clusterChangedEvent = new ClusterChangedEvent(task.source, newClusterState, previousClusterState);
  // new cluster state, notify all listeners
  final DiscoveryNodes.Delta nodesDelta = clusterChangedEvent.nodesDelta();
  if (nodesDelta.hasChanges() && logger.isInfoEnabled()) {
    String summary = nodesDelta.shortSummary();
    if (summary.length() > 0) {
      logger.info("{}, reason: {}", summary, task.source);
    }
  }
  nodeConnectionsService.connectToNodes(newClusterState.nodes());
  logger.debug("applying cluster state version {}", newClusterState.version());
  try {
    // nothing to do until we actually recover from the gateway or any other block indicates we need to disable persistency
    if (clusterChangedEvent.state().blocks().disableStatePersistence() == false && clusterChangedEvent.metaDataChanged()) {
      final Settings incomingSettings = clusterChangedEvent.state().metaData().settings();
      clusterSettings.applySettings(incomingSettings);
    }
  } catch (Exception ex) {
    logger.warn("failed to apply cluster settings", ex);
  }
  logger.debug("apply cluster state with version {}", newClusterState.version());
  callClusterStateAppliers(clusterChangedEvent);
  nodeConnectionsService.disconnectFromNodesExcept(newClusterState.nodes());
  logger.debug("set locally applied cluster state to version {}", newClusterState.version());
  state.set(newClusterState);
  callClusterStateListeners(clusterChangedEvent);
  task.listener.onSuccess(task.source);
}

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

@Override
public ClusterState execute(ClusterState currentState) {
  // read metadata from the clusterService thread to avoid freeze in gossip.
  MetaData schemaMetaData = clusterService.checkForNewMetaData(version);
  
  ClusterState.Builder newStateBuilder = ClusterState.builder(currentState).nodes(nodes());
  // update blocks
  ClusterBlocks.Builder blocks = ClusterBlocks.builder().blocks(currentState.blocks());
  if (schemaMetaData.settings().getAsBoolean("cluster.blocks.read_only", false))
    blocks.addGlobalBlock(MetaData.CLUSTER_READ_ONLY_BLOCK);
  
  if (schemaMetaData != null) {
    newStateBuilder.metaData(schemaMetaData);
    
    // update indices block.
    for (IndexMetaData indexMetaData : schemaMetaData)
      blocks.updateBlocks(indexMetaData);
  }
  return clusterService.updateNumberOfShardsAndReplicas( newStateBuilder.blocks(blocks).build() );
}

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

Settings settings = build.metaData().settings();

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

if (recoveredState.metaData().settings().getAsBoolean(MetaData.SETTING_READ_ONLY, false) || currentState.metaData().settings().getAsBoolean(MetaData.SETTING_READ_ONLY, false)) {
  blocks.addGlobalBlock(MetaData.CLUSTER_READ_ONLY_BLOCK);

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

@Override
public ClusterState execute(ClusterState currentState) {
  assert currentState.metaData().indices().isEmpty();
  
  // remove the block, since we recovered from gateway
  ClusterBlocks.Builder blocks = ClusterBlocks.builder()
      .blocks(currentState.blocks())
      .blocks(recoveredState.blocks())
      .removeGlobalBlock(STATE_NOT_RECOVERED_BLOCK);
  MetaData.Builder metaDataBuilder = MetaData.builder(recoveredState.metaData());
  // automatically generate a UID for the metadata if we need to
  metaDataBuilder.generateClusterUuidIfNeeded();
  if (recoveredState.metaData().settings().getAsBoolean("cluster.blocks.read_only", false)) {
    blocks.addGlobalBlock(MetaData.CLUSTER_READ_ONLY_BLOCK);
  }
  for (IndexMetaData indexMetaData : recoveredState.metaData()) {
    metaDataBuilder.put(indexMetaData, false);
    blocks.addBlocks(indexMetaData);
  }
  // update the state to reflect the new metadata and routing
  ClusterState updatedState = ClusterState.builder(currentState)
      .blocks(blocks)
      .metaData(metaDataBuilder)
      .build();
  RoutingTable newRoutingTable = RoutingTable.build(CassandraGatewayService.this.clusterService, updatedState);
  return ClusterState.builder(updatedState).incrementVersion().routingTable(newRoutingTable).build();
}

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

Metadata

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    MetaData类方法

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