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

TransportService.addressesFromString介绍

暂无

代码示例

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

hosts
    .stream()
    .map(hn -> (Callable<TransportAddress[]>) () -> transportService.addressesFromString(hn, limitPortCounts))
    .collect(Collectors.toList());
final List<Future<TransportAddress[]>> futures;

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

hosts
    .stream()
    .map(hn -> (Callable<TransportAddress[]>) () -> transportService.addressesFromString(hn, limitPortCounts))
    .collect(Collectors.toList());
final List<Future<TransportAddress[]>> futures;

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

hosts
    .stream()
    .map(hn -> (Callable<TransportAddress[]>) () -> transportService.addressesFromString(hn, limitPortCounts))
    .collect(Collectors.toList());
final List<Future<TransportAddress[]>> futures;

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

hosts
    .stream()
    .map(hn -> (Callable<TransportAddress[]>) () -> transportService.addressesFromString(hn, limitPortCounts))
    .collect(Collectors.toList());
final List<Future<TransportAddress[]>> futures =

代码示例来源：origin: fabric8io/elasticsearch-cloud-kubernetes

endpointSubset.getPorts().stream().forEach((port) -> {
 try {
  TransportAddress[] addresses = transportService.addressesFromString(formattedEndpointAddress + ":" + port.getPort(), 1);

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

for (String host : hosts) {
  try {
    TransportAddress[] addresses = transportService.addressesFromString(host, limitPortCounts);
    for (TransportAddress address : addresses) {
      configuredTargetNodes.add(new DiscoveryNode(UNICAST_NODE_PREFIX + unicastNodeIdGenerator.incrementAndGet() + "#", address, version.minimumCompatibilityVersion()));

代码示例来源：origin: lithiumtech/elasticsearch-consul-discovery

String address = discoveryResult.getIp() + ":" + discoveryResult.getPort();
try {
  TransportAddress[] addresses = transportService.addressesFromString(address, 1);
  if (logger.isTraceEnabled()) {
    logger.trace("adding {}, transport_address {}", address, addresses[0]);

代码示例来源：origin: github/elasticsearch-srv-discovery

protected List<DiscoveryNode> lookupNodes() throws TextParseException {
    List<DiscoveryNode> discoNodes = Lists.newArrayList();

    for (Record srvRecord : lookupRecords(query, Type.SRV)) {
      logger.trace("Found SRV record {}", srvRecord);
      for (Record aRecord : lookupRecords(((SRVRecord) srvRecord).getTarget().toString(), Type.A)) {
        logger.trace("Found A record {} for SRV record", aRecord, srvRecord);
        String address = ((ARecord) aRecord).getAddress().getHostAddress() + ":" + ((SRVRecord) srvRecord).getPort();
        try {
          for (TransportAddress transportAddress : transportService.addressesFromString(address)) {
            logger.trace("adding {}, transport_address {}", address, transportAddress);
            discoNodes.add(new DiscoveryNode("#srv-" + address + "-" + transportAddress, transportAddress, version.minimumCompatibilityVersion()));
          }
        } catch (Exception e) {
          logger.warn("failed to add {}, address {}", e, address);
        }
      }
    }

    return discoNodes;
  }
}

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

TransportAddress[] addresses = transportService.addressesFromString(address);