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

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

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

DiscoveryNodes.getNodes介绍

[英]Get a Map of the discovered nodes arranged by their ids
[中]获取按ID排列的已发现节点的映射

代码示例

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

private void sendRemoveBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.debug("Sending remove ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request, EmptyTransportResponseHandler
      .INSTANCE_SAME);
  }
}

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

private void sendSetBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request, ActionListener<Void> listener) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.trace("Sending ban for tasks with the parent [{}] to the node [{}], ban [{}]", request.parentTaskId, node.key,
      request.ban);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request,
      new EmptyTransportResponseHandler(ThreadPool.Names.SAME) {
        @Override
        public void handleResponse(TransportResponse.Empty response) {
          listener.onResponse(null);
        }
        @Override
        public void handleException(TransportException exp) {
          logger.warn("Cannot send ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
          listener.onFailure(exp);
        }
      });
  }
}

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

public Builder(DiscoveryNodes nodes) {
  this.masterNodeId = nodes.getMasterNodeId();
  this.localNodeId = nodes.getLocalNodeId();
  this.nodes = ImmutableOpenMap.builder(nodes.getNodes());
}

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

Iterable<DiscoveryNode> nodesIter = nodes.getNodes()::valuesIt;
for (DiscoveryNode n : nodesIter) {
  DiscoveryNode node = maybeAddProxyAddress(proxyAddress, n);

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

DiscoveryNode[] possibleMasters = electMaster.nextPossibleMasters(nodes.getNodes().values(), 5);
for (DiscoveryNode possibleMaster : possibleMasters) {
  if (nodes.getLocalNode().equals(possibleMaster)) {

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

private void sendRemoveBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.debug("Sending remove ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request, EmptyTransportResponseHandler
      .INSTANCE_SAME);
  }
}

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

private void sendRemoveBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.debug("Sending remove ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request, EmptyTransportResponseHandler
      .INSTANCE_SAME);
  }
}

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

private void sendRemoveBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.debug("Sending remove ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request, EmptyTransportResponseHandler
      .INSTANCE_SAME);
  }
}

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

private void sendSetBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request, ActionListener<Void> listener) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.trace("Sending ban for tasks with the parent [{}] to the node [{}], ban [{}]", request.parentTaskId, node.key,
      request.ban);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request,
      new EmptyTransportResponseHandler(ThreadPool.Names.SAME) {
        @Override
        public void handleResponse(TransportResponse.Empty response) {
          listener.onResponse(null);
        }
        @Override
        public void handleException(TransportException exp) {
          logger.warn("Cannot send ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
          listener.onFailure(exp);
        }
      });
  }
}

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

private void sendSetBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request, ActionListener<Void> listener) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.trace("Sending ban for tasks with the parent [{}] to the node [{}], ban [{}]", request.parentTaskId, node.key,
      request.ban);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request,
      new EmptyTransportResponseHandler(ThreadPool.Names.SAME) {
        @Override
        public void handleResponse(TransportResponse.Empty response) {
          listener.onResponse(null);
        }
        @Override
        public void handleException(TransportException exp) {
          logger.warn("Cannot send ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
          listener.onFailure(exp);
        }
      });
  }
}

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

private void sendSetBanRequest(DiscoveryNodes nodes, BanParentTaskRequest request, ActionListener<Void> listener) {
  for (ObjectObjectCursor<String, DiscoveryNode> node : nodes.getNodes()) {
    logger.trace("Sending ban for tasks with the parent [{}] to the node [{}], ban [{}]", request.parentTaskId, node.key,
      request.ban);
    transportService.sendRequest(node.value, BAN_PARENT_ACTION_NAME, request,
      new EmptyTransportResponseHandler(ThreadPool.Names.SAME) {
        @Override
        public void handleResponse(TransportResponse.Empty response) {
          listener.onResponse(null);
        }
        @Override
        public void handleException(TransportException exp) {
          logger.warn("Cannot send ban for tasks with the parent [{}] to the node [{}]", request.parentTaskId, node.key);
          listener.onFailure(exp);
        }
      });
  }
}

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

public Builder(DiscoveryNodes nodes) {
  this.masterNodeId = nodes.getMasterNodeId();
  this.localNodeId = nodes.getLocalNodeId();
  this.nodes = ImmutableOpenMap.builder(nodes.getNodes());
}

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

public Builder(DiscoveryNodes nodes) {
  this.masterNodeId = nodes.getMasterNodeId();
  this.localNodeId = nodes.getLocalNodeId();
  this.nodes = ImmutableOpenMap.builder(nodes.getNodes());
}

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

public Builder(DiscoveryNodes nodes) {
  this.masterNodeId = nodes.getMasterNodeId();
  this.localNodeId = nodes.getLocalNodeId();
  this.nodes = ImmutableOpenMap.builder(nodes.getNodes());
}

代码示例来源：origin: visallo/vertexium

private String getLocation() {
  ClusterStateResponse responsee = runner.node().client().admin().cluster().prepareState().execute().actionGet();
  InetSocketTransportAddress address = (InetSocketTransportAddress)
      responsee.getState().getNodes().getNodes().values().iterator().next().value.getAddress();
  return "localhost:" + address.address().getPort();
}

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

Iterable<DiscoveryNode> nodesIter = nodes.getNodes()::valuesIt;
for (DiscoveryNode node : nodesIter) {
  if (nodePredicate.test(node) && connectedNodes.size() < maxNumRemoteConnections) {

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

Iterable<DiscoveryNode> nodesIter = nodes.getNodes()::valuesIt;
for (DiscoveryNode n : nodesIter) {
  DiscoveryNode node = maybeAddProxyAddress(proxyAddress, n);

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

DiscoveryNode[] possibleMasters = electMaster.nextPossibleMasters(nodes.getNodes().values(), 5);
for (DiscoveryNode possibleMaster : possibleMasters) {
  if (nodes.getLocalNode().equals(possibleMaster)) {

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

DiscoveryNode[] possibleMasters = electMaster.nextPossibleMasters(nodes.getNodes().values(), 5);
for (DiscoveryNode possibleMaster : possibleMasters) {
  if (nodes.getLocalNode().equals(possibleMaster)) {

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

DiscoveryNode[] possibleMasters = electMaster.nextPossibleMasters(nodes.getNodes().values(), 5);
for (DiscoveryNode possibleMaster : possibleMasters) {
  if (nodes.getLocalNode().equals(possibleMaster)) {

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

DiscoveryNodes

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    DiscoveryNodes类方法

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