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

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

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

MetaData.customs介绍

暂无

代码示例

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

if (metaData.customs().isEmpty() == false) {
  sb.append("metadata customs:\n");
  for (final ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
    final String type = cursor.key;
    final MetaData.Custom custom = cursor.value;

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

/**
 * Returns a set of custom meta data types when any custom metadata for the cluster has changed
 * between the previous cluster state and the new cluster state. custom meta data types are
 * returned iff they have been added, updated or removed between the previous and the current state
 */
public Set<String> changedCustomMetaDataSet() {
  Set<String> result = new HashSet<>();
  ImmutableOpenMap<String, MetaData.Custom> currentCustoms = state.metaData().customs();
  ImmutableOpenMap<String, MetaData.Custom> previousCustoms = previousState.metaData().customs();
  if (currentCustoms.equals(previousCustoms) == false) {
    for (ObjectObjectCursor<String, MetaData.Custom> currentCustomMetaData : currentCustoms) {
      // new custom md added or existing custom md changed
      if (previousCustoms.containsKey(currentCustomMetaData.key) == false
          || currentCustomMetaData.value.equals(previousCustoms.get(currentCustomMetaData.key)) == false) {
        result.add(currentCustomMetaData.key);
      }
    }
    // existing custom md deleted
    for (ObjectObjectCursor<String, MetaData.Custom> previousCustomMetaData : previousCustoms) {
      if (currentCustoms.containsKey(previousCustomMetaData.key) == false) {
        result.add(previousCustomMetaData.key);
      }
    }
  }
  return result;
}

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

/**
 * For interoperability with transport clients older than 6.3, we need to strip customs
 * from the cluster state that the client might not be able to deserialize
 *
 * @param clusterState the cluster state to filter the customs from
 * @return the adapted cluster state
 */
public static ClusterState filterCustomsForPre63Clients(ClusterState clusterState) {
  final ClusterState.Builder builder = ClusterState.builder(clusterState);
  clusterState.customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_CLUSTER_CUSTOMS_WHITE_LIST.contains(name) == false) {
      builder.removeCustom(name);
    }
  });
  final MetaData.Builder metaBuilder = MetaData.builder(clusterState.metaData());
  clusterState.metaData().customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_METADATA_CUSTOMS_WHITE_LIST.contains(name) == false) {
      metaBuilder.removeCustom(name);
    }
  });
  return builder.metaData(metaBuilder).build();
}

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

