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

F.node2id介绍

暂无

代码示例

代码示例来源：origin: apache/ignite

/**
 * Converts collection of nodes to collection of node IDs.
 *
 * @param nodes Nodes.
 * @return Node IDs.
 */
public static Collection<UUID> nodeIds(@Nullable Collection<? extends ClusterNode> nodes) {
  return F.viewReadOnly(nodes, F.node2id());
}

代码示例来源：origin: apache/ignite

/** {@inheritDoc} */
@Override public Collection<UUID> getIds(int part) {
  assert part >= 0 && part < assignment.size() : "Affinity partition is out of range" +
    " [part=" + part + ", partitions=" + assignment.size() + ']';
  if (IGNITE_DISABLE_AFFINITY_MEMORY_OPTIMIZATION)
    return assignments2ids(assignment.get(part));
  else {
    List<ClusterNode> nodes = assignment.get(part);
    return nodes.size() > AffinityAssignment.IGNITE_AFFINITY_BACKUPS_THRESHOLD
        ? assignments2ids(nodes)
        : F.viewReadOnly(nodes, F.node2id());
  }
 }

代码示例来源：origin: apache/ignite

/**
 * Checks whether a node is alive or not.
 *
 * @param nodeId Node ID.
 * @return {@code True} if node is in the ring and is not being removed from.
 */
private boolean nodeAlive(UUID nodeId) {
  // Is node alive or about to be removed from the ring?
  TcpDiscoveryNode node = ring.node(nodeId);
  boolean nodeAlive = node != null && node.visible();
  if (nodeAlive) {
    synchronized (mux) {
      nodeAlive = !F.transform(failedNodes.keySet(), F.node2id()).contains(nodeId) &&
        !F.transform(leavingNodes, F.node2id()).contains(nodeId);
    }
  }
  return nodeAlive;
}

代码示例来源：origin: apache/ignite

/**
 * Get affinity node IDs for partition as unmodifiable collection.
 * Depending on AFFINITY_BACKUPS_THRESHOLD we returned newly allocated HashSet or view on List.
 * @param part Partition.
 * @return Affinity nodes IDs.
 */
@Override public Collection<UUID> getIds(int part) {
  assert part >= 0 && part < assignment.size() : "Affinity partition is out of range" +
    " [part=" + part + ", partitions=" + assignment.size() + ']';
  if (IGNITE_DISABLE_AFFINITY_MEMORY_OPTIMIZATION)
    return getOrCreateAssignmentsIds(part);
  else {
    List<ClusterNode> nodes = assignment.get(part);
    return nodes.size() > GridAffinityAssignmentV2.IGNITE_AFFINITY_BACKUPS_THRESHOLD
        ? getOrCreateAssignmentsIds(part)
        : F.viewReadOnly(nodes, F.node2id());
  }
}

代码示例来源：origin: apache/ignite

@Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Object arg) {
  if (log.isInfoEnabled()) {
    log.info("Mapping [task=" + this + ", subgrid=" + F.viewReadOnly(subgrid, F.node2id()) +
      ", arg=" + arg + ']');

代码示例来源：origin: apache/ignite

@Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Object arg) {
  if (log.isInfoEnabled()) {
    log.info("Mapping [task=" + this + ", subgrid=" + F.viewReadOnly(subgrid, F.node2id()) +
      ", arg=" + arg + ']');

代码示例来源：origin: apache/ignite

/** {@inheritDoc} */
@Override public Collection<UUID> getTopology() {
  if (topPred != null)
    return F.viewReadOnly(ctx.discovery().allNodes(), F.node2id(), topPred);
  return top != null ? top : F.nodeIds(ctx.discovery().allNodes());
}

代码示例来源：origin: apache/ignite

log.trace("Sending full partition map [nodeIds=" + F.viewReadOnly(nodes, F.node2id()) +
  ", exchId=" + exchId + ", msg=" + fullMsg + ']');

代码示例来源：origin: apache/ignite

F.viewReadOnly(
  igfsCtx.kernalContext().discovery().allNodes(),
  F.node2id(),
  new P1<ClusterNode>() {
    @Override public boolean apply(ClusterNode n) {

代码示例来源：origin: apache/ignite

if (last != null && equal(last.nodeIds(), F.viewReadOnly(affNodes, F.node2id()))) {

代码示例来源：origin: apache/ignite

", affNodes=" + F.nodeIds(affNodes) + ']');
if (last != null && equal(last.nodeIds(), F.viewReadOnly(affNodes, F.node2id()))) {

代码示例来源：origin: apache/ignite

Collection<UUID> nodes = F.viewReadOnly(grid.context().discovery().aliveServerNodes(), F.node2id());

代码示例来源：origin: apache/ignite

F.viewReadOnly(grid(0).affinity(DEFAULT_CACHE_NAME).mapKeyToPrimaryAndBackups(key), F.node2id()) + ']');

代码示例来源：origin: org.apache.ignite/ignite-core

/**
 * Converts collection of nodes to collection of node IDs.
 *
 * @param nodes Nodes.
 * @return Node IDs.
 */
public static Collection<UUID> nodeIds(@Nullable Collection<? extends ClusterNode> nodes) {
  return F.viewReadOnly(nodes, F.node2id());
}

代码示例来源：origin: org.apache.ignite/ignite-core

/**
 * Checks whether a node is alive or not.
 *
 * @param nodeId Node ID.
 * @return {@code True} if node is in the ring and is not being removed from.
 */
private boolean nodeAlive(UUID nodeId) {
  // Is node alive or about to be removed from the ring?
  TcpDiscoveryNode node = ring.node(nodeId);
  boolean nodeAlive = node != null && node.visible();
  if (nodeAlive) {
    synchronized (mux) {
      nodeAlive = !F.transform(failedNodes.keySet(), F.node2id()).contains(nodeId) &&
        !F.transform(leavingNodes, F.node2id()).contains(nodeId);
    }
  }
  return nodeAlive;
}

代码示例来源：origin: org.apache.ignite/ignite-core

/** {@inheritDoc} */
@Override public Collection<UUID> getTopology() {
  if (topPred != null)
    return F.viewReadOnly(ctx.discovery().allNodes(), F.node2id(), topPred);
  return top != null ? top : F.nodeIds(ctx.discovery().allNodes());
}

代码示例来源：origin: org.apache.ignite/ignite-core

log.trace("Sending full partition map [nodeIds=" + F.viewReadOnly(nodes, F.node2id()) +
  ", exchId=" + exchId + ", msg=" + fullMsg + ']');

代码示例来源：origin: org.apache.ignite/ignite-core

F.viewReadOnly(
  igfsCtx.kernalContext().discovery().allNodes(),
  F.node2id(),
  new P1<ClusterNode>() {
    @Override public boolean apply(ClusterNode n) {

代码示例来源：origin: org.apache.ignite/ignite-core

if (last != null && equal(last.nodeIds(), F.viewReadOnly(affNodes, F.node2id()))) {

代码示例来源：origin: org.apache.ignite/ignite-core

", affNodes=" + F.nodeIds(affNodes) + ']');
if (last != null && equal(last.nodeIds(), F.viewReadOnly(affNodes, F.node2id()))) {