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

Node.getHttpUri介绍

暂无

代码示例

代码示例来源：origin: prestosql/presto

@Override
  public URI createMemoryInfoLocation(Node node)
  {
    requireNonNull(node, "node is null");
    return uriBuilderFrom(node.getHttpUri())
        .appendPath("/v1/memory").build();
  }
}

代码示例来源：origin: io.prestosql/presto-main

@Override
  public URI createMemoryInfoLocation(Node node)
  {
    requireNonNull(node, "node is null");
    return uriBuilderFrom(node.getHttpUri())
        .appendPath("/v1/memory").build();
  }
}

代码示例来源：origin: io.prestosql/presto-main

private void addRows(Builder table, Set<Node> nodes, NodeState state)
{
  for (Node node : nodes) {
    table.addRow(node.getNodeIdentifier(), node.getHttpUri().toString(), getNodeVersion(node), isCoordinator(node), state.toString().toLowerCase(Locale.ENGLISH));
  }
}

代码示例来源：origin: prestosql/presto

@Override
public URI createTaskLocation(Node node, TaskId taskId)
{
  requireNonNull(node, "node is null");
  requireNonNull(taskId, "taskId is null");
  return uriBuilderFrom(node.getHttpUri())
      .appendPath("/v1/task")
      .appendPath(taskId.toString())
      .build();
}

代码示例来源：origin: io.prestosql/presto-main

@Override
public URI createTaskLocation(Node node, TaskId taskId)
{
  requireNonNull(node, "node is null");
  requireNonNull(taskId, "taskId is null");
  return uriBuilderFrom(node.getHttpUri())
      .appendPath("/v1/task")
      .appendPath(taskId.toString())
      .build();
}

代码示例来源：origin: prestosql/presto

private void addRows(Builder table, Set<Node> nodes, NodeState state)
{
  for (Node node : nodes) {
    table.addRow(node.getNodeIdentifier(), node.getHttpUri().toString(), getNodeVersion(node), isCoordinator(node), state.toString().toLowerCase(Locale.ENGLISH));
  }
}

代码示例来源：origin: io.prestosql/presto-main

private Response proxyJsonResponse(String nodeId, String workerPath)
{
  Set<Node> nodes = nodeManager.getNodes(NodeState.ACTIVE);
  Node node = nodes.stream()
      .filter(n -> n.getNodeIdentifier().equals(nodeId))
      .findFirst()
      .orElseThrow(() -> new WebApplicationException(NOT_FOUND));
  Request request = prepareGet()
      .setUri(uriBuilderFrom(node.getHttpUri())
          .appendPath(workerPath)
          .build())
      .build();
  InputStream responseStream = httpClient.execute(request, new StreamingJsonResponseHandler());
  return Response.ok(responseStream, APPLICATION_JSON_TYPE).build();
}

代码示例来源：origin: prestosql/presto

private Response proxyJsonResponse(String nodeId, String workerPath)
{
  Set<Node> nodes = nodeManager.getNodes(NodeState.ACTIVE);
  Node node = nodes.stream()
      .filter(n -> n.getNodeIdentifier().equals(nodeId))
      .findFirst()
      .orElseThrow(() -> new WebApplicationException(NOT_FOUND));
  Request request = prepareGet()
      .setUri(uriBuilderFrom(node.getHttpUri())
          .appendPath(workerPath)
          .build())
      .build();
  InputStream responseStream = httpClient.execute(request, new StreamingJsonResponseHandler());
  return Response.ok(responseStream, APPLICATION_JSON_TYPE).build();
}

代码示例来源：origin: prestosql/presto