for (ObjectObjectCursor<String, Custom> cursor : metaData.customs()) {
  if (cursor.value.context().contains(context)) {
    builder.startObject(cursor.key);

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

for (ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
  builder.startObject(cursor.key);
  cursor.value.toXContent(builder, params);

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

if (metaData.customs() != null) {
  for (ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
    if (!RepositoriesMetaData.TYPE.equals(cursor.key)) {

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

if (metaData.customs().isEmpty() == false) {
  sb.append("metadata customs:\n");
  for (final ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
    final String type = cursor.key;
    final MetaData.Custom custom = cursor.value;

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

/**
 * Returns a set of custom meta data types when any custom metadata for the cluster has changed
 * between the previous cluster state and the new cluster state. custom meta data types are
 * returned iff they have been added, updated or removed between the previous and the current state
 */
public Set<String> changedCustomMetaDataSet() {
  Set<String> result = new HashSet<>();
  ImmutableOpenMap<String, MetaData.Custom> currentCustoms = state.metaData().customs();
  ImmutableOpenMap<String, MetaData.Custom> previousCustoms = previousState.metaData().customs();
  if (currentCustoms.equals(previousCustoms) == false) {
    for (ObjectObjectCursor<String, MetaData.Custom> currentCustomMetaData : currentCustoms) {
      // new custom md added or existing custom md changed
      if (previousCustoms.containsKey(currentCustomMetaData.key) == false
          || currentCustomMetaData.value.equals(previousCustoms.get(currentCustomMetaData.key)) == false) {
        result.add(currentCustomMetaData.key);
      }
    }
    // existing custom md deleted
    for (ObjectObjectCursor<String, MetaData.Custom> previousCustomMetaData : previousCustoms) {
      if (currentCustoms.containsKey(previousCustomMetaData.key) == false) {
        result.add(previousCustomMetaData.key);
      }
    }
  }
  return result;
}

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

if (metaData.customs().isEmpty() == false) {
  sb.append("metadata customs:\n");
  for (final ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
    final String type = cursor.key;
    final MetaData.Custom custom = cursor.value;

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

/**
 * Returns a set of custom meta data types when any custom metadata for the cluster has changed
 * between the previous cluster state and the new cluster state. custom meta data types are
 * returned iff they have been added, updated or removed between the previous and the current state
 */
public Set<String> changedCustomMetaDataSet() {
  Set<String> result = new HashSet<>();
  ImmutableOpenMap<String, MetaData.Custom> currentCustoms = state.metaData().customs();
  ImmutableOpenMap<String, MetaData.Custom> previousCustoms = previousState.metaData().customs();
  if (currentCustoms.equals(previousCustoms) == false) {
    for (ObjectObjectCursor<String, MetaData.Custom> currentCustomMetaData : currentCustoms) {
      // new custom md added or existing custom md changed
      if (previousCustoms.containsKey(currentCustomMetaData.key) == false
          || currentCustomMetaData.value.equals(previousCustoms.get(currentCustomMetaData.key)) == false) {
        result.add(currentCustomMetaData.key);
      }
    }
    // existing custom md deleted
    for (ObjectObjectCursor<String, MetaData.Custom> previousCustomMetaData : previousCustoms) {
      if (currentCustoms.containsKey(previousCustomMetaData.key) == false) {
        result.add(previousCustomMetaData.key);
      }
    }
  }
  return result;
}

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

/**
 * Returns a set of custom meta data types when any custom metadata for the cluster has changed
 * between the previous cluster state and the new cluster state. custom meta data types are
 * returned iff they have been added, updated or removed between the previous and the current state
 */
public Set<String> changedCustomMetaDataSet() {
  Set<String> result = new HashSet<>();
  ImmutableOpenMap<String, MetaData.Custom> currentCustoms = state.metaData().customs();
  ImmutableOpenMap<String, MetaData.Custom> previousCustoms = previousState.metaData().customs();
  if (currentCustoms.equals(previousCustoms) == false) {
    for (ObjectObjectCursor<String, MetaData.Custom> currentCustomMetaData : currentCustoms) {
      // new custom md added or existing custom md changed
      if (previousCustoms.containsKey(currentCustomMetaData.key) == false
          || currentCustomMetaData.value.equals(previousCustoms.get(currentCustomMetaData.key)) == false) {
        result.add(currentCustomMetaData.key);
      }
    }
    // existing custom md deleted
    for (ObjectObjectCursor<String, MetaData.Custom> previousCustomMetaData : previousCustoms) {
      if (currentCustoms.containsKey(previousCustomMetaData.key) == false) {
        result.add(previousCustomMetaData.key);
      }
    }
  }
  return result;
}

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

for (ObjectObjectCursor<String, Custom> custom : currentState.metaData().customs()) {
  if (custom.value.context().contains(MetaData.XContentContext.API) == false) {
    mdBuilder.removeCustom(custom.key);

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

if (metaData.customs() != null) {
  for (ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
    if (!RepositoriesMetaData.TYPE.equals(cursor.key)) {

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

for (ObjectObjectCursor<String, Custom> cursor : metaData.customs()) {
  Custom proto = lookupPrototypeSafe(cursor.key);
  if (proto.context().contains(context)) {

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

for (ObjectObjectCursor<String, Custom> cursor : metaData.customs()) {
  if (cursor.value.context().contains(context)) {
    builder.startObject(cursor.key);

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

/**
 * For interoperability with transport clients older than 6.3, we need to strip customs
 * from the cluster state that the client might not be able to deserialize
 *
 * @param clusterState the cluster state to filter the customs from
 * @return the adapted cluster state
 */
public static ClusterState filterCustomsForPre63Clients(ClusterState clusterState) {
  final ClusterState.Builder builder = ClusterState.builder(clusterState);
  clusterState.customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_CLUSTER_CUSTOMS_WHITE_LIST.contains(name) == false) {
      builder.removeCustom(name);
    }
  });
  final MetaData.Builder metaBuilder = MetaData.builder(clusterState.metaData());
  clusterState.metaData().customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_METADATA_CUSTOMS_WHITE_LIST.contains(name) == false) {
      metaBuilder.removeCustom(name);
    }
  });
  return builder.metaData(metaBuilder).build();
}

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

for (ObjectObjectCursor<String, Custom> cursor : metaData.customs()) {
  if (cursor.value.context().contains(context)) {
    builder.startObject(cursor.key);

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

/**
 * For interoperability with transport clients older than 6.3, we need to strip customs
 * from the cluster state that the client might not be able to deserialize
 *
 * @param clusterState the cluster state to filter the customs from
 * @return the adapted cluster state
 */
public static ClusterState filterCustomsForPre63Clients(ClusterState clusterState) {
  final ClusterState.Builder builder = ClusterState.builder(clusterState);
  clusterState.customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_CLUSTER_CUSTOMS_WHITE_LIST.contains(name) == false) {
      builder.removeCustom(name);
    }
  });
  final MetaData.Builder metaBuilder = MetaData.builder(clusterState.metaData());
  clusterState.metaData().customs().keysIt().forEachRemaining(name -> {
    if (PRE_6_3_METADATA_CUSTOMS_WHITE_LIST.contains(name) == false) {
      metaBuilder.removeCustom(name);
    }
  });
  return builder.metaData(metaBuilder).build();
}

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

private void restoreGlobalStateIfRequested(MetaData.Builder mdBuilder) {
  if (request.includeGlobalState()) {
    if (metaData.persistentSettings() != null) {
      Settings settings = metaData.persistentSettings();
      clusterSettings.validateUpdate(settings);
      mdBuilder.persistentSettings(settings);
    }
    if (metaData.templates() != null) {
      // TODO: Should all existing templates be deleted first?
      for (ObjectCursor<IndexTemplateMetaData> cursor : metaData.templates().values()) {
        mdBuilder.put(cursor.value);
      }
    }
    if (metaData.customs() != null) {
      for (ObjectObjectCursor<String, MetaData.Custom> cursor : metaData.customs()) {
        if (!RepositoriesMetaData.TYPE.equals(cursor.key)) {
          // Don't restore repositories while we are working with them
          // TODO: Should we restore them at the end?
          mdBuilder.putCustom(cursor.key, cursor.value);
        }
      }
    }
  }
}

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

for(ObjectObjectCursor<String, Custom> custom :  currentState.metaData().customs()) {
  if(!custom.value.context().contains(MetaData.XContentContext.API)) {
    mdBuilder.removeCustom(custom.key);

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

Metadata

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    MetaData类方法

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