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

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

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

MetaData.transientSettings介绍

暂无

代码示例

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

if (context == XContentContext.API && !metaData.transientSettings().isEmpty()) {
  builder.startObject("transient_settings");
  metaData.transientSettings().toXContent(builder, new MapParams(Collections.singletonMap("flat_settings", "true")));
  builder.endObject();

代码示例来源：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

partitionKnownAndValidSettings(currentState.metaData().transientSettings(), "transient", logger);
final Settings knownAndValidTransientSettings = partitionedTransientSettings.v1();
final Settings unknownOrInvalidTransientSettings = partitionedTransientSettings.v2();

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

@Override
  public RestResponse buildResponse(ClusterStateResponse response, XContentBuilder builder) throws Exception {
    builder.startObject();
    builder.startObject("persistent");
    response.getState().metaData().persistentSettings().toXContent(builder, request);
    builder.endObject();
    builder.startObject("transient");
    response.getState().metaData().transientSettings().toXContent(builder, request);
    builder.endObject();
    builder.endObject();
    return new BytesRestResponse(RestStatus.OK, builder);
  }
});

代码示例来源：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: javanna/elasticshell

@Override
  protected XContentBuilder toXContent(ClusterStateRequest request, ClusterStateResponse response, XContentBuilder builder) throws IOException {
    builder.startObject();

    builder.startObject("persistent");
    for (Map.Entry<String, String> entry : response.getState().metaData().persistentSettings().getAsMap().entrySet()) {
      builder.field(entry.getKey(), entry.getValue());
    }
    builder.endObject();

    builder.startObject("transient");
    for (Map.Entry<String, String> entry : response.getState().metaData().transientSettings().getAsMap().entrySet()) {
      builder.field(entry.getKey(), entry.getValue());
    }
    builder.endObject();

    builder.endObject();

    return builder;
  }
}

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

if (context == XContentContext.API && !metaData.transientSettings().getAsMap().isEmpty()) {
  builder.startObject("transient_settings");
  for (Map.Entry<String, String> entry : metaData.transientSettings().getAsMap().entrySet()) {
    builder.field(entry.getKey(), entry.getValue());

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

if (context == XContentContext.API && !metaData.transientSettings().isEmpty()) {
  builder.startObject("transient_settings");
  for (Map.Entry<String, String> entry : metaData.transientSettings().getAsMap().entrySet()) {
    builder.field(entry.getKey(), entry.getValue());

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

if (context == XContentContext.API && !metaData.transientSettings().isEmpty()) {
  builder.startObject("transient_settings");
  metaData.transientSettings().toXContent(builder, new MapParams(Collections.singletonMap("flat_settings", "true")));
  builder.endObject();

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

@After
@Override
public void tearDown() throws Exception {
  logger.info("[{}#{}]: cleaning up after test", getTestClass().getSimpleName(), getTestName());
  try {
    DeleteIndexRequestBuilder builder = ElassandraDaemon.instance.node().client().admin().indices().prepareDelete("*");
    assertAcked(builder.get());
    MetaData metaData = client().admin().cluster().prepareState().get().getState().getMetaData();
    assertThat("test leaves persistent cluster metadata behind: " + metaData.persistentSettings().getAsGroups(),
        metaData.persistentSettings().size(), equalTo(0));
    assertThat("test leaves transient cluster metadata behind: " + metaData.transientSettings().getAsGroups(),
        metaData.transientSettings().size(), equalTo(0));
    List<String> userKeyspaces = Schema.instance.getUserKeyspaces();
    userKeyspaces.remove(this.clusterService().getElasticAdminKeyspaceName());
    assertThat("test leaves a user keyspace behind:" + userKeyspaces, userKeyspaces.size(), equalTo(0));
  } catch(Exception e) {
    logger.warn("[{}#{}]: failed to clean indices and metadata: error="+e, getTestClass().getSimpleName(), getTestName());
  } finally {
    testMutex.release();
    logger.info("[{}#{}]: released semaphore={}", getTestClass().getSimpleName(), getTestName(), testMutex.toString());
  }
  super.tearDown();
}

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

metaData.clusterUUID(),
metaData.version(),
metaData.transientSettings(),
newPersistentSettings.build(),
metaData.getIndices(),

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

@Override
public ClusterState execute(final ClusterState currentState) {
  Settings.Builder transientSettings = Settings.settingsBuilder();
  transientSettings.put(currentState.metaData().transientSettings());
  for (Map.Entry<String, String> entry : request.transientSettings().getAsMap().entrySet()) {
    if (dynamicSettings.isDynamicOrLoggingSetting(entry.getKey())) {

代码示例来源：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: com.strapdata.elasticsearch.test/framework

final Set<String> persistent = metaData.persistentSettings().keySet();
assertThat("test leaves persistent cluster metadata behind: " + persistent, persistent.size(), equalTo(0));
final Set<String> transientSettings =  new HashSet<>(metaData.transientSettings().keySet());
if (isInternalCluster() && internalCluster().getAutoManageMinMasterNode()) {

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

/** As of 2.0 we require units for time and byte-sized settings. This methods adds default units to any
 * persistent settings and template settings that don't specify a unit.
 **/
public static MetaData addDefaultUnitsIfNeeded(ESLogger logger, MetaData metaData) {
  Settings newPersistentSettings = addDefaultUnitsIfNeeded(
      CLUSTER_TIME_SETTINGS, CLUSTER_BYTES_SIZE_SETTINGS, logger, metaData.persistentSettings());
  ImmutableOpenMap<String, IndexTemplateMetaData> templates = updateTemplates(logger, metaData.getTemplates());
  if (newPersistentSettings != null || templates != null) {
    return new MetaData(
        metaData.clusterUUID(),
        metaData.version(),
        metaData.transientSettings(),
        MoreObjects.firstNonNull(newPersistentSettings, metaData.persistentSettings()),
        metaData.getIndices(),
        MoreObjects.firstNonNull(templates, metaData.getTemplates()),
        metaData.getCustoms(),
        metaData.concreteAllIndices(),
        metaData.concreteAllOpenIndices(),
        metaData.concreteAllClosedIndices(),
        metaData.getAliasAndIndexLookup());
  } else {
    // No changes:
    return metaData;
  }
}

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

partitionKnownAndValidSettings(currentState.metaData().transientSettings(), "transient", logger);
final Settings knownAndValidTransientSettings = partitionedTransientSettings.v1();
final Settings unknownOrInvalidTransientSettings = partitionedTransientSettings.v2();

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

partitionKnownAndValidSettings(currentState.metaData().transientSettings(), "transient", logger);
final Settings knownAndValidTransientSettings = partitionedTransientSettings.v1();
final Settings unknownOrInvalidTransientSettings = partitionedTransientSettings.v2();

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

synchronized ClusterState updateSettings(final ClusterState currentState, Settings transientToApply, Settings persistentToApply) {
  boolean changed = false;
  Settings.Builder transientSettings = Settings.builder();
  transientSettings.put(currentState.metaData().transientSettings());
  changed |= clusterSettings.updateDynamicSettings(transientToApply, transientSettings, transientUpdates, "transient");

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

Metadata

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    MetaData类方法

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