private void pollWorkers()
{
  AllNodes allNodes = getAllNodes();
  Set<Node> aliveNodes = ImmutableSet.<Node>builder()
      .addAll(allNodes.getActiveNodes())
      .addAll(allNodes.getShuttingDownNodes())
      .build();
  ImmutableSet<String> aliveNodeIds = aliveNodes.stream()
      .map(Node::getNodeIdentifier)
      .collect(toImmutableSet());
  // Remove nodes that don't exist anymore
  // Make a copy to materialize the set difference
  Set<String> deadNodes = difference(nodeStates.keySet(), aliveNodeIds).immutableCopy();
  nodeStates.keySet().removeAll(deadNodes);
  // Add new nodes
  for (Node node : aliveNodes) {
    nodeStates.putIfAbsent(node.getNodeIdentifier(),
        new RemoteNodeState(httpClient, uriBuilderFrom(node.getHttpUri()).appendPath("/v1/info/state").build()));
  }
  // Schedule refresh
  nodeStates.values().forEach(RemoteNodeState::asyncRefresh);
  // update indexes
  refreshNodesInternal();
}

代码示例来源：origin: io.prestosql/presto-main

private void pollWorkers()
{
  AllNodes allNodes = getAllNodes();
  Set<Node> aliveNodes = ImmutableSet.<Node>builder()
      .addAll(allNodes.getActiveNodes())
      .addAll(allNodes.getShuttingDownNodes())
      .build();
  ImmutableSet<String> aliveNodeIds = aliveNodes.stream()
      .map(Node::getNodeIdentifier)
      .collect(toImmutableSet());
  // Remove nodes that don't exist anymore
  // Make a copy to materialize the set difference
  Set<String> deadNodes = difference(nodeStates.keySet(), aliveNodeIds).immutableCopy();
  nodeStates.keySet().removeAll(deadNodes);
  // Add new nodes
  for (Node node : aliveNodes) {
    nodeStates.putIfAbsent(node.getNodeIdentifier(),
        new RemoteNodeState(httpClient, uriBuilderFrom(node.getHttpUri()).appendPath("/v1/info/state").build()));
  }
  // Schedule refresh
  nodeStates.values().forEach(RemoteNodeState::asyncRefresh);
  // update indexes
  refreshNodesInternal();
}

代码示例来源：origin: prestosql/presto

writerImplementation,
nodeManager.getCurrentNode().getVersion(),
nodeManager.getCurrentNode().getHttpUri().getHost(),
session.getIdentity().getPrincipal().map(Principal::getName).orElse(null),
nodeManager.getEnvironment(),

代码示例来源：origin: io.prestosql/presto-main

private synchronized void announceNodes(Set<Node> activeNodes, Set<Node> inactiveNodes)
{
  ImmutableList.Builder<ServiceDescriptor> descriptors = ImmutableList.builder();
  for (Node node : Iterables.concat(activeNodes, inactiveNodes)) {
    descriptors.add(serviceDescriptor("presto")
        .setNodeId(node.getNodeIdentifier())
        .addProperty("http", node.getHttpUri().toString())
        .addProperty("node_version", ((PrestoNode) node).getNodeVersion().toString())
        .addProperty("coordinator", String.valueOf(node.isCoordinator()))
        .build());
  }
  this.descriptors = descriptors.build();
}

代码示例来源：origin: prestosql/presto

private synchronized void announceNodes(Set<Node> activeNodes, Set<Node> inactiveNodes)
{
  ImmutableList.Builder<ServiceDescriptor> descriptors = ImmutableList.builder();
  for (Node node : Iterables.concat(activeNodes, inactiveNodes)) {
    descriptors.add(serviceDescriptor("presto")
        .setNodeId(node.getNodeIdentifier())
        .addProperty("http", node.getHttpUri().toString())
        .addProperty("node_version", ((PrestoNode) node).getNodeVersion().toString())
        .addProperty("coordinator", String.valueOf(node.isCoordinator()))
        .build());
  }
  this.descriptors = descriptors.build();
}

代码示例来源：origin: io.prestosql/presto-main

byHostAndPort.put(node.getHostAndPort(), node);
InetAddress host = InetAddress.getByName(node.getHttpUri().getHost());
byHost.put(host, node);

代码示例来源：origin: prestosql/presto

byHostAndPort.put(node.getHostAndPort(), node);
InetAddress host = InetAddress.getByName(node.getHttpUri().getHost());
byHost.put(host, node);