org.elasticsearch.cluster.node.DiscoveryNodes.getSize()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(10.6k)|赞(0)|评价(0)|浏览(102)

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

DiscoveryNodes.getSize介绍

[英]Get the number of known nodes
[中]获取已知节点的数量

代码示例

代码示例来源：origin: floragunncom/search-guard

@Before
public void setup() {
  when(dns.getSize()).thenReturn(10);
  when(cstate.getNodes()).thenReturn(dns);
  when(cs.state()).thenReturn(cstate);
}

代码示例来源：origin: floragunncom/search-guard

final int numberOfNodes = clusterService.state().getNodes().getSize();

代码示例来源：origin: pentaho/pentaho-kettle

String name = cluResp.getClusterName().value();
ClusterState cluState = cluResp.getState();
int numNodes = cluState.getNodes().getSize();
showMessage( BaseMessages.getString( PKG, "ElasticSearchBulkDialog.TestCluster.TestOK", name, numNodes ) );
break;

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

public void connectToNodes(DiscoveryNodes discoveryNodes) {
  CountDownLatch latch = new CountDownLatch(discoveryNodes.getSize());
  for (final DiscoveryNode node : discoveryNodes) {
    final boolean connected;

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

ClearScrollController(ClearScrollRequest request, ActionListener<ClearScrollResponse> listener, DiscoveryNodes nodes, Logger logger,
           SearchTransportService searchTransportService) {
  this.nodes = nodes;
  this.logger = logger;
  this.searchTransportService = searchTransportService;
  this.listener = listener;
  List<String> scrollIds = request.getScrollIds();
  final int expectedOps;
  if (scrollIds.size() == 1 && "_all".equals(scrollIds.get(0))) {
    expectedOps = nodes.getSize();
    runner = this::cleanAllScrolls;
  } else {
    List<ScrollIdForNode> parsedScrollIds = new ArrayList<>();
    for (String parsedScrollId : request.getScrollIds()) {
      ScrollIdForNode[] context = parseScrollId(parsedScrollId).getContext();
      for (ScrollIdForNode id : context) {
        parsedScrollIds.add(id);
      }
    }
    if (parsedScrollIds.isEmpty()) {
      expectedOps = 0;
      runner = () -> listener.onResponse(new ClearScrollResponse(true, 0));
    } else {
      expectedOps = parsedScrollIds.size();
      runner = () -> cleanScrollIds(parsedScrollIds);
    }
  }
  this.expectedOps = new CountDown(expectedOps);
}

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

if (cancellableTask.shouldCancelChildrenOnCancellation()) {
  DiscoveryNodes childNodes = clusterService.state().nodes();
  final BanLock banLock = new BanLock(childNodes.getSize(), () -> removeBanOnNodes(cancellableTask, childNodes));
  canceled = taskManager.cancel(cancellableTask, request.getReason(), banLock::onTaskFinished);
  if (canceled) {
    AtomicInteger responses = new AtomicInteger(childNodes.getSize());
    List<Exception> failures = new ArrayList<>();
    setBanOnNodes(request.getReason(), cancellableTask, childNodes, new ActionListener<Void>() {

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

try {
  nodes = clusterChangedEvent.state().nodes();
  nodesToPublishTo = new HashSet<>(nodes.getSize());
  DiscoveryNode localNode = nodes.getLocalNode();
  final int totalMasterNodes = nodes.getMasterNodes().size();

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

numberOfNodes = clusterState.nodes().getSize();
numberOfDataNodes = clusterState.nodes().getDataNodes().size();
indices = new HashMap<>();

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

public void connectToNodes(DiscoveryNodes discoveryNodes) {
  CountDownLatch latch = new CountDownLatch(discoveryNodes.getSize());
  for (final DiscoveryNode node : discoveryNodes) {
    final boolean connected;

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

public void connectToNodes(DiscoveryNodes discoveryNodes) {
  CountDownLatch latch = new CountDownLatch(discoveryNodes.getSize());
  for (final DiscoveryNode node : discoveryNodes) {
    final boolean connected;

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

public void connectToNodes(DiscoveryNodes discoveryNodes) {
  CountDownLatch latch = new CountDownLatch(discoveryNodes.getSize());
  for (final DiscoveryNode node : discoveryNodes) {
    final boolean connected;

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

public MetaDataVersionAckListener(long version, Discovery.AckListener ackListener, ClusterState clusterState) {
  this.expectedVersion = version;
  this.ackListener = ackListener;
  this.clusterState = clusterState;
  this.attendees = new ConcurrentHashMap<String, DiscoveryNode>(clusterState.nodes().getSize());
  MetaDataVersionAckListener prevListener = CassandraDiscovery.this.metaDataVersionAckListener.getAndSet(this);
  assert prevListener == null : "metaDataVersionAckListener should be null";
  clusterState.nodes().forEach((n) -> { 
    if (!localNode.getId().equals(n.getId()) && 
      n.status() == DiscoveryNodeStatus.ALIVE &&
      isNormal(Gossiper.instance.getEndpointStateForEndpoint(n.getInetAddress()))) 
      attendees.put(n.getId(), n); 
    });
  logger.debug("new MetaDataVersionAckListener version={} attendees={}", expectedVersion, this.attendees.keySet());
  if (attendees.size() == 0)
    countDownLatch.countDown();
}

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

private Async(ClearScrollRequest request, ActionListener<ClearScrollResponse> listener, ClusterState clusterState) {
  int expectedOps = 0;
  this.nodes = clusterState.nodes();
  if (request.getScrollIds().size() == 1 && "_all".equals(request.getScrollIds().get(0))) {
    expectedOps = nodes.getSize();
  } else {
    for (String parsedScrollId : request.getScrollIds()) {
      ScrollIdForNode[] context = parseScrollId(parsedScrollId).getContext();
      expectedOps += context.length;
      this.contexts.add(context);
    }
  }
  this.listener = listener;
  this.expHolder = new AtomicReference<>();
  this.expectedOps = new CountDown(expectedOps);
}

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

ClearScrollController(ClearScrollRequest request, ActionListener<ClearScrollResponse> listener, DiscoveryNodes nodes, Logger logger,
           SearchTransportService searchTransportService) {
  this.nodes = nodes;
  this.logger = logger;
  this.searchTransportService = searchTransportService;
  this.listener = listener;
  List<String> scrollIds = request.getScrollIds();
  final int expectedOps;
  if (scrollIds.size() == 1 && "_all".equals(scrollIds.get(0))) {
    expectedOps = nodes.getSize();
    runner = this::cleanAllScrolls;
  } else {
    List<ScrollIdForNode> parsedScrollIds = new ArrayList<>();
    for (String parsedScrollId : request.getScrollIds()) {
      ScrollIdForNode[] context = parseScrollId(parsedScrollId).getContext();
      for (ScrollIdForNode id : context) {
        parsedScrollIds.add(id);
      }
    }
    if (parsedScrollIds.isEmpty()) {
      expectedOps = 0;
      runner = () -> listener.onResponse(new ClearScrollResponse(true, 0));
    } else {
      expectedOps = parsedScrollIds.size();
      runner = () -> cleanScrollIds(parsedScrollIds);
    }
  }
  this.expectedOps = new CountDown(expectedOps);
}

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

ClearScrollController(ClearScrollRequest request, ActionListener<ClearScrollResponse> listener, DiscoveryNodes nodes, Logger logger,
           SearchTransportService searchTransportService) {
  this.nodes = nodes;
  this.logger = logger;
  this.searchTransportService = searchTransportService;
  this.listener = listener;
  List<String> scrollIds = request.getScrollIds();
  final int expectedOps;
  if (scrollIds.size() == 1 && "_all".equals(scrollIds.get(0))) {
    expectedOps = nodes.getSize();
    runner = this::cleanAllScrolls;
  } else {
    List<ScrollIdForNode> parsedScrollIds = new ArrayList<>();
    for (String parsedScrollId : request.getScrollIds()) {
      ScrollIdForNode[] context = parseScrollId(parsedScrollId).getContext();
      for (ScrollIdForNode id : context) {
        parsedScrollIds.add(id);
      }
    }
    if (parsedScrollIds.isEmpty()) {
      expectedOps = 0;
      runner = () -> listener.onResponse(new ClearScrollResponse(true, 0));
    } else {
      expectedOps = parsedScrollIds.size();
      runner = () -> cleanScrollIds(parsedScrollIds);
    }
  }
  this.expectedOps = new CountDown(expectedOps);
}

代码示例来源：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();
}

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

/** ensure a cluster is formed with all published nodes, but do so by using the client of the specified node */
public synchronized void validateClusterFormed(String viaNode) {
  Set<DiscoveryNode> expectedNodes = new HashSet<>();
  for (NodeAndClient nodeAndClient : nodes.values()) {
    expectedNodes.add(getInstanceFromNode(ClusterService.class, nodeAndClient.node()).localNode());
  }
  logger.trace("validating cluster formed via [{}], expecting {}", viaNode, expectedNodes);
  final Client client = client(viaNode);
  try {
    if (awaitBusy(() -> {
      DiscoveryNodes discoveryNodes = client.admin().cluster().prepareState().get().getState().nodes();
      if (discoveryNodes.getSize() != expectedNodes.size()) {
        return false;
      }
      for (DiscoveryNode expectedNode : expectedNodes) {
        if (discoveryNodes.nodeExists(expectedNode) == false) {
          return false;
        }
      }
      return true;
    }, 30, TimeUnit.SECONDS) == false) {
      throw new IllegalStateException("cluster failed to form with expected nodes " + expectedNodes + " and actual nodes " +
        client.admin().cluster().prepareState().get().getState().nodes());
    }
  } catch (InterruptedException e) {
    throw new IllegalStateException(e);
  }
}

代码示例来源：origin: NLPchina/elasticsearch-analysis-ansj

final CountDownLatch countDownLatch = new CountDownLatch(nodes.getSize());

代码示例来源：origin: NLPchina/elasticsearch-analysis-ansj

final CountDownLatch countDownLatch = new CountDownLatch(nodes.getSize());

代码示例来源：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();
}

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

DiscoveryNodes

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    DiscoveryNodes类方法

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