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

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

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

MetaData.iterator介绍

暂无

代码示例

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

public ClusterState updateNumberOfReplica(ClusterState currentState) {
  MetaData.Builder metaDataBuilder = MetaData.builder(currentState.metaData());
  for(Iterator<IndexMetaData> it = currentState.metaData().iterator(); it.hasNext(); ) {
    IndexMetaData indexMetaData = it.next();
    IndexMetaData.Builder indexMetaDataBuilder = IndexMetaData.builder(indexMetaData);
    int rf = replicationFactor(indexMetaData.keyspace());
    indexMetaDataBuilder.numberOfReplicas( Math.max(0, rf - 1) );
    metaDataBuilder.put(indexMetaDataBuilder.build(), false);
  }
  return ClusterState.builder(currentState).metaData(metaDataBuilder.build()).build();
}

代码示例来源:origin: crate/elasticsearch-inout-plugin

IndexMetaData indexMetaData = metaData.iterator().next();
if (context.settings()) {
  try {

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

List<ImmutableIndexInfo> indexList = new ArrayList<ImmutableIndexInfo>();
for(Iterator<IndexMetaData> indexMetaDataIterator = state.metaData().iterator(); indexMetaDataIterator.hasNext(); ) {
  IndexMetaData indexMetaData = indexMetaDataIterator.next();
  String index = indexMetaData.getIndex().getName();

代码示例来源:origin: javanna/elasticshell

IndexMetaData indexMetaData = metaData.iterator().next();
for (MappingMetaData mappingMd : indexMetaData.mappings().values()) {
  if (!typesSet.isEmpty() && !typesSet.contains(mappingMd.type())) {

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

public ClusterState updateNumberOfShardsAndReplicas(ClusterState currentState) {
  int numberOfNodes = currentState.nodes().getSize();
  
  if (numberOfNodes == 0)
    return currentState; // for testing purposes.
  
  MetaData.Builder metaDataBuilder = MetaData.builder(currentState.metaData());
  for(Iterator<IndexMetaData> it = currentState.metaData().iterator(); it.hasNext(); ) {
    IndexMetaData indexMetaData = it.next();
    IndexMetaData.Builder indexMetaDataBuilder = IndexMetaData.builder(indexMetaData);
    indexMetaDataBuilder.numberOfShards(numberOfNodes);
    int rf = replicationFactor(indexMetaData.keyspace());
    indexMetaDataBuilder.numberOfReplicas( Math.max(0, rf - 1) );
    metaDataBuilder.put(indexMetaDataBuilder.build(), false);
  }
  return ClusterState.builder(currentState).metaData(metaDataBuilder.build()).build();
}

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

@Override
public ClusterState execute(ClusterState currentState) {
  ClusterState.Builder clusterStateBuilder = ClusterState.builder(currentState);
  
  DiscoveryNodes discoverNodes = nodes();
  if (nodesUpdate)
    clusterStateBuilder.nodes(discoverNodes);
  
  if (currentState.nodes().getSize() != discoverNodes.getSize()) {
    // update numberOfShards for all indices.
    MetaData.Builder metaDataBuilder = MetaData.builder(currentState.metaData());
    for(Iterator<IndexMetaData> it = currentState.metaData().iterator(); it.hasNext(); ) {
      IndexMetaData indexMetaData = it.next();
      IndexMetaData.Builder indexMetaDataBuilder = IndexMetaData.builder(indexMetaData);
      indexMetaDataBuilder.numberOfShards(discoverNodes.getSize());
      metaDataBuilder.put(indexMetaDataBuilder.build(), false);
    }
    clusterStateBuilder.metaData(metaDataBuilder.build());
  }
  return clusterStateBuilder.incrementVersion().build();
}

相关文章

微信公众号

最新文章

更多