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

Node.getNodeIdentifier介绍

暂无

代码示例

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

public int getQueuedSplitCountForStage(Node node)
{
  return queuedSplitCountByNode.getOrDefault(node.getNodeIdentifier(), 0) + assignmentCount.getOrDefault(node, 0);
}

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

public int getQueuedSplitCountForStage(Node node)
{
  return queuedSplitCountByNode.getOrDefault(node.getNodeIdentifier(), 0) + assignmentCount.getOrDefault(node, 0);
}

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

@Inject
public JmxRecordSetProvider(MBeanServer mbeanServer, NodeManager nodeManager, JmxHistoricalData jmxHistoricalData)
{
  this.mbeanServer = requireNonNull(mbeanServer, "mbeanServer is null");
  this.nodeId = requireNonNull(nodeManager, "nodeManager is null").getCurrentNode().getNodeIdentifier();
  this.jmxHistoricalData = requireNonNull(jmxHistoricalData, "jmxHistoryHolder is null");
}

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

@Override
public URI createTaskLocation(Node node, TaskId taskId)
{
  return URI.create("http://fake.invalid/task/" + node.getNodeIdentifier() + "/" + taskId);
}

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

@Override
public URI createTaskLocation(Node node, TaskId taskId)
{
  return URI.create("http://fake.invalid/task/" + node.getNodeIdentifier() + "/" + taskId);
}

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

@Override
  public URI createMemoryInfoLocation(Node node)
  {
    return URI.create("http://fake.invalid/" + node.getNodeIdentifier() + "/memory");
  }
}

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

@Override
  public URI createMemoryInfoLocation(Node node)
  {
    return URI.create("http://fake.invalid/" + node.getNodeIdentifier() + "/memory");
  }
}

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

public static ResettableRandomizedIterator<Node> randomizedNodes(NodeMap nodeMap, boolean includeCoordinator, Set<Node> excludedNodes)
{
  ImmutableList<Node> nodes = nodeMap.getNodesByHostAndPort().values().stream()
      .filter(node -> includeCoordinator || !nodeMap.getCoordinatorNodeIds().contains(node.getNodeIdentifier()))
      .filter(node -> !excludedNodes.contains(node))
      .collect(toImmutableList());
  return new ResettableRandomizedIterator<>(nodes);
}

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

public static ResettableRandomizedIterator<Node> randomizedNodes(NodeMap nodeMap, boolean includeCoordinator, Set<Node> excludedNodes)
{
  ImmutableList<Node> nodes = nodeMap.getNodesByHostAndPort().values().stream()
      .filter(node -> includeCoordinator || !nodeMap.getCoordinatorNodeIds().contains(node.getNodeIdentifier()))
      .filter(node -> !excludedNodes.contains(node))
      .collect(toImmutableList());
  return new ResettableRandomizedIterator<>(nodes);
}

代码示例来源：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

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

public ShardRecoveryManager(
    StorageService storageService,
    Optional<BackupStore> backupStore,
    NodeManager nodeManager,
    ShardManager shardManager,
    Duration missingShardDiscoveryInterval,
    int recoveryThreads)
{
  this.storageService = requireNonNull(storageService, "storageService is null");
  this.backupStore = requireNonNull(backupStore, "backupStore is null");
  this.nodeIdentifier = requireNonNull(nodeManager, "nodeManager is null").getCurrentNode().getNodeIdentifier();
  this.shardManager = requireNonNull(shardManager, "shardManager is null");
  this.missingShardDiscoveryInterval = requireNonNull(missingShardDiscoveryInterval, "missingShardDiscoveryInterval is null");
  this.shardQueue = new MissingShardsQueue(new PrioritizedFifoExecutor<>(executorService, recoveryThreads, new MissingShardComparator()));
  this.stats = new ShardRecoveryStats();
}

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

private SimpleConsumer createConsumer(HostAddress host)
  {
    log.info("Creating new Consumer for %s", host);
    return new SimpleConsumer(host.getHostText(),
        host.getPort(),
        connectTimeoutMillis,
        bufferSizeBytes,
        format("presto-kafka-%s-%s", connectorId, nodeManager.getCurrentNode().getNodeIdentifier()));
  }
}

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

@Inject
public ShardOrganizationManager(
    @ForMetadata IDBI dbi,
    NodeManager nodeManager,
    ShardManager shardManager,
    ShardOrganizer organizer,
    TemporalFunction temporalFunction,
    StorageManagerConfig config)
{
  this(dbi,
      nodeManager.getCurrentNode().getNodeIdentifier(),
      shardManager,
      organizer,
      temporalFunction,
      config.isOrganizationEnabled(),
      config.getOrganizationInterval(),
      config.getOrganizationDiscoveryInterval());
}

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

@Inject
public ShardCompactionManager(@ForMetadata IDBI dbi,
    NodeManager nodeManager,
    ShardManager shardManager,
    ShardOrganizer organizer,
    TemporalFunction temporalFunction,
    StorageManagerConfig config)
{
  this(dbi,
      nodeManager.getCurrentNode().getNodeIdentifier(),
      shardManager,
      organizer,
      temporalFunction,
      config.getCompactionInterval(),
      config.getMaxShardSize(),
      config.getMaxShardRows(),
      config.isCompactionEnabled());
}

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

@Test
public void testPredicatePushdown()
    throws Exception
{
  for (Node node : nodes) {
    String nodeIdentifier = node.getNodeIdentifier();
    TupleDomain<ColumnHandle> nodeTupleDomain = TupleDomain.fromFixedValues(ImmutableMap.of(columnHandle, NullableValue.of(createUnboundedVarcharType(), utf8Slice(nodeIdentifier))));
    ConnectorTableLayoutHandle layout = new JmxTableLayoutHandle(tableHandle, nodeTupleDomain);
    ConnectorSplitSource splitSource = splitManager.getSplits(JmxTransactionHandle.INSTANCE, SESSION, layout, UNGROUPED_SCHEDULING);
    List<ConnectorSplit> allSplits = getAllSplits(splitSource);
    assertEquals(allSplits.size(), 1);
    assertEquals(allSplits.get(0).getAddresses().size(), 1);
    assertEquals(allSplits.get(0).getAddresses().get(0).getHostText(), nodeIdentifier);
  }
}

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