本文整理了Java中org.elasticsearch.cluster.metadata.MetaData.iterator()
方法的一些代码示例,展示了MetaData.iterator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetaData.iterator()
方法的具体详情如下:
包路径:org.elasticsearch.cluster.metadata.MetaData
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!