Uses of Interface
org.apache.ignite.cluster.ClusterNode

Packages that use ClusterNode

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.cache.affinity	Contains cache node affinity implementations.
org.apache.ignite.cache.affinity.rendezvous	Contains HRW-based cache affinity for partitioned cache.
org.apache.ignite.client	Contains Ignite Thin Client API classes.
org.apache.ignite.cluster	Contains cluster-related classes.
org.apache.ignite.compute	Contains Compute Grid functionality.
org.apache.ignite.configuration	Contains configuration-related classes.
org.apache.ignite.events	Contains Event Subscription functionality together with various events emitted by Ignite.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.cluster
org.apache.ignite.internal.cluster.graph
org.apache.ignite.internal.events
org.apache.ignite.internal.management.api
org.apache.ignite.internal.management.cache
org.apache.ignite.internal.management.diagnostic
org.apache.ignite.internal.management.kill
org.apache.ignite.internal.management.tx
org.apache.ignite.internal.management.wal
org.apache.ignite.internal.managers	TODO.
org.apache.ignite.internal.managers.communication	TODO.
org.apache.ignite.internal.managers.deployment	TODO.
org.apache.ignite.internal.managers.discovery	TODO.
org.apache.ignite.internal.managers.encryption	Encryption manager classes.
org.apache.ignite.internal.managers.eventstorage	TODO.
org.apache.ignite.internal.managers.failover	TODO.
org.apache.ignite.internal.managers.loadbalancer	TODO.
org.apache.ignite.internal.processors	Package with Apache Ignite internal Processors.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.authentication
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.affinity
org.apache.ignite.internal.processors.cache.binary	Implementation of binary processor.
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.atomic
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
org.apache.ignite.internal.processors.cache.distributed.dht.topology
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.distributed.near.consistency
org.apache.ignite.internal.processors.cache.persistence.snapshot
org.apache.ignite.internal.processors.cache.persistence.wal.reader
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cache.verify
org.apache.ignite.internal.processors.cluster
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.job	TODO.
org.apache.ignite.internal.processors.metastorage.persistence
org.apache.ignite.internal.processors.nodevalidation
org.apache.ignite.internal.processors.platform
org.apache.ignite.internal.processors.platform.cache.affinity
org.apache.ignite.internal.processors.platform.client.cluster
org.apache.ignite.internal.processors.platform.cluster
org.apache.ignite.internal.processors.platform.compute
org.apache.ignite.internal.processors.plugin
org.apache.ignite.internal.processors.query
org.apache.ignite.internal.processors.query.schema
org.apache.ignite.internal.processors.security
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.processors.session	Session processing package to guarantee reuse of same session object on the same node.
org.apache.ignite.internal.processors.task	TODO.
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.future	Future related classes.
org.apache.ignite.internal.util.lang
org.apache.ignite.internal.util.lang.gridfunc	Contains utilities classes for GridFunc.
org.apache.ignite.internal.util.nio	NIO server interfaces and common utility classes for NIO.
org.apache.ignite.internal.visor
org.apache.ignite.internal.visor.util
org.apache.ignite.platform.dotnet	Contains .Net platform-related classes.
org.apache.ignite.plugin	Contains plugins management API.
org.apache.ignite.services	Contains main Managed Services APIs.
org.apache.ignite.spi	Contains common classes and interfaces for SPI implementations.
org.apache.ignite.spi.communication	Contains APIs for grid communication SPI.
org.apache.ignite.spi.communication.tcp	Contains default TCP/IP-based implementation for communication SPI.
org.apache.ignite.spi.communication.tcp.internal	Contains connection health-checkers for TCP/IP-based implementation of communication SPI.
org.apache.ignite.spi.discovery	Contains APIs for topology manager SPI.
org.apache.ignite.spi.discovery.isolated	Contains implementation of special "isolated" mode for single-node cluster.
org.apache.ignite.spi.discovery.tcp	Contains default TCP/IP implementation for discovery SPI.
org.apache.ignite.spi.discovery.tcp.internal	Contains internal implementation.
org.apache.ignite.spi.discovery.tcp.messages	Contains implementation messages.
org.apache.ignite.spi.failover	Contains APIs for failover SPI.
org.apache.ignite.spi.failover.always	Contains default "always" failover SPI.
org.apache.ignite.spi.failover.jobstealing	Contains job stealing failover SPI.
org.apache.ignite.spi.failover.never	Contains "never" failover SPI.
org.apache.ignite.spi.indexing	Contains APIs for indexing SPI.
org.apache.ignite.spi.loadbalancing	Contains APIs for load balancing SPI.
org.apache.ignite.spi.loadbalancing.adaptive	Contains adaptive load balancing SPI.
org.apache.ignite.spi.loadbalancing.roundrobin	Contains default round-robin implementation for load balancing SPI.
org.apache.ignite.spi.loadbalancing.weightedrandom	Contains weighted random-base implementation for load balancing SPI.
org.apache.ignite.spi.systemview.view	Contains SystemView clases that exists in Ignite.
org.apache.ignite.util

Uses of ClusterNode in org.apache.ignite

Methods in org.apache.ignite that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	IgniteCluster.localNode()	Gets local grid node.

Methods in org.apache.ignite that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	IgniteCluster.topology(long topVer)	Gets a topology by version.

Uses of ClusterNode in org.apache.ignite.cache.affinity

Methods in org.apache.ignite.cache.affinity that return ClusterNode

Modifier and Type	Method	Description
@Nullable ClusterNode	Affinity.mapKeyToNode(K key)	This method provides ability to detect to which primary node the given key is mapped.
ClusterNode	Affinity.mapPartitionToNode(int part)	Gets primary node for the given partition.

Methods in org.apache.ignite.cache.affinity that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	AffinityFunction.assignPartitions(AffinityFunctionContext affCtx)	Gets affinity nodes for a partition.
List<ClusterNode>	AffinityFunctionContext.currentTopologySnapshot()	Gets current topology snapshot.
Map<ClusterNode,Collection<K>>	Affinity.mapKeysToNodes(Collection<? extends K> keys)	This method provides ability to detect which keys are mapped to which nodes.
Collection<ClusterNode>	Affinity.mapKeyToPrimaryAndBackups(K key)	Gets primary and backup nodes for the key.
Map<Integer,ClusterNode>	Affinity.mapPartitionsToNodes(Collection<Integer> parts)	Gets primary nodes for the given partitions.
Collection<ClusterNode>	Affinity.mapPartitionToPrimaryAndBackups(int part)	Gets primary and backup nodes for partition.
@Nullable List<ClusterNode>	AffinityFunctionContext.previousAssignment(int part)	Gets affinity assignment for given partition on previous topology version.

Methods in org.apache.ignite.cache.affinity with parameters of type ClusterNode

Modifier and Type	Method	Description
int[]	Affinity.allPartitions(ClusterNode n)	Gets partition ids for which given cluster node has any ownership (either primary or backup).
int[]	Affinity.backupPartitions(ClusterNode n)	Gets partition ids for which given cluster node has backup ownership.
boolean	Affinity.isBackup(ClusterNode n, K key)	Returns true if local node is one of the backup nodes for given key.
boolean	Affinity.isPrimary(ClusterNode n, K key)	Returns true if given node is the primary node for given key.
boolean	Affinity.isPrimaryOrBackup(ClusterNode n, K key)	Returns true if local node is primary or one of the backup nodes
int[]	Affinity.primaryPartitions(ClusterNode n)	Gets partition ids for which the given cluster node has primary ownership.

Uses of ClusterNode in org.apache.ignite.cache.affinity.rendezvous

Methods in org.apache.ignite.cache.affinity.rendezvous that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<ClusterNode>	RendezvousAffinityFunction.assignPartition(int part, List<ClusterNode> nodes, int backups, @Nullable Map<UUID,Collection<ClusterNode>> neighborhoodCache)	Returns collection of nodes (primary first) for specified partition.
List<List<ClusterNode>>	RendezvousAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)	Gets affinity nodes for a partition.
@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>>	RendezvousAffinityFunction.getAffinityBackupFilter()	Gets optional backup filter.
@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>>	RendezvousAffinityFunction.getAffinityBackupFilter()	Gets optional backup filter.
@Nullable IgniteBiPredicate<ClusterNode,ClusterNode>	RendezvousAffinityFunction.getBackupFilter()	Gets optional backup filter.
@Nullable IgniteBiPredicate<ClusterNode,ClusterNode>	RendezvousAffinityFunction.getBackupFilter()	Gets optional backup filter.

Methods in org.apache.ignite.cache.affinity.rendezvous with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	ClusterNodeAttributeAffinityBackupFilter.apply(ClusterNode candidate, List<ClusterNode> previouslySelected)	Defines a predicate which returns true if a node is acceptable for a backup or false otherwise.
boolean	ClusterNodeAttributeColocatedBackupFilter.apply(ClusterNode candidate, List<ClusterNode> previouslySelected)	Defines a predicate which returns true if a node is acceptable for a backup or false otherwise.
Object	RendezvousAffinityFunction.resolveNodeHash(ClusterNode node)	Resolves node hash.

Method parameters in org.apache.ignite.cache.affinity.rendezvous with type arguments of type ClusterNode

Modifier and Type	Method	Description
boolean	ClusterNodeAttributeAffinityBackupFilter.apply(ClusterNode candidate, List<ClusterNode> previouslySelected)	Defines a predicate which returns true if a node is acceptable for a backup or false otherwise.
boolean	ClusterNodeAttributeColocatedBackupFilter.apply(ClusterNode candidate, List<ClusterNode> previouslySelected)	Defines a predicate which returns true if a node is acceptable for a backup or false otherwise.
List<ClusterNode>	RendezvousAffinityFunction.assignPartition(int part, List<ClusterNode> nodes, int backups, @Nullable Map<UUID,Collection<ClusterNode>> neighborhoodCache)	Returns collection of nodes (primary first) for specified partition.
List<ClusterNode>	RendezvousAffinityFunction.assignPartition(int part, List<ClusterNode> nodes, int backups, @Nullable Map<UUID,Collection<ClusterNode>> neighborhoodCache)	Returns collection of nodes (primary first) for specified partition.
RendezvousAffinityFunction	RendezvousAffinityFunction.setAffinityBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)	Sets optional backup filter.
RendezvousAffinityFunction	RendezvousAffinityFunction.setAffinityBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)	Sets optional backup filter.
RendezvousAffinityFunction	RendezvousAffinityFunction.setBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)	Deprecated. Use affinityBackupFilter instead.
RendezvousAffinityFunction	RendezvousAffinityFunction.setBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)	Deprecated. Use affinityBackupFilter instead.

Constructor parameters in org.apache.ignite.cache.affinity.rendezvous with type arguments of type ClusterNode

Constructor	Description
RendezvousAffinityFunction(int parts, @Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)	Initializes optional counts for replicas and backups.
RendezvousAffinityFunction(int parts, @Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)	Initializes optional counts for replicas and backups.

Uses of ClusterNode in org.apache.ignite.client

Methods in org.apache.ignite.client that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	ClientClusterGroup.node()	Gets first node from the list of nodes in this cluster group.
ClusterNode	ClientClusterGroup.node(UUID nid)	Gets a node for given ID from this cluster group.

Methods in org.apache.ignite.client that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	ClientClusterGroup.nodes()	Gets the read-only collection of nodes in this cluster group.

Methods in org.apache.ignite.client with parameters of type ClusterNode

Modifier and Type	Method	Description
ClientClusterGroup	ClientClusterGroup.forHost(ClusterNode node)	Gets cluster group consisting from the nodes in this cluster group residing on the same host (with the same MAC address) as the given node.
ClientClusterGroup	ClientClusterGroup.forNode(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for the given node.
ClientClusterGroup	ClientClusterGroup.forOthers(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for nodes other than the given nodes.

Method parameters in org.apache.ignite.client with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClientClusterGroup	ClientClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)	Creates a cluster group over a given set of nodes.
ClientClusterGroup	ClientClusterGroup.forPredicate(Predicate<ClusterNode> p)	Creates a new cluster group which includes all nodes that pass the given predicate filter.

Uses of ClusterNode in org.apache.ignite.cluster

Methods in org.apache.ignite.cluster that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	ClusterGroup.node()	Gets first node from the list of nodes in this cluster group.
ClusterNode	ClusterGroup.node(UUID nid)	Gets a node for given ID from this cluster group.

Methods in org.apache.ignite.cluster that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	ClusterGroup.nodes()	Gets the read-only collection of nodes in this cluster group.
IgnitePredicate<ClusterNode>	ClusterGroup.predicate()	Gets predicate that defines a subset of nodes for this cluster group.

Methods in org.apache.ignite.cluster with parameters of type ClusterNode

Modifier and Type	Method	Description
ClusterGroup	ClusterGroup.forHost(ClusterNode node)	Gets cluster group consisting from the nodes in this cluster group residing on the same host as the given node.
ClusterGroup	ClusterGroup.forNode(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for the given node.
ClusterGroup	ClusterGroup.forOthers(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for nodes other than the given nodes.

Method parameters in org.apache.ignite.cluster with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterGroup	ClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)	Creates a cluster group over a given set of nodes.
ClusterGroup	ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)	Creates a new cluster group which includes all nodes that pass the given predicate filter.

Uses of ClusterNode in org.apache.ignite.compute

Methods in org.apache.ignite.compute that return ClusterNode

Modifier and Type	Method	Description
@Nullable ClusterNode	ComputeLoadBalancer.getBalancedNode(ComputeJob job, @Nullable Collection<ClusterNode> exclNodes)	Gets the next balanced node according to the underlying load balancing policy.
ClusterNode	ComputeJobResult.getNode()	Gets node this job executed on.

Methods in org.apache.ignite.compute that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	ComputeTask.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	ComputeTaskSplitAdapter.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.

Methods in org.apache.ignite.compute with parameters of type ClusterNode

Modifier and Type	Method	Description
void	ComputeTaskContinuousMapper.send(ComputeJob job, ClusterNode node)	Sends given job to a specific grid node.

Method parameters in org.apache.ignite.compute with type arguments of type ClusterNode

Modifier and Type	Method	Description
@Nullable ClusterNode	ComputeLoadBalancer.getBalancedNode(ComputeJob job, @Nullable Collection<ClusterNode> exclNodes)	Gets the next balanced node according to the underlying load balancing policy.
@NotNull Map<? extends ComputeJob,ClusterNode>	ComputeTask.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	ComputeTaskSplitAdapter.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.
void	ComputeTaskContinuousMapper.send(Map<? extends ComputeJob,ClusterNode> mappedJobs)	Sends collection of grid jobs to assigned nodes.

Uses of ClusterNode in org.apache.ignite.configuration

Fields in org.apache.ignite.configuration with type parameters of type ClusterNode

Modifier and Type	Field	Description
static IgnitePredicate<ClusterNode>	CacheConfiguration.ALL_NODES	Filter that accepts all nodes.

Methods in org.apache.ignite.configuration that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	CommunicationFailureContext.cacheAffinity(String cacheName)
List<List<ClusterNode>>	CommunicationFailureContext.cachePartitionOwners(String cacheName)
IgnitePredicate<ClusterNode>	CacheConfiguration.getNodeFilter()	Gets filter which determines on what nodes the cache should be started.
IgnitePredicate<ClusterNode>	CollectionConfiguration.getNodeFilter()
List<ClusterNode>	CommunicationFailureContext.topologySnapshot()

Methods in org.apache.ignite.configuration with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	CacheConfiguration.IgniteAllNodesPredicate.apply(ClusterNode node)	Predicate body.
boolean	CommunicationFailureContext.connectionAvailable(ClusterNode node1, ClusterNode node2)
void	CommunicationFailureContext.killNode(ClusterNode node)

Method parameters in org.apache.ignite.configuration with type arguments of type ClusterNode

Modifier and Type	Method	Description
CacheConfiguration<K,V>	CacheConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)	Sets filter which determines on what nodes the cache should be started.
CollectionConfiguration	CollectionConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
boolean	TopologyValidator.validate(Collection<ClusterNode> nodes)	Validates topology.

Uses of ClusterNode in org.apache.ignite.events

Methods in org.apache.ignite.events that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	CacheRebalancingEvent.discoveryNode()	Gets shadow of the node that triggered this rebalancing event.
ClusterNode	CacheEvent.eventNode()	Gets node which initiated cache operation or null if that node is not available.
ClusterNode	DiscoveryEvent.eventNode()	Gets node that caused this event to be generated.
ClusterNode	NodeValidationFailedEvent.eventNode()
ClusterNode	Event.node()	Node where event occurred and was recorded
ClusterNode	EventAdapter.node()	Node where event occurred and was recorded
ClusterNode	JobEvent.taskNode()	Get node where parent task of the job has originated.

Methods in org.apache.ignite.events that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Map<ClusterNode,CacheConsistencyViolationEvent.EntryInfo>	CacheConsistencyViolationEvent.EntriesInfo.getMapping()
Collection<ClusterNode>	DiscoveryEvent.topologyNodes()	Gets topology nodes from topology snapshot.

Methods in org.apache.ignite.events with parameters of type ClusterNode

Modifier and Type	Method	Description
void	DiscoveryEvent.eventNode(ClusterNode evtNode)	Sets node this event is referring to.
void	EventAdapter.node(ClusterNode node)	Sets node where even is occurred (i.e. node local to the event).
void	JobEvent.taskNode(ClusterNode taskNode)	Sets node where parent task of the job has originated.

Method parameters in org.apache.ignite.events with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	DiscoveryEvent.topologySnapshot(long topVer, Collection<ClusterNode> topSnapshot)	Sets the topology snapshot.

Constructors in org.apache.ignite.events with parameters of type ClusterNode

Constructor	Description
BaselineChangedEvent(ClusterNode node, String msg, int type, Collection<BaselineNode> baselineNodes)	Creates baseline changed event with given parameters.
BaselineConfigurationChangedEvent(ClusterNode node, String msg, int type, boolean autoAdjustEnabled, long autoAdjustTimeout)	Creates baseline configuration changed event with given parameters.
CacheConsistencyViolationEvent(String cacheName, ClusterNode node, String msg, Map<Object,CacheConsistencyViolationEvent.EntriesInfo> entries, Map<Object,Object> repaired, ReadRepairStrategy strategy)	Creates a new instance of CacheConsistencyViolationEvent.
CacheEvent(String cacheName, ClusterNode node, @Nullable ClusterNode evtNode, String msg, int type, int part, boolean near, Object key, IgniteUuid xid, String txLbl, Object lockId, Object newVal, boolean hasNewVal, Object oldVal, boolean hasOldVal, UUID subjId, String cloClsName, String taskName)	Constructs cache event.
CacheObjectTransformedEvent(ClusterNode node, String msg, int type, byte[] original, byte[] transformed, boolean restore)
CacheQueryExecutedEvent(ClusterNode node, String msg, int type, String qryType, @Nullable String cacheName, @Nullable String clsName, @Nullable String clause, @Nullable IgniteBiPredicate<K,V> scanQryFilter, @Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter, @Nullable Object[] args, @Nullable UUID subjId, @Nullable String taskName)
CacheQueryReadEvent(ClusterNode node, String msg, int type, String qryType, @Nullable String cacheName, @Nullable String clsName, @Nullable String clause, @Nullable IgniteBiPredicate<K,V> scanQryFilter, @Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter, @Nullable Object[] args, @Nullable UUID subjId, @Nullable String taskName, K key, V val, V oldVal, @Nullable Object row)
CacheRebalancingEvent(String cacheName, ClusterNode node, String msg, int type, int part, ClusterNode discoNode, int discoEvtType, long discoTs)	Constructs cache event.
CheckpointEvent(ClusterNode node, String msg, int type, String cpKey)	Creates new checkpoint event with given parameters.
ClusterActivationEvent(ClusterNode node, String msg, int type, Collection<BaselineNode> baselineNodes)	Deprecated. Creates activation event with given parameters.
ClusterStateChangeEvent(ClusterState prevState, ClusterState state, @Nullable Collection<? extends BaselineNode> baselineNodes, ClusterNode node, String msg)
ClusterStateChangeStartedEvent(ClusterState prevState, ClusterState state, ClusterNode node, String msg, UUID subjId)
ClusterTagUpdatedEvent(ClusterNode node, String msg, UUID clusterId, String prevTag, String newTag)
DeploymentEvent(ClusterNode node, String msg, int type)	Creates deployment event with given parameters.
DiscoveryEvent(ClusterNode node, String msg, int type, ClusterNode evtNode)	Creates new discovery event with given parameters.
EventAdapter(ClusterNode node, String msg, int type)	Creates event based with given parameters.
JobEvent(ClusterNode node, String msg, int type)	Creates job event with given parameters.
NodeValidationFailedEvent(ClusterNode node, ClusterNode evtNode, IgniteNodeValidationResult res)	Creates new node validation event with given parameters.
PageReplacementStartedEvent(ClusterNode node, String msg, String dataRegionName)
SnapshotEvent(ClusterNode node, String msg, String snpName, int type)
SqlQueryExecutionEvent(ClusterNode node, String msg, @Nullable String text, @Nullable Object[] args, @Nullable UUID subjId)
TaskEvent(ClusterNode node, String msg, int type, IgniteUuid sesId, String taskName, String taskClsName, boolean internal, @Nullable UUID subjId)	Creates task event with given parameters.
TransactionStateChangedEvent(ClusterNode node, String msg, int type, Transaction tx)
WalSegmentArchivedEvent(@NotNull ClusterNode node, long absWalSegmentIdx, File archiveFile)	Creates WAL segment event
WalSegmentArchivedEvent(@NotNull ClusterNode node, long absWalSegmentIdx, File archiveFile, int evtType)
WalSegmentCompactedEvent(@NotNull ClusterNode node, long absWalSegmentIdx, File archiveFile)	Creates WAL segment compaction event.

Uses of ClusterNode in org.apache.ignite.internal

Methods in org.apache.ignite.internal that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridJobResultImpl.getNode()	Gets node this job executed on.
ClusterNode	GridCachePluginContext.localNode()	Gets local grid node.
ClusterNode	GridPluginContext.localNode()	Gets local grid node.
ClusterNode	IgniteEx.localNode()	Gets local grid node.
ClusterNode	IgniteKernal.localNode()	Gets local grid node.

Methods in org.apache.ignite.internal that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
IgnitePredicate<ClusterNode>	GridJobExecuteRequest.getTopologyPredicate()
@Nullable IgnitePredicate<ClusterNode>	GridTaskSessionImpl.getTopologyPredicate()
Map<org.apache.ignite.internal.CheckCpHistTask.CheckCpHistClosureJob,ClusterNode>	CheckCpHistTask.map(List<ClusterNode> subgrid, Map<UUID,Map<Integer,Set<Integer>>> arg)	This method is called to map or split grid task into multiple grid jobs.
Collection<ClusterNode>	GridPluginContext.nodes()	Gets a collection of all grid nodes.

Methods in org.apache.ignite.internal with parameters of type ClusterNode

Modifier and Type	Method	Description
static boolean	IgniteFeatures.nodeSupports(ClusterNode clusterNode, IgniteFeatures feature)	Checks that feature supported by node.
IgniteInternalFuture	IgniteKernal.sendIoTest(ClusterNode node, byte[] payload, boolean procFromNioThread)
void	GridJobResultImpl.setNode(ClusterNode node)
@Nullable IgniteNodeValidationResult	GridComponent.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridComponent.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridPluginComponent.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridPluginComponent.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Method parameters in org.apache.ignite.internal with type arguments of type ClusterNode

Modifier and Type	Method	Description
static boolean	IgniteFeatures.allNodesSupports(Iterable<ClusterNode> nodes, IgniteFeatures feature)	Checks that feature supported by all nodes.
Map<org.apache.ignite.internal.CheckCpHistTask.CheckCpHistClosureJob,ClusterNode>	CheckCpHistTask.map(List<ClusterNode> subgrid, Map<UUID,Map<Integer,Set<Integer>>> arg)	This method is called to map or split grid task into multiple grid jobs.
IgniteInternalFuture	IgniteKernal.sendIoTest(List<ClusterNode> nodes, byte[] payload, boolean procFromNioThread)
IgniteComputeHandler	IgniteComputeHandler.withProjection(Collection<ClusterNode> prj)
IgniteComputeHandler	IgniteComputeHandler.withProjectionPredicate(IgnitePredicate<ClusterNode> predicate)

Constructors in org.apache.ignite.internal with parameters of type ClusterNode

Constructor	Description
GridJobResultImpl(ComputeJob job, IgniteUuid jobId, ClusterNode node, GridJobSiblingImpl sib)
IgniteNeedReconnectException(ClusterNode node, @Nullable Throwable cause)

Constructor parameters in org.apache.ignite.internal with type arguments of type ClusterNode

Constructor	Description
GridJobExecuteRequest(IgniteUuid sesId, IgniteUuid jobId, String taskName, String userVer, String taskClsName, byte[] jobBytes, ComputeJob job, long startTaskTime, long timeout, @Nullable Collection<UUID> top, @Nullable IgnitePredicate<ClusterNode> topPred, byte[] topPredBytes, byte[] siblingsBytes, Collection<ComputeJobSibling> siblings, byte[] sesAttrsBytes, Map<Object,Object> sesAttrs, byte[] jobAttrsBytes, Map<? extends Serializable,? extends Serializable> jobAttrs, String cpSpi, IgniteUuid clsLdrId, DeploymentMode depMode, boolean dynamicSiblings, Map<UUID,IgniteUuid> ldrParticipants, boolean forceLocDep, boolean sesFullSup, boolean internal, @org.jetbrains.annotations.Nullable int[] cacheIds, int part, @Nullable AffinityTopologyVersion topVer, @Nullable String execName)
GridTaskSessionImpl(UUID taskNodeId, String taskName, @Nullable GridDeployment dep, String taskClsName, IgniteUuid sesId, @Nullable Collection<UUID> top, @Nullable IgnitePredicate<ClusterNode> topPred, long startTime, long endTime, Collection<ComputeJobSibling> siblings, @Nullable Map<Object,Object> attrs, GridKernalContext ctx, boolean fullSup, boolean internal, @Nullable String execName, @Nullable SecurityContext secCtx)	Constructor.

Uses of ClusterNode in org.apache.ignite.internal.cluster

Classes in org.apache.ignite.internal.cluster that implement ClusterNode

Modifier and Type	Class	Description
class	DetachedClusterNode	Representation of cluster node that either isn't currently present in cluster, or semantically detached.

Fields in org.apache.ignite.internal.cluster with type parameters of type ClusterNode

Modifier and Type	Field	Description
static Comparator<ClusterNode>	NodeOrderLegacyComparator.INSTANCE
protected IgnitePredicate<ClusterNode>	ClusterGroupAdapter.p	Cluster group predicate.

Methods in org.apache.ignite.internal.cluster that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	IgniteClusterAsyncImpl.localNode()	Gets local grid node.
ClusterNode	IgniteClusterImpl.localNode()	Gets local grid node.
ClusterNode	ClusterGroupAdapter.node()	Gets first node from the list of nodes in this cluster group.
ClusterNode	ClusterGroupAdapter.node(UUID id)	Gets a node for given ID from this cluster group.
@Nullable ClusterNode	IgniteClusterAsyncImpl.node()	Gets first node from the list of nodes in this cluster group.
@Nullable ClusterNode	IgniteClusterAsyncImpl.node(UUID id)	Gets a node for given ID from this cluster group.

Methods in org.apache.ignite.internal.cluster that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
static Comparator<ClusterNode>	NodeOrderComparator.getInstance()
Collection<ClusterNode>	ClusterGroupAdapter.nodes()	Gets the read-only collection of nodes in this cluster group.
Collection<ClusterNode>	IgniteClusterAsyncImpl.nodes()	Gets the read-only collection of nodes in this cluster group.
IgnitePredicate<ClusterNode>	ClusterGroupAdapter.predicate()	Gets predicate that defines a subset of nodes for this cluster group.
IgnitePredicate<ClusterNode>	IgniteClusterAsyncImpl.predicate()	Gets predicate that defines a subset of nodes for this cluster group.
protected Collection<ClusterNode>	ClusterGroupAdapter.resolveCurrentNodes()
@Nullable Collection<ClusterNode>	IgniteClusterAsyncImpl.topology(long topVer)	Gets a topology by version.
Collection<ClusterNode>	IgniteClusterImpl.topology(long topVer)	Gets a topology by version.

Methods in org.apache.ignite.internal.cluster with parameters of type ClusterNode

Modifier and Type	Method	Description
int	NodeOrderComparator.compare(ClusterNode n1, ClusterNode n2)
int	NodeOrderLegacyComparator.compare(ClusterNode n1, ClusterNode n2)
ClusterGroup	ClusterGroupAdapter.forHost(ClusterNode node)	Gets cluster group consisting from the nodes in this cluster group residing on the same host as the given node.
ClusterGroup	IgniteClusterAsyncImpl.forHost(ClusterNode node)	Gets cluster group consisting from the nodes in this cluster group residing on the same host as the given node.
ClusterGroup	ClusterGroupAdapter.forNode(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for the given node.
ClusterGroup	IgniteClusterAsyncImpl.forNode(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for the given node.
ClusterGroup	ClusterGroupAdapter.forOthers(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for nodes other than the given nodes.
ClusterGroup	IgniteClusterAsyncImpl.forOthers(ClusterNode node, ClusterNode... nodes)	Creates a cluster group for nodes other than the given nodes.

Method parameters in org.apache.ignite.internal.cluster with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterGroup	ClusterGroupAdapter.forNodes(Collection<? extends ClusterNode> nodes)	Creates a cluster group over a given set of nodes.
ClusterGroup	IgniteClusterAsyncImpl.forNodes(Collection<? extends ClusterNode> nodes)	Creates a cluster group over a given set of nodes.
ClusterGroup	ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p)	Creates a new cluster group which includes all nodes that pass the given predicate filter.
ClusterGroup	IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p)	Creates a new cluster group which includes all nodes that pass the given predicate filter.

Constructor parameters in org.apache.ignite.internal.cluster with type arguments of type ClusterNode

Constructor	Description
ClusterGroupAdapter(@Nullable GridKernalContext ctx, @Nullable IgnitePredicate<ClusterNode> p)

Uses of ClusterNode in org.apache.ignite.internal.cluster.graph

Constructor parameters in org.apache.ignite.internal.cluster.graph with type arguments of type ClusterNode

Constructor	Description
ClusterGraph(CommunicationFailureContext ctx, Predicate<ClusterNode> nodeFilterOut)	Constructor.

Uses of ClusterNode in org.apache.ignite.internal.events

Constructors in org.apache.ignite.internal.events with parameters of type ClusterNode

Constructor	Description
ManagementTaskEvent(ClusterNode node, String msg, int type, IgniteUuid sesId, String taskName, String taskClsName, boolean internal, @Nullable UUID subjId, VisorTaskArgument<?> arg)	Creates task event with given parameters.

Uses of ClusterNode in org.apache.ignite.internal.management.api

Methods in org.apache.ignite.internal.management.api with parameters of type ClusterNode

Modifier and Type	Method	Description
static GridClientNode	CommandUtils.clusterToClientNode(ClusterNode n)

Uses of ClusterNode in org.apache.ignite.internal.management.cache

Methods in org.apache.ignite.internal.management.cache that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	ContentionInfo.getNode()

Methods in org.apache.ignite.internal.management.cache that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Map<ClusterNode,Exception>	IdleVerifyResultV2.exceptions()
@NotNull Map<? extends ComputeJob,ClusterNode>	VerifyBackupPartitionsDumpTask.map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	VerifyBackupPartitionsTaskV2.map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)	This method is called to map or split grid task into multiple grid jobs.

Methods in org.apache.ignite.internal.management.cache with parameters of type ClusterNode

Modifier and Type	Method	Description
void	ValidateIndexesTaskResult.addException(ClusterNode clusterNode, Exception exception)	Adds single node job failure.
void	ValidateIndexesTaskResult.addResult(ClusterNode clusterNode, ValidateIndexesJobResult jobResult)	Adds single node job result.
@Nullable ValidateIndexesJobResult	ValidateIndexesTaskResult.jobResult(ClusterNode clusterNode)
void	ContentionInfo.setNode(ClusterNode node)

Method parameters in org.apache.ignite.internal.management.cache with type arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	VerifyBackupPartitionsDumpTask.map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	VerifyBackupPartitionsTaskV2.map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)	This method is called to map or split grid task into multiple grid jobs.

Constructor parameters in org.apache.ignite.internal.management.cache with type arguments of type ClusterNode

Constructor	Description
IdleVerifyResultV2(Map<ClusterNode,Exception> exceptions)

Uses of ClusterNode in org.apache.ignite.internal.management.diagnostic

Methods in org.apache.ignite.internal.management.diagnostic that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@Nullable Map<ClusterNode,Boolean>	ConnectivityResult.getNodeIds()	Get connectivity statuses for a node
protected @Nullable Map<ClusterNode,ConnectivityResult>	ConnectivityTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Map<ClusterNode,PageLocksResult>	PageLocksTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.

Method parameters in org.apache.ignite.internal.management.diagnostic with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	DiagnosticConnectivityCommand.printResult(DiagnosticConnectivityCommandArg arg, Map<ClusterNode,ConnectivityResult> res, Consumer<String> printer)	Prints command result to the user.
void	DiagnosticPagelocksCommand.printResult(DiagnosticPagelocksCommandArg arg, Map<ClusterNode,PageLocksResult> res, Consumer<String> printer)	Prints command result to the user.

Constructor parameters in org.apache.ignite.internal.management.diagnostic with type arguments of type ClusterNode

Constructor	Description
ConnectivityResult(@Nullable Map<ClusterNode,Boolean> nodeStatuses)

Uses of ClusterNode in org.apache.ignite.internal.management.kill

Methods in org.apache.ignite.internal.management.kill that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
protected @Nullable Map<ClusterNode,TxTaskResult>	KillTransactionTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.

Uses of ClusterNode in org.apache.ignite.internal.management.tx

Methods in org.apache.ignite.internal.management.tx that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Map<ClusterNode,TxTaskResult>	TxInfoCommand.execute(@Nullable GridClient cli, @Nullable IgniteClient client, @Nullable Ignite ignite, TxCommand.AbstractTxCommandArg arg0, Consumer<String> printer)	Executes command logic.
protected @Nullable Map<ClusterNode,TxTaskResult>	TxTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
static Map<ClusterNode,TxTaskResult>	TxTask.reduce0(List<ComputeJobResult> results, boolean detailedInfo)

Method parameters in org.apache.ignite.internal.management.tx with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	TxCommand.printResult(TxCommand.AbstractTxCommandArg arg0, Map<ClusterNode,TxTaskResult> res, Consumer<String> printer)	Prints command result to the user.

Uses of ClusterNode in org.apache.ignite.internal.management.wal

Constructors in org.apache.ignite.internal.management.wal with parameters of type ClusterNode

Constructor	Description
ClusterNode(ClusterNode node)	Create data transfer object for baseline node.

Uses of ClusterNode in org.apache.ignite.internal.managers

Methods in org.apache.ignite.internal.managers with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	GridManagerAdapter.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridManagerAdapter.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.managers.communication

Methods in org.apache.ignite.internal.managers.communication with parameters of type ClusterNode

Modifier and Type	Method	Description
void	GridIoManager.sendGeneric(ClusterNode node, Object topic, int topicOrd, Message msg, byte plc)
IgniteInternalFuture<List<IgniteIoTestMessage>>	GridIoManager.sendIoTest(ClusterNode node, byte[] payload, boolean procFromNioThread)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, Message msg, byte plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, Message msg, byte plc, long timeout, boolean skipOnTimeout, IgniteInClosure<IgniteException> ackC)
void	GridIoManager.sendToCustomTopic(ClusterNode node, Object topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc)
void	GridIoManager.sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc, Span span)
void	GridIoManager.sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc, IgniteInClosure<IgniteException> ackC)

Method parameters in org.apache.ignite.internal.managers.communication with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	GridIoManager.runIoTest(long warmup, long duration, int threads, long latencyLimit, int rangesCnt, int payLoadSize, boolean procFromNioThread, List<ClusterNode> nodes)
IgniteInternalFuture	GridIoManager.sendIoTest(List<ClusterNode> nodes, byte[] payload, boolean procFromNioThread)
void	GridIoManager.sendToGridTopic(Collection<? extends ClusterNode> nodes, GridTopic topic, Message msg, byte plc)
void	GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes, Object msg, @Nullable Object topic, boolean ordered, long timeout, boolean async)	Sends a peer deployable user message.

Uses of ClusterNode in org.apache.ignite.internal.managers.deployment

Methods in org.apache.ignite.internal.managers.deployment that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
IgnitePredicate<ClusterNode>	GridDeploymentMetadata.nodeFilter()

Method parameters in org.apache.ignite.internal.managers.deployment with type arguments of type ClusterNode

Modifier and Type	Method	Description
@Nullable GridDeployment	GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode, String rsrcName, String clsName, String userVer, UUID sndNodeId, IgniteUuid clsLdrId, Map<UUID,IgniteUuid> participants, @Nullable IgnitePredicate<ClusterNode> nodeFilter)
void	GridDeploymentMetadata.nodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
void	GridDeploymentManager.undeployTask(String taskName, boolean locUndeploy, Collection<ClusterNode> rmtNodes)

Uses of ClusterNode in org.apache.ignite.internal.managers.discovery

Subinterfaces of ClusterNode in org.apache.ignite.internal.managers.discovery

Modifier and Type	Interface	Description
interface	IgniteClusterNode

Methods in org.apache.ignite.internal.managers.discovery that return ClusterNode

Modifier and Type	Method	Description
@Nullable ClusterNode	GridDiscoveryManager.getAlive(UUID nodeId)
ClusterNode	GridDiscoveryManager.historicalNode(UUID nodeId)	Resolves by ID cluster node which is alive or has recently left the cluster.
ClusterNode	DiscoCache.localNode()
ClusterNode	GridDiscoveryManager.localNode()
@Nullable ClusterNode	DiscoCache.node(UUID id)
@Nullable ClusterNode	GridDiscoveryManager.node(UUID nodeId)
ClusterNode	GridDiscoveryManager.node(AffinityTopologyVersion topVer, UUID id)	Gets node from history for given topology version.
@Nullable ClusterNode	DiscoCache.oldestAliveServerNode()
@Nullable ClusterNode	GridDiscoveryManager.oldestAliveServerNode(AffinityTopologyVersion topVer)
@Nullable ClusterNode	DiscoCache.oldestServerNode()
@Nullable ClusterNode	DiscoCache.serverNodeByOrder(long order)

Methods in org.apache.ignite.internal.managers.discovery that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@Nullable Collection<ClusterNode>	DiscoCache.aliveBaselineNodes()	Returns a collection of live baseline nodes.
Collection<ClusterNode>	DiscoCache.aliveServerNodes()	Gets collection of server nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.aliveServerNodes()
List<ClusterNode>	DiscoCache.allNodes()
Collection<ClusterNode>	GridDiscoveryManager.allNodes()
List<ClusterNode>	DiscoCache.cacheGroupAffinityNodes(int grpId)
Collection<ClusterNode>	GridDiscoveryManager.cacheGroupAffinityNodes(int grpId, AffinityTopologyVersion topVer)	Gets cache nodes for cache with given ID that participate in affinity calculation.
List<ClusterNode>	DiscoCache.cacheNodes(@Nullable String cacheName)	Gets all nodes that have cache with given name.
List<ClusterNode>	DiscoCache.cacheNodes(Integer cacheId)	Gets all nodes that have cache with given ID.
List<ClusterNode>	GridDiscoveryManager.cacheNodes(@Nullable String cacheName, AffinityTopologyVersion topVer)	Gets cache nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.nodes(long topVer)	Gets all nodes for given topology version.
Collection<ClusterNode>	GridDiscoveryManager.nodes(@Nullable Collection<UUID> ids, IgnitePredicate<UUID>... p)	Gets collection of node for given node IDs and predicates.
Collection<ClusterNode>	GridDiscoveryManager.nodes(AffinityTopologyVersion topVer)	Gets all nodes for given topology version.
Collection<ClusterNode>	DiscoCache.remoteAliveNodesWithCaches()	Gets all alive remote nodes that have at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.remoteAliveNodesWithCaches(AffinityTopologyVersion topVer)	Gets cache remote nodes for cache with given name.
List<ClusterNode>	DiscoCache.remoteNodes()
Collection<ClusterNode>	GridDiscoveryManager.remoteNodes()
List<ClusterNode>	DiscoCache.serverNodes()
List<ClusterNode>	GridDiscoveryManager.serverNodes(AffinityTopologyVersion topVer)
Collection<ClusterNode>	GridDiscoveryManager.serverTopologyNodes(long topVer)	Gets server nodes topology by specified version from snapshots history storage.
@Nullable Collection<ClusterNode>	GridDiscoveryManager.topology(long topVer)	Gets topology by specified version from history storage.
Collection<ClusterNode>	GridDiscoveryTopologySnapshot.topologyNodes()	Gets topology nodes from topology snapshot.

Methods in org.apache.ignite.internal.managers.discovery with parameters of type ClusterNode

Modifier and Type	Method	Description
void	GridDiscoveryManager.ackTopology(long topVer, int evtType, ClusterNode evtNode)	Prints the latest topology info into log taking into account logging/verbosity settings.
boolean	GridDiscoveryManager.alive(ClusterNode node)
boolean	DiscoCache.baselineNode(ClusterNode node)
void	IgniteDiscoverySpiInternalListener.beforeJoin(ClusterNode locNode, IgniteLogger log)
default void	IgniteDiscoverySpiInternalListener.beforeReconnect(ClusterNode locNode, IgniteLogger log)
boolean	GridDiscoveryManager.cacheAffinityNode(ClusterNode node, String cacheName)	Checks if node is a data node for the given cache.
boolean	GridDiscoveryManager.cacheClientNode(ClusterNode node, String cacheName)
boolean	GridDiscoveryManager.cacheGroupAffinityNode(ClusterNode node, int grpId)	Checks if node is a data node for the given cache group.
boolean	GridDiscoveryManager.cacheNearNode(ClusterNode node, String cacheName)
boolean	GridDiscoveryManager.cacheNode(ClusterNode node, String cacheName)
void	GridDiscoveryManager.metricsUpdateEvent(DiscoCache discoCache, ClusterNode node)	Adds metrics update event to discovery worker queue.
Map<String,CacheConfiguration>	GridDiscoveryManager.nodePublicCaches(ClusterNode node)
void	CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer, ClusterNode snd, T msg)
void	GridDiscoveryManager.resolveCommunicationError(ClusterNode node, Exception err)
void	IgniteDiscoverySpi.resolveCommunicationFailure(ClusterNode node, Exception err)
void	DiscoCache.updateAlives(ClusterNode rmvd)	Removes left node from alives lists.
protected abstract boolean	DiscoveryMessageResultsCollector.waitForNode(DiscoCache discoCache, ClusterNode node)

Method parameters in org.apache.ignite.internal.managers.discovery with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	GridDiscoveryManager.addCacheGroup(CacheGroupDescriptor grpDesc, IgnitePredicate<ClusterNode> filter, CacheMode cacheMode)
void	GridDiscoveryManager.addLocalNodeInitializedEventListener(IgniteInClosure<ClusterNode> lsnr)	Adds a listener for local node initialized event.

Constructor parameters in org.apache.ignite.internal.managers.discovery with type arguments of type ClusterNode

Constructor	Description
GridDiscoveryTopologySnapshot(long topVer, Collection<ClusterNode> topNodes)	Creates a topology snapshot with given topology version and topology nodes.

Uses of ClusterNode in org.apache.ignite.internal.managers.encryption

Methods in org.apache.ignite.internal.managers.encryption with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	GridEncryptionManager.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.managers.eventstorage

Method parameters in org.apache.ignite.internal.managers.eventstorage with type arguments of type ClusterNode

Modifier and Type	Method	Description
<T extends Event> IgniteInternalFuture<List<T>>	GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p, Collection<? extends ClusterNode> nodes, long timeout)

Uses of ClusterNode in org.apache.ignite.internal.managers.failover

Methods in org.apache.ignite.internal.managers.failover that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridFailoverManager.failover(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, List<ClusterNode> top, int affPartId, @Nullable String affCacheName, @Nullable AffinityTopologyVersion topVer)
ClusterNode	GridFailoverContextImpl.getBalancedNode(List<ClusterNode> top)	Gets the next balanced node for failed job.

Method parameters in org.apache.ignite.internal.managers.failover with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridFailoverManager.failover(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, List<ClusterNode> top, int affPartId, @Nullable String affCacheName, @Nullable AffinityTopologyVersion topVer)
ClusterNode	GridFailoverContextImpl.getBalancedNode(List<ClusterNode> top)	Gets the next balanced node for failed job.

Uses of ClusterNode in org.apache.ignite.internal.managers.loadbalancer

Methods in org.apache.ignite.internal.managers.loadbalancer that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses, List<ClusterNode> top, ComputeJob job)

Method parameters in org.apache.ignite.internal.managers.loadbalancer with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses, List<ClusterNode> top, ComputeJob job)
ComputeLoadBalancer	GridLoadBalancerManager.getLoadBalancer(GridTaskSessionImpl ses, List<ClusterNode> top)

Uses of ClusterNode in org.apache.ignite.internal.processors

Methods in org.apache.ignite.internal.processors with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	GridProcessorAdapter.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridProcessorAdapter.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.processors.affinity

Methods in org.apache.ignite.internal.processors.affinity that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	IdealAffinityAssignment.currentPrimary(int partition)
<K> @Nullable ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key)	Maps single key to a node.
<K> @Nullable ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key, AffinityTopologyVersion topVer)	Maps single key to a node.
@Nullable ClusterNode	GridAffinityProcessor.mapPartitionToNode(String cacheName, int partId, AffinityTopologyVersion topVer)	Maps partition to a node.

Methods in org.apache.ignite.internal.processors.affinity that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	AffinityAssignment.assignment()
List<List<ClusterNode>>	GridAffinityAssignment.assignment()	Deprecated.
List<List<ClusterNode>>	GridAffinityAssignmentV2.assignment()
List<List<ClusterNode>>	HistoryAffinityAssignmentImpl.assignment()
List<List<ClusterNode>>	HistoryAffinityAssignmentShallowCopy.assignment()
List<List<ClusterNode>>	IdealAffinityAssignment.assignment()
List<List<ClusterNode>>	GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer)
List<ClusterNode>	GridAffinityFunctionContextImpl.currentTopologySnapshot()	Gets current topology snapshot.
List<ClusterNode>	AffinityAssignment.get(int part)	Get affinity nodes for partition.
List<ClusterNode>	GridAffinityAssignment.get(int part)	Deprecated. Get affinity nodes for partition.
List<ClusterNode>	GridAffinityAssignmentV2.get(int part)	Get affinity nodes for partition.
List<ClusterNode>	HistoryAffinityAssignmentImpl.get(int part)	Get affinity nodes for partition.
List<ClusterNode>	HistoryAffinityAssignmentShallowCopy.get(int part)	Get affinity nodes for partition.
List<List<ClusterNode>>	AffinityAssignment.idealAssignment()
List<List<ClusterNode>>	GridAffinityAssignment.idealAssignment()	Deprecated.
List<List<ClusterNode>>	GridAffinityAssignmentV2.idealAssignment()
List<List<ClusterNode>>	HistoryAffinityAssignmentImpl.idealAssignment()
List<List<ClusterNode>>	HistoryAffinityAssignmentShallowCopy.idealAssignment()
@Nullable List<List<ClusterNode>>	GridAffinityAssignmentCache.idealAssignmentRaw()
<K> Map<ClusterNode,Collection<K>>	GridAffinityProcessor.mapKeysToNodes(String cacheName, @Nullable Collection<? extends K> keys)	Maps keys to nodes for given cache.
<K> List<ClusterNode>	GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName, K key, AffinityTopologyVersion topVer)	Map single key to primary and backup nodes.
Set<ClusterNode>	AffinityAssignment.nodes()
Set<ClusterNode>	GridAffinityAssignment.nodes()	Deprecated.
List<ClusterNode>	GridAffinityAssignmentCache.nodes(int part, AffinityTopologyVersion topVer)	Gets affinity nodes for specified partition.
Set<ClusterNode>	GridAffinityAssignmentV2.nodes()
Set<ClusterNode>	HistoryAffinityAssignmentImpl.nodes()
Set<ClusterNode>	HistoryAffinityAssignmentShallowCopy.nodes()
List<List<ClusterNode>>	GridAffinityFunctionContextImpl.prevAssignment()	Gets the previous assignment.
@Nullable List<ClusterNode>	GridAffinityFunctionContextImpl.previousAssignment(int part)	Gets affinity assignment for given partition on previous topology version.
Set<ClusterNode>	AffinityAssignment.primaryPartitionNodes()
Set<ClusterNode>	GridAffinityAssignment.primaryPartitionNodes()	Deprecated.
Set<ClusterNode>	GridAffinityAssignmentV2.primaryPartitionNodes()
Set<ClusterNode>	HistoryAffinityAssignmentImpl.primaryPartitionNodes()
Set<ClusterNode>	HistoryAffinityAssignmentShallowCopy.primaryPartitionNodes()
List<List<ClusterNode>>	GridAffinityAssignmentCache.readyAssignments(AffinityTopologyVersion topVer)

Methods in org.apache.ignite.internal.processors.affinity with parameters of type ClusterNode

Modifier and Type	Method	Description
Set<Integer>	IdealAffinityAssignment.idealPrimaries(ClusterNode clusterNode)

Method parameters in org.apache.ignite.internal.processors.affinity with type arguments of type ClusterNode

Modifier and Type	Method	Description
default Collection<UUID>	AffinityAssignment.assignments2ids(List<ClusterNode> assignmentPart)	Converts List of Cluster Nodes to HashSet of UUIDs wrapped as unmodifiable collection.
static Map<Object,Set<Integer>>	IdealAffinityAssignment.calculatePrimaries(@Nullable List<ClusterNode> nodes, List<List<ClusterNode>> assignment)
static IdealAffinityAssignment	IdealAffinityAssignment.create(AffinityTopologyVersion topVer, @Nullable List<ClusterNode> nodes, List<List<ClusterNode>> assignment)
static IdealAffinityAssignment	IdealAffinityAssignment.create(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment)
static IdealAffinityAssignment	IdealAffinityAssignment.createWithPreservedPrimaries(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment, IdealAffinityAssignment previousAssignment)
void	GridAffinityAssignmentCache.idealAssignment(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment)
void	GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment)	Initializes affinity with given topology version and assignment.
Object	GridAffinityProcessor.similaryAffinityKey(AffinityFunction aff, IgnitePredicate<ClusterNode> nodeFilter, int backups, int parts)

Constructor parameters in org.apache.ignite.internal.processors.affinity with type arguments of type ClusterNode

Constructor	Description
GridAffinityAssignmentV2(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment, List<List<ClusterNode>> idealAssignment)
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot, List<List<ClusterNode>> prevAssignment, DiscoveryEvent discoEvt, @NotNull AffinityTopologyVersion topVer, int backups)

Uses of ClusterNode in org.apache.ignite.internal.processors.authentication

Methods in org.apache.ignite.internal.processors.authentication with parameters of type ClusterNode

Modifier and Type	Method	Description
SecurityContext	IgniteAuthenticationProcessor.authenticateNode(ClusterNode node, SecurityCredentials cred)	Authenticates grid node with it's attributes via underlying Authenticator.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridCacheContext.localNode()
ClusterNode	GridCacheSharedContext.localNode()
@Nullable ClusterNode	GridCacheContext.node(UUID nodeId)
@Nullable ClusterNode	GridCacheSharedContext.node(UUID nodeId)
ClusterNode	WalStateNodeLeaveExchangeTask.node()
static @Nullable ClusterNode	GridCacheUtils.oldest(Collection<ClusterNode> nodes)
static ClusterNode	GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes)
@Nullable ClusterNode	GridCacheAffinityManager.primaryByKey(Object key, AffinityTopologyVersion topVer)
@Nullable ClusterNode	GridCacheAffinityManager.primaryByPartition(int part, AffinityTopologyVersion topVer)
@Nullable ClusterNode	GridCacheContext.selectAffinityNodeBalanced(List<ClusterNode> affNodes, Set<ClusterNode> invalidNodes, int partId, boolean canRemap, boolean forcePrimary)	Determines an affinity node to send get request to.

Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
static Collection<ClusterNode>	GridCacheUtils.affinityNodes(GridCacheContext ctx, AffinityTopologyVersion topVer)	Gets DHT affinity nodes.
List<List<ClusterNode>>	GridCacheAffinityManager.assignments(AffinityTopologyVersion topVer)
static Collection<ClusterNode>	GridCacheUtils.backups(Collection<ClusterNode> nodes)
Collection<ClusterNode>	GridCacheAffinityManager.backupsByKey(Object key, AffinityTopologyVersion topVer)
List<List<ClusterNode>>	GridCacheAffinityManager.idealAssignment()
Collection<ClusterNode>	ExchangeDiscoveryEvents.joinedServerNodes()
Collection<ClusterNode>	ExchangeDiscoveryEvents.leftServerNodes()
Collection<ClusterNode>	GridCacheMvccCandidate.mappedDhtNodes()
Collection<ClusterNode>	GridCacheMvccCandidate.mappedNearNodes()
static Map<UUID,Collection<ClusterNode>>	GridCacheUtils.neighbors(Collection<ClusterNode> topSnapshot)	Builds neighborhood map for all nodes in snapshot.
static Collection<ClusterNode>	GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood, Iterable<ClusterNode> nodes)	Returns neighbors for all nodes.
static Comparator<ClusterNode>	GridCacheUtils.nodeComparator(boolean asc)
IgnitePredicate<ClusterNode>	CacheGroupContext.nodeFilter()
List<ClusterNode>	GridCacheAffinityManager.nodesByKey(Object key, AffinityTopologyVersion topVer)
List<ClusterNode>	GridCacheAffinityManager.nodesByPartition(int part, AffinityTopologyVersion topVer)

Methods in org.apache.ignite.internal.processors.cache with parameters of type ClusterNode

Modifier and Type	Method	Description
void	CacheGroupContext.addRebalanceEvent(int part, int type, ClusterNode discoNode, int discoType, long discoTs)	Adds rebalancing event.
static boolean	GridCacheUtils.affinityNode(ClusterNode node, IgnitePredicate<ClusterNode> filter)
boolean	GridCacheAffinityManager.backupByPartition(ClusterNode n, int part, AffinityTopologyVersion topVer)
static boolean	GridCacheUtils.baselineNode(ClusterNode node, DiscoveryDataClusterState discoveryDataClusterState)
static @Nullable DataStorageConfiguration	GridCacheUtils.extractDataStorage(ClusterNode node, JdkMarshaller marshaller, ClassLoader clsLdr)	Extract and unmarshal data storage configuration from given node.
static @Nullable DataRegionConfiguration	GridCacheUtils.findRemoteDataRegionConfiguration(ClusterNode node, JdkMarshaller marshaller, ClassLoader clsLdr, @Nullable String name)	Finds and returns a data region configuration with the specified name that is configured on remote node.
boolean	GridCacheProcessor.hasCachesReceivedFromJoin(ClusterNode node)
boolean	GridCacheContext.isLocalNode(ClusterNode n)
boolean	ClusterCachesInfo.isMergeConfigSupports(ClusterNode joiningNode)
void	ClusterCachesInfo.onClientCacheChange(ClientCacheChangeDiscoveryMessage msg, ClusterNode node)
boolean	GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg, AffinityTopologyVersion topVer, ClusterNode node)	Callback invoked from discovery thread when discovery custom message is received.
void	ClusterCachesInfo.onDiscoveryEvent(int type, ClusterNode node, AffinityTopologyVersion topVer)	Discovery event callback, executed from discovery thread.
void	GridCacheProcessor.onDiscoveryEvent(int type, @Nullable DiscoveryCustomMessage customMsg, ClusterNode node, AffinityTopologyVersion topVer, DiscoveryDataClusterState state)
boolean	GridCacheAffinityManager.partitionBelongs(ClusterNode node, int part, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheSharedContext.partitionRecoveryFuture(AffinityTopologyVersion topVer, ClusterNode node)	Captures all prepared operations that we need to wait before we able to perform PME-free switch.
boolean	GridCacheAffinityManager.primaryByKey(ClusterNode n, Object key, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primaryByPartition(ClusterNode n, int part, AffinityTopologyVersion topVer)
void	GridCachePartitionExchangeManager.processFullPartitionUpdate(ClusterNode node, GridDhtPartitionsFullMessage msg)
void	GridCacheMvccCandidate.removeMappedNode(ClusterNode node)
void	GridCacheIoManager.send(ClusterNode node, GridCacheMessage msg, byte plc)	Sends communication message.
void	GridCacheIoManager.sendOrderedMessage(ClusterNode node, Object topic, GridCacheMessage msg, byte plc, long timeout)
@Nullable IgniteNodeValidationResult	GridCacheProcessor.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridCacheProcessor.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Method parameters in org.apache.ignite.internal.processors.cache with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	CacheAffinitySharedManager.addToWaitGroup(int grpId, int part, AffinityTopologyVersion topVer, List<ClusterNode> assignment)	Adds group partition to wait list.
static boolean	GridCacheUtils.affinityNode(ClusterNode node, IgnitePredicate<ClusterNode> filter)
static Collection<ClusterNode>	GridCacheUtils.backups(Collection<ClusterNode> nodes)
void	GridCacheContext.dhtMap(UUID nearNodeId, AffinityTopologyVersion topVer, GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, @Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
void	GridCacheContext.dhtMap(GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
static boolean	GridCacheUtils.isInMemoryCluster(Collection<ClusterNode> nodes, JdkMarshaller marshaller, ClassLoader clsLdr)
void	GridCacheMvccCandidate.mappedNodeIds(Collection<ClusterNode> mappedDhtNodes, Collection<ClusterNode> mappedNearNodes)
static Map<UUID,Collection<ClusterNode>>	GridCacheUtils.neighbors(Collection<ClusterNode> topSnapshot)	Builds neighborhood map for all nodes in snapshot.
static Collection<ClusterNode>	GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood, Iterable<ClusterNode> nodes)	Returns neighbors for all nodes.
static Collection<ClusterNode>	GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood, Iterable<ClusterNode> nodes)	Returns neighbors for all nodes.
static @Nullable ClusterNode	GridCacheUtils.oldest(Collection<ClusterNode> nodes)
static ClusterNode	GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes)
@Nullable ClusterNode	GridCacheContext.selectAffinityNodeBalanced(List<ClusterNode> affNodes, Set<ClusterNode> invalidNodes, int partId, boolean canRemap, boolean forcePrimary)	Determines an affinity node to send get request to.
@Nullable ClusterNode	GridCacheContext.selectAffinityNodeBalanced(List<ClusterNode> affNodes, Set<ClusterNode> invalidNodes, int partId, boolean canRemap, boolean forcePrimary)	Determines an affinity node to send get request to.

Constructors in org.apache.ignite.internal.processors.cache with parameters of type ClusterNode

Constructor	Description
DynamicCacheChangeFailureMessage(ClusterNode locNode, GridDhtPartitionExchangeId exchId, IgniteCheckedException cause, Collection<String> cacheNames)	Creates new DynamicCacheChangeFailureMessage instance.
WalStateNodeLeaveExchangeTask(SecurityContext secCtx, ClusterNode node)	Constructor.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.affinity

Methods in org.apache.ignite.internal.processors.cache.affinity that return ClusterNode

Modifier and Type	Method	Description
@Nullable ClusterNode	GridCacheAffinityImpl.mapKeyToNode(K key)	This method provides ability to detect to which primary node the given key is mapped.
@Nullable ClusterNode	GridCacheAffinityProxy.mapKeyToNode(K key)	This method provides ability to detect to which primary node the given key is mapped.
ClusterNode	GridCacheAffinityImpl.mapPartitionToNode(int part)	Gets primary node for the given partition.
ClusterNode	GridCacheAffinityProxy.mapPartitionToNode(int part)	Gets primary node for the given partition.

Methods in org.apache.ignite.internal.processors.cache.affinity that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Map<ClusterNode,Collection<K>>	GridCacheAffinityImpl.mapKeysToNodes(@Nullable Collection<? extends K> keys)	This method provides ability to detect which keys are mapped to which nodes.
Map<ClusterNode,Collection<K>>	GridCacheAffinityProxy.mapKeysToNodes(@Nullable Collection<? extends K> keys)	This method provides ability to detect which keys are mapped to which nodes.
Collection<ClusterNode>	GridCacheAffinityImpl.mapKeyToPrimaryAndBackups(K key)	Gets primary and backup nodes for the key.
Collection<ClusterNode>	GridCacheAffinityProxy.mapKeyToPrimaryAndBackups(K key)	Gets primary and backup nodes for the key.
Map<Integer,ClusterNode>	GridCacheAffinityImpl.mapPartitionsToNodes(Collection<Integer> parts)	Gets primary nodes for the given partitions.
Map<Integer,ClusterNode>	GridCacheAffinityProxy.mapPartitionsToNodes(Collection<Integer> parts)	Gets primary nodes for the given partitions.
Collection<ClusterNode>	GridCacheAffinityImpl.mapPartitionToPrimaryAndBackups(int part)	Gets primary and backup nodes for partition.
Collection<ClusterNode>	GridCacheAffinityProxy.mapPartitionToPrimaryAndBackups(int part)	Gets primary and backup nodes for partition.

Methods in org.apache.ignite.internal.processors.cache.affinity with parameters of type ClusterNode

Modifier and Type	Method	Description
int[]	GridCacheAffinityImpl.allPartitions(ClusterNode n)	Gets partition ids for which given cluster node has any ownership (either primary or backup).
int[]	GridCacheAffinityProxy.allPartitions(ClusterNode n)	Gets partition ids for which given cluster node has any ownership (either primary or backup).
int[]	GridCacheAffinityImpl.backupPartitions(ClusterNode n)	Gets partition ids for which given cluster node has backup ownership.
int[]	GridCacheAffinityProxy.backupPartitions(ClusterNode n)	Gets partition ids for which given cluster node has backup ownership.
boolean	GridCacheAffinityImpl.isBackup(ClusterNode n, K key)	Returns true if local node is one of the backup nodes for given key.
boolean	GridCacheAffinityProxy.isBackup(ClusterNode n, K key)	Returns true if local node is one of the backup nodes for given key.
boolean	GridCacheAffinityImpl.isPrimary(ClusterNode n, K key)	Returns true if given node is the primary node for given key.
boolean	GridCacheAffinityProxy.isPrimary(ClusterNode n, K key)	Returns true if given node is the primary node for given key.
boolean	GridCacheAffinityImpl.isPrimaryOrBackup(ClusterNode n, K key)	Returns true if local node is primary or one of the backup nodes
boolean	GridCacheAffinityProxy.isPrimaryOrBackup(ClusterNode n, K key)	Returns true if local node is primary or one of the backup nodes
int[]	GridCacheAffinityImpl.primaryPartitions(ClusterNode n)	Gets partition ids for which the given cluster node has primary ownership.
int[]	GridCacheAffinityProxy.primaryPartitions(ClusterNode n)	Gets partition ids for which the given cluster node has primary ownership.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.binary

Methods in org.apache.ignite.internal.processors.cache.binary with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	CacheObjectBinaryProcessorImpl.validateNode(ClusterNode rmtNode, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed

Methods in org.apache.ignite.internal.processors.cache.distributed that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridDistributedTxMapping.primary()

Constructors in org.apache.ignite.internal.processors.cache.distributed with parameters of type ClusterNode

Constructor	Description
GridDistributedTxMapping(ClusterNode primary)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed.dht

Fields in org.apache.ignite.internal.processors.cache.distributed.dht declared as ClusterNode

Modifier and Type	Field	Description
protected ClusterNode	CacheDistributedGetFutureAdapter.AbstractMiniFuture.node	Mapped node.

Fields in org.apache.ignite.internal.processors.cache.distributed.dht with type parameters of type ClusterNode

Modifier and Type	Field	Description
protected Map<AffinityTopologyVersion,Map<Integer,Set<ClusterNode>>>	CacheDistributedGetFutureAdapter.invalidNodes

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridPartitionedGetFuture.affNode()	Explicit predefined single mapping (backup or primary).
ClusterNode	CacheDistributedGetFutureAdapter.AbstractMiniFuture.node()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	GridDhtAffinityAssignmentResponse.affinityAssignment(DiscoCache discoCache)
protected Set<ClusterNode>	CacheDistributedGetFutureAdapter.getInvalidNodes(int part, AffinityTopologyVersion topVer)
protected Set<ClusterNode>	GridPartitionedSingleGetFuture.getInvalidNodes()
List<List<ClusterNode>>	GridDhtAffinityAssignmentResponse.idealAffinityAssignment(DiscoCache discoCache)

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type ClusterNode

Modifier and Type	Method	Description
protected void	CacheDistributedGetFutureAdapter.addNodeAsInvalid(ClusterNode node, int part, AffinityTopologyVersion topVer)
protected boolean	CacheDistributedGetFutureAdapter.checkRetryPermits(KeyCacheObject key, ClusterNode node, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping)
IgniteInternalFuture<GridNearLockResponse>	GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx, ClusterNode nearNode, GridNearLockRequest req)
protected abstract void	GridDhtCacheAdapter.MessageHandler.onMessage(ClusterNode node, M msg)
protected void	GridDhtCacheAdapter.processForceKeyResponse(ClusterNode node, GridDhtForceKeysResponse msg)
protected void	GridDhtCacheAdapter.processForceKeysRequest(ClusterNode node, GridDhtForceKeysRequest msg)
void	GridDhtCacheEntry.removeMapping(GridCacheVersion ver, ClusterNode mappedNode)

Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	GridDhtTxMapping.addMapping(List<ClusterNode> nodes)	Adds information about next mapping.
protected boolean	CacheDistributedGetFutureAdapter.checkRetryPermits(KeyCacheObject key, ClusterNode node, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping)
void	GridDhtAffinityAssignmentResponse.idealAffinityAssignment(List<List<ClusterNode>> idealAffAssignment)
protected abstract void	CacheDistributedGetFutureAdapter.map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)
protected void	GridPartitionedGetFuture.map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)
@Nullable GridCacheMvccCandidate	GridDhtCacheEntry.mappings(GridCacheVersion ver, Collection<ClusterNode> dhtNodeIds, Collection<ClusterNode> nearNodeIds)	Sets mappings into entry.
protected GridDhtTopologyFutureAdapter.CacheGroupValidation	GridDhtTopologyFutureAdapter.validateCacheGroup(CacheGroupContext grp, Collection<ClusterNode> topNodes)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type ClusterNode

Constructor	Description
AbstractMiniFuture(ClusterNode node, LinkedHashMap<KeyCacheObject,Boolean> keys, AffinityTopologyVersion topVer)
GridPartitionedGetFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, String taskName, boolean deserializeBinary, boolean recovery, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, @Nullable String txLbl, ClusterNode affNode)

Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type ClusterNode

Constructor	Description
GridDhtAffinityAssignmentResponse(long futId, int grpId, @NotNull AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with type arguments of type ClusterNode

Modifier and Type	Method	Description
protected abstract void	GridDhtAtomicAbstractUpdateFuture.addDhtKey(KeyCacheObject key, List<ClusterNode> dhtNodes)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridDhtPartitionExchangeId.eventNode()
ClusterNode	GridDhtPreloaderAssignments.supplier(int part)	Gets a supplier node for a partition.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder, DiscoCache discoCache)
@Nullable List<List<ClusterNode>>	CacheGroupAffinityMessage.createIdealAssignments(Map<Long,ClusterNode> nodesByOrder, DiscoCache discoCache)
static List<ClusterNode>	CacheGroupAffinityMessage.toNodes(GridLongList assign, Map<Long,ClusterNode> nodesByOrder, DiscoCache discoCache)

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	GridDhtPartitionsExchangeFuture.addOrMergeDelayedFullMessage(ClusterNode node, GridDhtPartitionsFullMessage fullMsg)	Add or merge updates received from coordinator while exchange in progress.
boolean	GridDhtPartitionsExchangeFuture.fastReplyOnSingleMessage(ClusterNode node, GridDhtPartitionsSingleMessage msg)	Tries to fast reply with GridDhtPartitionsFullMessage on received single message in case of exchange future has already completed.
void	GridDhtPartitionsExchangeFuture.forceClientReconnect(ClusterNode node, GridDhtPartitionsSingleMessage msg)	Method is called on coordinator in situation when initial ExchangeFuture created on client join event was preempted from exchange history because of IGNITE_EXCHANGE_HISTORY_SIZE property.
void	GridDhtPartitionsExchangeFuture.onAffinityChangeMessage(ClusterNode node, CacheAffinityChangeMessage msg)	Affinity change message callback, processed from the same thread as GridDhtPartitionsExchangeFuture.onNodeLeft(org.apache.ignite.cluster.ClusterNode).
void	GridDhtPartitionsExchangeFuture.onDynamicCacheChangeFail(ClusterNode node, DynamicCacheChangeFailureMessage msg)	Cache change failure message callback, processed from the discovery thread.
void	InitNewCoordinatorFuture.onMessage(ClusterNode node, GridDhtPartitionsSingleMessage msg)
void	GridDhtPartitionsExchangeFuture.onNodeLeft(ClusterNode node)	Node left callback, processed from the same thread as GridDhtPartitionsExchangeFuture.onAffinityChangeMessage(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.internal.processors.cache.CacheAffinityChangeMessage).
void	GridDhtPartitionsExchangeFuture.onReceiveFullMessage(ClusterNode node, GridDhtPartitionsFullMessage msg)
void	GridDhtPartitionsExchangeFuture.onReceivePartitionRequest(ClusterNode node, GridDhtPartitionsSingleRequest msg)
void	GridDhtPartitionsExchangeFuture.onReceiveSingleMessage(ClusterNode node, GridDhtPartitionsSingleMessage msg)	Processing of received single message.

Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with type arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder, DiscoCache discoCache)
@Nullable List<List<ClusterNode>>	CacheGroupAffinityMessage.createIdealAssignments(Map<Long,ClusterNode> nodesByOrder, DiscoCache discoCache)
static List<ClusterNode>	CacheGroupAffinityMessage.toNodes(GridLongList assign, Map<Long,ClusterNode> nodesByOrder, DiscoCache discoCache)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed.dht.topology

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	GridClientPartitionTopology.allOwners()
List<List<ClusterNode>>	GridDhtPartitionTopology.allOwners()
List<List<ClusterNode>>	GridDhtPartitionTopologyImpl.allOwners()
List<ClusterNode>	GridClientPartitionTopology.moving(int p)
List<ClusterNode>	GridDhtPartitionTopology.moving(int p)
List<ClusterNode>	GridDhtPartitionTopologyImpl.moving(int p)
@Nullable List<ClusterNode>	GridClientPartitionTopology.nodes(int p, AffinityAssignment affAssignment, List<ClusterNode> affNodes)
List<ClusterNode>	GridClientPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
@Nullable List<ClusterNode>	GridDhtPartitionTopology.nodes(int p, AffinityAssignment affAssignment, List<ClusterNode> affNodes)
List<ClusterNode>	GridDhtPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
@Nullable List<ClusterNode>	GridDhtPartitionTopologyImpl.nodes(int p, AffinityAssignment affAssignment, List<ClusterNode> affNodes)
List<ClusterNode>	GridDhtPartitionTopologyImpl.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridClientPartitionTopology.owners(int p)
List<ClusterNode>	GridClientPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopologyImpl.owners(int p)
List<ClusterNode>	GridDhtPartitionTopologyImpl.owners(int p, AffinityTopologyVersion topVer)

Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.topology with type arguments of type ClusterNode

Modifier and Type	Method	Description
@Nullable List<ClusterNode>	GridClientPartitionTopology.nodes(int p, AffinityAssignment affAssignment, List<ClusterNode> affNodes)
@Nullable List<ClusterNode>	GridDhtPartitionTopology.nodes(int p, AffinityAssignment affAssignment, List<ClusterNode> affNodes)
@Nullable List<ClusterNode>	GridDhtPartitionTopologyImpl.nodes(int p, AffinityAssignment affAssignment, List<ClusterNode> affNodes)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridNearLockMapping.node()

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type ClusterNode

Modifier and Type	Method	Description
void	GridNearTxLocal.addKeyMapping(IgniteTxKey key, ClusterNode node)	Adds key mapping to dht mapping.

Method parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type ClusterNode

Modifier and Type	Method	Description
protected void	GridNearGetFuture.map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type ClusterNode

Constructor	Description
GridNearLockMapping(ClusterNode node, KeyCacheObject firstKey)	Creates near lock mapping for specified node and key.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.distributed.near.consistency

Fields in org.apache.ignite.internal.processors.cache.distributed.near.consistency with type parameters of type ClusterNode

Modifier and Type	Field	Description
protected Map<ClusterNode,GridPartitionedGetFuture<KeyCacheObject,EntryGetResult>>	GridNearReadRepairAbstractFuture.futs	Affinity node's get futures.
protected Map<KeyCacheObject,ClusterNode>	GridNearReadRepairAbstractFuture.primaries	Primaries per key.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.persistence.snapshot

Fields in org.apache.ignite.internal.processors.cache.persistence.snapshot with type parameters of type ClusterNode

Modifier and Type	Field	Description
protected Map<ClusterNode,List<SnapshotMetadata>>	AbstractSnapshotVerificationTask.metas	Map of snapshot metadata information found on each cluster node.

Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	SnapshotHandlerContext.localNode()
ClusterNode	SnapshotHandlerResult.node()

Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Map<ClusterNode,List<SnapshotMetadata>>	SnapshotPartitionsVerifyTaskArg.clusterMetadata()
Map<ClusterNode,Exception>	IgniteSnapshotVerifyException.exceptions()
Map<ClusterNode,Exception>	SnapshotMetadataVerificationTaskResult.exceptions()
Map<ClusterNode,Exception>	SnapshotPartitionsVerifyTaskResult.exceptions()
Map<ComputeJob,ClusterNode>	AbstractSnapshotVerificationTask.map(List<ClusterNode> subgrid, SnapshotPartitionsVerifyTaskArg arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	SnapshotMetadataVerificationTask.map(List<ClusterNode> subgrid, SnapshotMetadataVerificationTaskArg arg)	This method is called to map or split grid task into multiple grid jobs.
Map<ClusterNode,List<SnapshotMetadata>>	SnapshotMetadataVerificationTaskResult.meta()
Map<ClusterNode,List<SnapshotMetadata>>	SnapshotPartitionsVerifyTaskResult.metas()

Method parameters in org.apache.ignite.internal.processors.cache.persistence.snapshot with type arguments of type ClusterNode

Modifier and Type	Method	Description
Map<ComputeJob,ClusterNode>	AbstractSnapshotVerificationTask.map(List<ClusterNode> subgrid, SnapshotPartitionsVerifyTaskArg arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	SnapshotMetadataVerificationTask.map(List<ClusterNode> subgrid, SnapshotMetadataVerificationTaskArg arg)	This method is called to map or split grid task into multiple grid jobs.

Constructors in org.apache.ignite.internal.processors.cache.persistence.snapshot with parameters of type ClusterNode

Constructor	Description
SnapshotHandlerContext(SnapshotMetadata metadata, @Nullable Collection<String> grps, ClusterNode locNode, File snpDir, boolean streamerWrn, boolean check)
SnapshotHandlerResult(T data, @Nullable Exception err, ClusterNode node)

Constructor parameters in org.apache.ignite.internal.processors.cache.persistence.snapshot with type arguments of type ClusterNode

Constructor	Description
IgniteSnapshotVerifyException(Map<ClusterNode,? extends Exception> map)
SnapshotMetadataVerificationTaskResult(Map<ClusterNode,List<SnapshotMetadata>> meta, Map<ClusterNode,Exception> exceptions)
SnapshotPartitionsVerifyTaskArg(@Nullable Collection<String> grpNames, Map<ClusterNode,List<SnapshotMetadata>> clusterMetas, @Nullable String snpPath, int incIdx, boolean check)
SnapshotPartitionsVerifyTaskResult(Map<ClusterNode,List<SnapshotMetadata>> metas, @Nullable IdleVerifyResultV2 idleRes)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.persistence.wal.reader

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	StandaloneNoopDiscoverySpi.getLocalNode()	Gets local node.
@Nullable ClusterNode	StandaloneNoopDiscoverySpi.getNode(UUID nodeId)	Gets node by ID.
ClusterNode	StandaloneSpiContext.localNode()	Gets local grid node.
@Nullable ClusterNode	StandaloneSpiContext.node(UUID nodeId)	Gets a node instance based on its ID.

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	StandaloneNoopDiscoverySpi.getRemoteNodes()	Gets collection of remote nodes in grid or empty collection if no remote nodes found.
Collection<ClusterNode>	StandaloneSpiContext.nodes()	Gets a collection of all grid nodes.
Collection<ClusterNode>	StandaloneSpiContext.remoteNodes()	Gets a collection of remote grid nodes.

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader with parameters of type ClusterNode

Modifier and Type	Method	Description
void	StandaloneSpiContext.resolveCommunicationFailure(ClusterNode node, Exception err)
void	StandaloneSpiContext.send(ClusterNode node, Serializable msg, String topic)	Sends a message to a remote node.
void	StandaloneNoopCommunicationSpi.sendMessage(ClusterNode destNode, Serializable msg)	Sends given message to destination node.
@Nullable IgniteNodeValidationResult	StandaloneSpiContext.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	StandaloneSpiContext.validateNode(ClusterNode node, DiscoveryDataBag discoData)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.query

Method parameters in org.apache.ignite.internal.processors.cache.query with type arguments of type ClusterNode

Modifier and Type	Method	Description
CacheQueryFuture<?>	GridCacheDistributedQueryManager.queryDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes)	Executes distributed query.
abstract CacheQueryFuture<?>	GridCacheQueryManager.queryDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes)	Executes distributed query.
CacheQueryFuture<?>	GridCacheDistributedQueryManager.queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes)	Executes distributed fields query.
abstract CacheQueryFuture<?>	GridCacheQueryManager.queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes)	Executes distributed fields query.
GridCloseableIterator	GridCacheDistributedQueryManager.scanQueryDistributed(CacheQuery qry, Collection<ClusterNode> nodes)	Executes distributed SCAN query.
abstract GridCloseableIterator	GridCacheQueryManager.scanQueryDistributed(CacheQuery qry, Collection<ClusterNode> nodes)	Executes distributed SCAN query.

Constructor parameters in org.apache.ignite.internal.processors.cache.query with type arguments of type ClusterNode

Constructor	Description
GridCacheDistributedFieldsQueryFuture(GridCacheContext<?,?> ctx, long reqId, GridCacheQueryBean qry, Collection<ClusterNode> nodes)
GridCacheDistributedQueryFuture(GridCacheContext<K,V> ctx, long reqId, GridCacheQueryBean qry, Collection<ClusterNode> nodes)

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.transactions

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable List<PartitionUpdateCountersMessage>	IgniteTxHandler.filterUpdateCountersForBackupNode(IgniteInternalTx tx, ClusterNode node)
IgniteInternalFuture<Boolean>	IgniteTxManager.recoverLocalTxs(AffinityTopologyVersion topVer, ClusterNode node)	Creates a future that will wait for all transactions with failed primary recovery.
void	IgniteTxManager.sendTransactionMessage(ClusterNode n, GridCacheMessage msg, IgniteInternalTx tx, byte plc)	Sends transaction message after transforming it.

Uses of ClusterNode in org.apache.ignite.internal.processors.cache.verify

Methods in org.apache.ignite.internal.processors.cache.verify that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	CollectConflictPartitionKeysTask.map(List<ClusterNode> subgrid, PartitionKey partKey)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid, Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)	This method is called to map or split grid task into multiple grid jobs.

Method parameters in org.apache.ignite.internal.processors.cache.verify with type arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	CollectConflictPartitionKeysTask.map(List<ClusterNode> subgrid, PartitionKey partKey)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid, Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)	This method is called to map or split grid task into multiple grid jobs.

Uses of ClusterNode in org.apache.ignite.internal.processors.cluster

Methods in org.apache.ignite.internal.processors.cluster that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	BaselineTopology.baselineNode(Object consId)

Methods in org.apache.ignite.internal.processors.cluster that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<ClusterNode>	BaselineTopology.createBaselineView(Collection<ClusterNode> aliveNodes, @Nullable IgnitePredicate<ClusterNode> nodeFilter)

Methods in org.apache.ignite.internal.processors.cluster with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable ChangeGlobalStateFinishMessage	GridClusterStateProcessor.onNodeLeft(ClusterNode node)
@Nullable ChangeGlobalStateFinishMessage	IGridClusterStateProcessor.onNodeLeft(ClusterNode node)
@Nullable IgniteNodeValidationResult	GridClusterStateProcessor.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	GridClusterStateProcessor.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Method parameters in org.apache.ignite.internal.processors.cluster with type arguments of type ClusterNode

Modifier and Type	Method	Description
boolean	GridClusterStateProcessor.autoAdjustInMemoryClusterState(UUID nodeId, Collection<ClusterNode> topSnapshot, DiscoCache discoCache, long topVer, int minorTopVer)	Update baseline locally if cluster is not persistent and baseline autoadjustment is enabled with zero timeout.
List<ClusterNode>	BaselineTopology.createBaselineView(Collection<ClusterNode> aliveNodes, @Nullable IgnitePredicate<ClusterNode> nodeFilter)
List<ClusterNode>	BaselineTopology.createBaselineView(Collection<ClusterNode> aliveNodes, @Nullable IgnitePredicate<ClusterNode> nodeFilter)
boolean	BaselineTopology.isSatisfied(@NotNull Collection<ClusterNode> presentedNodes)

Uses of ClusterNode in org.apache.ignite.internal.processors.continuous

Method parameters in org.apache.ignite.internal.processors.continuous with type arguments of type ClusterNode

Modifier and Type	Method	Description
UUID	GridContinuousProcessor.registerStaticRoutine(String cacheName, javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr, CacheEntryEventSerializableFilter rmtFilter, @Nullable IgnitePredicate<ClusterNode> prjPred)	Registers routine info to be sent in discovery data during this node join (to be used for internal queries started from client nodes).
IgniteInternalFuture<UUID>	GridContinuousProcessor.startRoutine(GridContinuousHandler hnd, boolean locOnly, int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgnitePredicate<ClusterNode> prjPred)

Uses of ClusterNode in org.apache.ignite.internal.processors.datastreamer

Methods in org.apache.ignite.internal.processors.datastreamer with parameters of type ClusterNode

Modifier and Type	Method	Description
static byte	DataStreamProcessor.ioPolicy(@Nullable IgniteClosure<ClusterNode,Byte> rslvr, ClusterNode node)	Get IO policy for particular node with provided resolver.

Method parameters in org.apache.ignite.internal.processors.datastreamer with type arguments of type ClusterNode

Modifier and Type	Method	Description
static byte	DataStreamProcessor.ioPolicy(@Nullable IgniteClosure<ClusterNode,Byte> rslvr, ClusterNode node)	Get IO policy for particular node with provided resolver.
void	DataStreamerImpl.ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr)

Uses of ClusterNode in org.apache.ignite.internal.processors.job

Methods in org.apache.ignite.internal.processors.job that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridJobWorker.getTaskNode()

Methods in org.apache.ignite.internal.processors.job with parameters of type ClusterNode

Modifier and Type	Method	Description
void	GridJobProcessor.processJobExecuteRequest(ClusterNode node, GridJobExecuteRequest req)

Uses of ClusterNode in org.apache.ignite.internal.processors.metastorage.persistence

Methods in org.apache.ignite.internal.processors.metastorage.persistence with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	DistributedMetaStorageImpl.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.processors.nodevalidation

Methods in org.apache.ignite.internal.processors.nodevalidation with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	OsDiscoveryNodeValidationProcessor.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.processors.platform

Methods in org.apache.ignite.internal.processors.platform with parameters of type ClusterNode

Modifier and Type	Method	Description
void	PlatformContext.addNode(ClusterNode node)	Sends node info to native platform, if necessary.
void	PlatformContextImpl.addNode(ClusterNode node)	Sends node info to native platform, if necessary.
void	PlatformContext.writeNode(BinaryRawWriterEx writer, ClusterNode node)	Writes a node id to a stream and sends node info to native platform, if necessary.
void	PlatformContextImpl.writeNode(BinaryRawWriterEx writer, ClusterNode node)	Writes a node id to a stream and sends node info to native platform, if necessary.

Method parameters in org.apache.ignite.internal.processors.platform with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	PlatformContext.writeNodes(BinaryRawWriterEx writer, Collection<ClusterNode> nodes)	Writes multiple node ids to a stream and sends node info to native platform, if necessary.
void	PlatformContextImpl.writeNodes(BinaryRawWriterEx writer, Collection<ClusterNode> nodes)	Writes multiple node ids to a stream and sends node info to native platform, if necessary.

Uses of ClusterNode in org.apache.ignite.internal.processors.platform.cache.affinity

Methods in org.apache.ignite.internal.processors.platform.cache.affinity that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	PlatformAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)	Gets affinity nodes for a partition.
static @NotNull List<List<ClusterNode>>	PlatformAffinityUtils.readPartitionAssignment(BinaryRawReader reader, PlatformContext ctx)	Reads the partition assignment.

Method parameters in org.apache.ignite.internal.processors.platform.cache.affinity with type arguments of type ClusterNode

Modifier and Type	Method	Description
static void	PlatformAffinityUtils.writePartitionAssignment(Collection<List<ClusterNode>> partitions, BinaryRawWriterEx writer, PlatformContext ctx)	Writes the partition assignment to a stream.

Uses of ClusterNode in org.apache.ignite.internal.processors.platform.client.cluster

Constructor parameters in org.apache.ignite.internal.processors.platform.client.cluster with type arguments of type ClusterNode

Constructor	Description
ClientClusterGroupGetNodesDetailsResponse(long reqId, Collection<ClusterNode> nodes)	Constructor.

Uses of ClusterNode in org.apache.ignite.internal.processors.platform.cluster

Methods in org.apache.ignite.internal.processors.platform.cluster with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	PlatformClusterNodeFilterImpl.apply(ClusterNode clusterNode)	Predicate body.

Uses of ClusterNode in org.apache.ignite.internal.processors.platform.compute

Methods in org.apache.ignite.internal.processors.platform.compute that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformFullTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.

Method parameters in org.apache.ignite.internal.processors.platform.compute with type arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformFullTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.

Uses of ClusterNode in org.apache.ignite.internal.processors.plugin

Methods in org.apache.ignite.internal.processors.plugin with parameters of type ClusterNode

Modifier and Type	Method	Description
void	CachePluginManager.validateRemotes(CacheConfiguration rmtCfg, ClusterNode rmtNode)	Checks that remote caches has configuration compatible with the local.

Uses of ClusterNode in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query with parameters of type ClusterNode

Modifier and Type	Method	Description
void	GridQueryProcessor.onNodeLeave(ClusterNode node)	Handle node leave.

Uses of ClusterNode in org.apache.ignite.internal.processors.query.schema

Methods in org.apache.ignite.internal.processors.query.schema that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	SchemaNodeLeaveExchangeWorkerTask.node()

Methods in org.apache.ignite.internal.processors.query.schema with parameters of type ClusterNode

Modifier and Type	Method	Description
void	SchemaOperationManager.onNodeLeave(UUID nodeId, ClusterNode curCrd)	Handle node leave event.

Constructors in org.apache.ignite.internal.processors.query.schema with parameters of type ClusterNode

Constructor	Description
SchemaNodeLeaveExchangeWorkerTask(SecurityContext secCtx, ClusterNode node)	Constructor.
SchemaOperationManager(GridKernalContext ctx, GridQueryProcessor qryProc, SchemaOperationWorker worker, @Nullable ClusterNode crd)	Constructor.

Uses of ClusterNode in org.apache.ignite.internal.processors.security

Methods in org.apache.ignite.internal.processors.security with parameters of type ClusterNode

Modifier and Type	Method	Description
static SecurityContext	SecurityUtils.authenticateLocalNode(ClusterNode node, SecurityCredentials cred, DiscoverySpiNodeAuthenticator nodeAuth)	Performs local node authentication.
SecurityContext	GridSecurityProcessor.authenticateNode(ClusterNode node, SecurityCredentials cred)	Authenticates grid node with it's attributes via underlying Authenticator.
SecurityContext	IgniteSecurity.authenticateNode(ClusterNode node, SecurityCredentials cred)	Delegates call to GridSecurityProcessor.authenticateNode(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.plugin.security.SecurityCredentials)
SecurityContext	IgniteSecurityProcessor.authenticateNode(ClusterNode node, SecurityCredentials cred)	Delegates call to GridSecurityProcessor.authenticateNode(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.plugin.security.SecurityCredentials)
SecurityContext	NoOpIgniteSecurityProcessor.authenticateNode(ClusterNode node, SecurityCredentials cred)	Delegates call to GridSecurityProcessor.authenticateNode(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.plugin.security.SecurityCredentials)
static SecurityContext	SecurityUtils.nodeSecurityContext(Marshaller marsh, ClassLoader ldr, ClusterNode node)	Gets the node's security context.
@Nullable IgniteNodeValidationResult	IgniteSecurityProcessor.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	IgniteSecurityProcessor.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	NoOpIgniteSecurityProcessor.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	NoOpIgniteSecurityProcessor.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData discoData)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Uses of ClusterNode in org.apache.ignite.internal.processors.service

Methods in org.apache.ignite.internal.processors.service that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
IgnitePredicate<ClusterNode>	LazyServiceConfiguration.getNodeFilter()	Gets node filter used to filter nodes on which the service will be deployed.

Methods in org.apache.ignite.internal.processors.service with parameters of type ClusterNode

Modifier and Type	Method	Description
@Nullable IgniteNodeValidationResult	IgniteServiceProcessor.validateNode(ClusterNode node, DiscoveryDataBag.JoiningNodeDiscoveryData data)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

Method parameters in org.apache.ignite.internal.processors.service with type arguments of type ClusterNode

Modifier and Type	Method	Description
ServiceConfiguration	LazyServiceConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)	Sets node filter used to filter nodes on which the service will be deployed.

Uses of ClusterNode in org.apache.ignite.internal.processors.session

Method parameters in org.apache.ignite.internal.processors.session with type arguments of type ClusterNode

Modifier and Type	Method	Description
GridTaskSessionImpl	GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId, UUID taskNodeId, String taskName, @Nullable GridDeployment dep, String taskClsName, @Nullable Collection<UUID> top, @Nullable IgnitePredicate<ClusterNode> topPred, long startTime, long endTime, Collection<ComputeJobSibling> siblings, Map<Object,Object> attrs, boolean fullSup, boolean internal, @Nullable String execName, @Nullable SecurityContext secCtx)	Creates task session.

Uses of ClusterNode in org.apache.ignite.internal.processors.task

Methods in org.apache.ignite.internal.processors.task that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	TaskExecutionOptions.projection()
IgnitePredicate<ClusterNode>	TaskExecutionOptions.projectionPredicate()

Method parameters in org.apache.ignite.internal.processors.task with type arguments of type ClusterNode

Modifier and Type	Method	Description
static TaskExecutionOptions	TaskExecutionOptions.options(Collection<ClusterNode> projection)
TaskExecutionOptions	TaskExecutionOptions.withProjection(Collection<ClusterNode> projection)
TaskExecutionOptions	TaskExecutionOptions.withProjectionPredicate(IgnitePredicate<ClusterNode> projectionPredicate)

Uses of ClusterNode in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util that return ClusterNode

Modifier and Type	Method	Description
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)	Gets oldest node out of collection of nodes.
static ClusterNode	IgniteUtils.randomServerNode(GridKernalContext ctx)
static ClusterNode	IgniteUtils.youngest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)	Gets youngest node out of collection of nodes.

Methods in org.apache.ignite.internal.util that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
static IgniteClosure<UUID,ClusterNode>	IgniteUtils.id2Node(GridKernalContext ctx)
static Map<String,Collection<ClusterNode>>	IgniteUtils.neighborhood(Iterable<ClusterNode> nodes)	Groups given nodes by the node's physical computer (host).

Methods in org.apache.ignite.internal.util with parameters of type ClusterNode

Modifier and Type	Method	Description
static String	IgniteUtils.addressesAsString(ClusterNode node)	Returns string representation of node addresses.
static GridCacheAttributes[]	IgniteUtils.cacheAttributes(ClusterNode n)	Gets cache attributes for the node.
static boolean	IgniteUtils.hasNearCache(ClusterNode n, String cacheName)	Checks if given node has near cache enabled for the specified partitioned cache.
static double	IgniteUtils.heapSize(ClusterNode node, int precision)	Gets heap size in GB rounded to specified precision.
static IgniteProductVersion	IgniteUtils.productVersion(ClusterNode node)	Gets node product version based on node attributes.
static boolean	IgniteUtils.sameMacs(ClusterNode loc, ClusterNode rmt)
static String	IgniteUtils.toShortString(ClusterNode n)	Short node representation.
static Collection<InetSocketAddress>	IgniteUtils.toSocketAddresses(ClusterNode node, int port)	Returns the list of resolved socket addresses.

Method parameters in org.apache.ignite.internal.util with type arguments of type ClusterNode

Modifier and Type	Method	Description
static IgniteFuture<Void>	IgniteUtils.broadcastToNodesWithFilterAsync(GridKernalContext kctx, IgniteRunnable job, boolean srvrsOnly, IgnitePredicate<ClusterNode> nodeFilter)	Broadcasts given job to nodes that match filter.
static double	IgniteUtils.heapSize(Iterable<ClusterNode> nodes, int precision)	Gets total heap size in GB rounded to specified precision.
static boolean	IgniteUtils.isOldestNodeVersionAtLeast(IgniteProductVersion ver, Iterable<ClusterNode> nodes)	Check that node Ignite product version is not less then specified.
static Map<String,Collection<ClusterNode>>	IgniteUtils.neighborhood(Iterable<ClusterNode> nodes)	Groups given nodes by the node's physical computer (host).
static Collection<UUID>	IgniteUtils.nodeIds(@Nullable Collection<? extends ClusterNode> nodes)	Converts collection of nodes to collection of node IDs.
static Collection<String>	IgniteUtils.nodes2names(@Nullable Collection<? extends ClusterNode> nodes)	Converts collection of grid nodes to collection of grid names.
static double	IgniteUtils.offheapSize(Iterable<ClusterNode> nodes, int precision)	Gets total offheap size in GB rounded to specified precision.
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)	Gets oldest node out of collection of nodes.
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)	Gets oldest node out of collection of nodes.
static String	IgniteUtils.toShortString(Collection<? extends ClusterNode> ns)	Short node representation.
static ClusterNode	IgniteUtils.youngest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)	Gets youngest node out of collection of nodes.
static ClusterNode	IgniteUtils.youngest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)	Gets youngest node out of collection of nodes.

Uses of ClusterNode in org.apache.ignite.internal.util.future

Methods in org.apache.ignite.internal.util.future that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	IgniteRemoteMapTask.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.

Method parameters in org.apache.ignite.internal.util.future with type arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	IgniteRemoteMapTask.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.

Constructors in org.apache.ignite.internal.util.future with parameters of type ClusterNode

Constructor	Description
IgniteRemoteMapTask(ClusterNode node, ComputeTask<T,R> remoteTask)

Uses of ClusterNode in org.apache.ignite.internal.util.lang

Methods in org.apache.ignite.internal.util.lang with type parameters of type ClusterNode

Modifier and Type	Method	Description
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.localNode(UUID locNodeId)	Gets predicate that evaluates to true only for given local node ID.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.nodeForNodeId(UUID nodeId)	Creates grid node predicate evaluating on the given node ID.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.nodeForNodeIds(@Nullable Collection<UUID> nodeIds)	Creates grid node predicate evaluating on the given node IDs.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.remoteNodes(UUID locNodeId)	Gets predicate that evaluates to false for given local node ID.

Methods in org.apache.ignite.internal.util.lang that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
static IgniteClosure<? super ClusterNode,UUID>	GridFunc.node2id()	Gets closure which converts node to node ID.
static IgnitePredicate<ClusterNode>	GridFunc.nodeForNodes(ClusterNode... nodes)	Creates predicates that evaluates to true for each node in given collection.

Methods in org.apache.ignite.internal.util.lang with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	GridNodePredicate.apply(ClusterNode n)	Predicate body.
static IgnitePredicate<ClusterNode>	GridFunc.nodeForNodes(ClusterNode... nodes)	Creates predicates that evaluates to true for each node in given collection.

Method parameters in org.apache.ignite.internal.util.lang with type arguments of type ClusterNode

Modifier and Type	Method	Description
static Collection<UUID>	GridFunc.nodeIds(@Nullable Collection<? extends ClusterNode> nodes)	Convenient utility method that returns collection of node IDs for a given collection of grid nodes.

Constructors in org.apache.ignite.internal.util.lang with parameters of type ClusterNode

Constructor	Description
GridNodePredicate(@Nullable ClusterNode... nodes)	Creates node predicate that evaluates to true for all provided nodes.

Uses of ClusterNode in org.apache.ignite.internal.util.lang.gridfunc

Classes in org.apache.ignite.internal.util.lang.gridfunc with type parameters of type ClusterNode

Modifier and Type	Class	Description
class	ContainsNodeIdsPredicate<T extends ClusterNode>	Grid node predicate evaluating on the given node IDs.
class	EqualsClusterNodeIdPredicate<T extends ClusterNode>	Creates grid node predicate evaluating on the given node ID.
class	HasEqualIdPredicate<T extends ClusterNode>	ClusterNode has equal id predicate.
class	HasNotEqualIdPredicate<T extends ClusterNode>	ClusterNode node has NOT equal id predicate.

Methods in org.apache.ignite.internal.util.lang.gridfunc with parameters of type ClusterNode

Modifier and Type	Method	Description
UUID	ClusterNodeGetIdClosure.apply(ClusterNode n)	Closure body.
boolean	ContainsNodeIdsPredicate.apply(ClusterNode e)	Predicate body.
boolean	EqualsClusterNodeIdPredicate.apply(ClusterNode e)	Predicate body.

Uses of ClusterNode in org.apache.ignite.internal.util.nio

Methods in org.apache.ignite.internal.util.nio that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	GridNioRecoveryDescriptor.node()

Methods in org.apache.ignite.internal.util.nio with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	GridNioRecoveryDescriptor.nodeAlive(@Nullable ClusterNode node)

Constructors in org.apache.ignite.internal.util.nio with parameters of type ClusterNode

Constructor	Description
GridNioRecoveryDescriptor(boolean pairedConnections, int queueLimit, ClusterNode node, IgniteLogger log)

Uses of ClusterNode in org.apache.ignite.internal.visor

Methods in org.apache.ignite.internal.visor that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	VisorMultiNodeTask.map(List<ClusterNode> subgrid, VisorTaskArgument<A> arg)	This method is called to map or split grid task into multiple grid jobs.
protected Map<? extends ComputeJob,ClusterNode>	VisorMultiNodeTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<A> arg)	Actual map logic.

Method parameters in org.apache.ignite.internal.visor with type arguments of type ClusterNode

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	VisorMultiNodeTask.map(List<ClusterNode> subgrid, VisorTaskArgument<A> arg)	This method is called to map or split grid task into multiple grid jobs.
protected Map<? extends ComputeJob,ClusterNode>	VisorMultiNodeTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<A> arg)	Actual map logic.

Uses of ClusterNode in org.apache.ignite.internal.visor.util

Method parameters in org.apache.ignite.internal.visor.util with type arguments of type ClusterNode

Modifier and Type	Method	Description
static void	VisorTaskUtils.logMapped(@Nullable IgniteLogger log, Class<?> clazz, Collection<ClusterNode> nodes)	Log task mapped.

Uses of ClusterNode in org.apache.ignite.platform.dotnet

Methods in org.apache.ignite.platform.dotnet that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
List<List<ClusterNode>>	PlatformDotNetAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)	Gets affinity nodes for a partition.

Uses of ClusterNode in org.apache.ignite.plugin

Methods in org.apache.ignite.plugin that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	CachePluginContext.localNode()	Gets local grid node.
ClusterNode	PluginContext.localNode()	Gets local grid node.

Methods in org.apache.ignite.plugin that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	PluginContext.nodes()	Gets a collection of all grid nodes.

Methods in org.apache.ignite.plugin with parameters of type ClusterNode

Modifier and Type	Method	Description
void	PluginProvider.validateNewNode(ClusterNode node)	Deprecated. Use PluginProvider.validateNewNode(ClusterNode, Serializable) instead.
default void	PluginProvider.validateNewNode(ClusterNode node, Serializable data)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
void	CachePluginProvider.validateRemote(CacheConfiguration locCfg, CacheConfiguration rmtCfg, ClusterNode rmtNode)	Checks that remote caches has configuration compatible with the local.

Uses of ClusterNode in org.apache.ignite.services

Fields in org.apache.ignite.services with type parameters of type ClusterNode

Modifier and Type	Field	Description
protected IgnitePredicate<ClusterNode>	ServiceConfiguration.nodeFilter	Node filter.

Methods in org.apache.ignite.services that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
IgnitePredicate<ClusterNode>	ServiceConfiguration.getNodeFilter()	Gets node filter used to filter nodes on which the service will be deployed.

Method parameters in org.apache.ignite.services with type arguments of type ClusterNode

Modifier and Type	Method	Description
ServiceConfiguration	ServiceConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)	Sets node filter used to filter nodes on which the service will be deployed.

Uses of ClusterNode in org.apache.ignite.spi

Methods in org.apache.ignite.spi that return ClusterNode

Modifier and Type	Method	Description
protected ClusterNode	IgniteSpiAdapter.getLocalNode()
ClusterNode	IgniteSpiContext.localNode()	Gets local grid node.
@Nullable ClusterNode	IgniteSpiContext.node(UUID nodeId)	Gets a node instance based on its ID.

Methods in org.apache.ignite.spi that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	IgniteSpiContext.nodes()	Gets a collection of all grid nodes.
Collection<ClusterNode>	IgniteSpiContext.remoteNodes()	Gets a collection of remote grid nodes.

Methods in org.apache.ignite.spi with parameters of type ClusterNode

Modifier and Type	Method	Description
protected void	IgniteSpiAdapter.checkConfigurationConsistency0(IgniteSpiContext spiCtx, ClusterNode node, boolean starting)	Method which is called in the end of checkConfigurationConsistency() method.
void	IgniteSpiContext.resolveCommunicationFailure(ClusterNode node, Exception err)
void	IgniteSpiContext.send(ClusterNode node, Serializable msg, String topic)	Sends a message to a remote node.
@Nullable IgniteNodeValidationResult	IgniteSpiContext.validateNode(ClusterNode node)	Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
@Nullable IgniteNodeValidationResult	IgniteSpiContext.validateNode(ClusterNode node, DiscoveryDataBag discoData)

Uses of ClusterNode in org.apache.ignite.spi.communication

Methods in org.apache.ignite.spi.communication with parameters of type ClusterNode

Modifier and Type	Method	Description
void	CommunicationSpi.sendMessage(ClusterNode destNode, T msg)	Sends given message to destination node.

Uses of ClusterNode in org.apache.ignite.spi.communication.tcp

Methods in org.apache.ignite.spi.communication.tcp with parameters of type ClusterNode

Modifier and Type	Method	Description
protected void	TcpCommunicationSpi.checkConfigurationConsistency0(IgniteSpiContext spiCtx, ClusterNode node, boolean starting)	Method which is called in the end of checkConfigurationConsistency() method.
protected GridCommunicationClient	TcpCommunicationSpi.createTcpClient(ClusterNode node, int connIdx)	Establish TCP connection to remote node and returns client.
static boolean	ClientExceptionsUtils.isClientNodeTopologyException(Throwable t, ClusterNode node)	Returns true if the exception relates to cluster topology change that prevents a connection, AND the given node is client.
Collection<InetSocketAddress>	TcpCommunicationSpi.nodeAddresses(ClusterNode node, boolean filterReachableAddrs)
IgniteInternalFuture<Channel>	TcpCommunicationSpi.openChannel(ClusterNode remote, Message initMsg)
protected void	TcpCommunicationSpi.processSessionCreationError(ClusterNode node, Collection<InetSocketAddress> addrs, IgniteCheckedException errs)	Process errors if TCP/IP GridNioSession creation to remote node hasn't been performed.
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg)	Sends given message to destination node.
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg, IgniteInClosure<IgniteException> ackC)	Sends given message to destination node.

Method parameters in org.apache.ignite.spi.communication.tcp with type arguments of type ClusterNode

Modifier and Type	Method	Description
IgniteFuture<BitSet>	TcpCommunicationSpi.checkConnection(List<ClusterNode> nodes)

Uses of ClusterNode in org.apache.ignite.spi.communication.tcp.internal

Methods in org.apache.ignite.spi.communication.tcp.internal with parameters of type ClusterNode

Modifier and Type	Method	Description
void	ConnectionClientPool.addNodeClient(ClusterNode node, int connIdx, GridCommunicationClient addClient)
String	ConnectionClientPool.clientString(GridCommunicationClient client, ClusterNode node)	Returns the string representation of client with protection from null client value.
@Nullable GridCommunicationClient	ConnectionClientPool.createCommunicationClient(ClusterNode node, int connIdx)
GridNioSession	GridNioServerWrapper.createNioSession(ClusterNode node, int connIdx)	Deprecated. Returns the established TCP/IP connection between the current node and remote server.
GridCommunicationClient	GridNioServerWrapper.createTcpClient(ClusterNode node, int connIdx, boolean backwardCompatibility)	Deprecated. Establish TCP connection to remote node and returns client.
static void	CommunicationTcpUtils.failNode(ClusterNode nodeToFail, IgniteSpiContext spiCtx, Throwable err, IgniteLogger log)	Forcibly fails client node.
GridNioRecoveryDescriptor	GridNioServerWrapper.inRecoveryDescriptor(ClusterNode node, ConnectionKey key)	Deprecated.
static Collection<InetSocketAddress>	CommunicationTcpUtils.nodeAddresses(ClusterNode node, boolean filterReachableAddrs, AttributeNames attrs, Supplier<ClusterNode> localNode)
IgniteInternalFuture<Channel>	GridNioServerWrapper.openChannel(ClusterNode remote, Message initMsg)	Deprecated.
void	GridNioServerWrapper.processSessionCreationError(ClusterNode node, Collection<InetSocketAddress> addrs, IgniteCheckedException errs)	Deprecated. Process errors if TCP/IP GridNioSession creation to remote node hasn't been performed.
void	ConnectionRequestor.request(ClusterNode node, int connIdx)	Request opening of TCP connection from node node with index connIdx.
GridCommunicationClient	ConnectionClientPool.reserveClient(ClusterNode node, int connIdx)	Returns existing or just created client to node.
static boolean	CommunicationTcpUtils.usePairedConnections(ClusterNode node, String attributeName)

Method parameters in org.apache.ignite.spi.communication.tcp.internal with type arguments of type ClusterNode

Modifier and Type	Method	Description
static Collection<InetSocketAddress>	CommunicationTcpUtils.nodeAddresses(ClusterNode node, boolean filterReachableAddrs, AttributeNames attrs, Supplier<ClusterNode> localNode)

Constructor parameters in org.apache.ignite.spi.communication.tcp.internal with type arguments of type ClusterNode

Constructor	Description
ClusterStateProvider(Ignite ignite, Supplier<ClusterNode> locNodeSupplier, TcpCommunicationSpi tcpCommSpi, Supplier<Boolean> stoppedSupplier, Supplier<IgniteSpiContext> spiCtxWithoutLatchSupplier, IgniteLogger log, Supplier<Ignite> igniteExSupplier)	Deprecated.
CommunicationWorker(String igniteInstanceName, IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attrs, ConnectionClientPool clientPool, Supplier<FailureProcessor> failureProcessorSupplier, Function<UUID,ClusterNode> nodeGetter, Function<UUID,Boolean> pingNode, Supplier<IgniteExceptionRegistry> eRegistrySupplier, GridNioServerWrapper nioSrvWrapper, WorkersRegistry workersRegistry, String spiName)
ConnectionClientPool(TcpCommunicationConfiguration cfg, AttributeNames attrs, IgniteLogger log, TcpCommunicationMetricsListener metricsLsnr, Supplier<ClusterNode> locNodeSupplier, Function<UUID,ClusterNode> nodeGetter, Supplier<MessageFormatter> msgFormatterSupplier, WorkersRegistry registry, TcpCommunicationSpi tcpCommSpi, ClusterStateProvider clusterStateProvider, GridNioServerWrapper nioSrvWrapper, String igniteInstanceName)
ConnectionClientPool(TcpCommunicationConfiguration cfg, AttributeNames attrs, IgniteLogger log, TcpCommunicationMetricsListener metricsLsnr, Supplier<ClusterNode> locNodeSupplier, Function<UUID,ClusterNode> nodeGetter, Supplier<MessageFormatter> msgFormatterSupplier, WorkersRegistry registry, TcpCommunicationSpi tcpCommSpi, ClusterStateProvider clusterStateProvider, GridNioServerWrapper nioSrvWrapper, String igniteInstanceName)
GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor)	Deprecated.
GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor)	Deprecated.
GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor)	Deprecated.
InboundConnectionHandler(IgniteLogger log, TcpCommunicationConfiguration cfg, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ClusterStateProvider stateProvider, ConnectionClientPool clientPool, CommunicationWorker commWorker, ConnectGateway connectGate, Supplier<FailureProcessor> failureProcessorSupplier, AttributeNames attributeNames, TcpCommunicationMetricsListener metricsLsnr, GridNioServerWrapper nioSrvWrapper, CountDownLatch ctxInitLatch, boolean client, Supplier<Ignite> igniteExSupplier, CommunicationListener<Message> lsnr)
InboundConnectionHandler(IgniteLogger log, TcpCommunicationConfiguration cfg, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ClusterStateProvider stateProvider, ConnectionClientPool clientPool, CommunicationWorker commWorker, ConnectGateway connectGate, Supplier<FailureProcessor> failureProcessorSupplier, AttributeNames attributeNames, TcpCommunicationMetricsListener metricsLsnr, GridNioServerWrapper nioSrvWrapper, CountDownLatch ctxInitLatch, boolean client, Supplier<Ignite> igniteExSupplier, CommunicationListener<Message> lsnr)
TcpCommunicationConnectionCheckFuture(TcpCommunicationSpi spi, IgniteLogger log, GridNioServer nioSrvr, List<ClusterNode> nodes)

Uses of ClusterNode in org.apache.ignite.spi.discovery

Methods in org.apache.ignite.spi.discovery that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	DiscoverySpi.getLocalNode()	Gets local node.
ClusterNode	DiscoveryNotification.getNode()
@Nullable ClusterNode	DiscoverySpi.getNode(UUID nodeId)	Gets node by ID.

Methods in org.apache.ignite.spi.discovery that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	DiscoverySpi.getRemoteNodes()	Gets collection of remote nodes in grid or empty collection if no remote nodes found.
NavigableMap<Long,Collection<ClusterNode>>	DiscoveryNotification.getTopHist()
Collection<ClusterNode>	DiscoveryNotification.getTopSnapshot()

Methods in org.apache.ignite.spi.discovery with parameters of type ClusterNode

Modifier and Type	Method	Description
SecurityContext	DiscoverySpiNodeAuthenticator.authenticateNode(ClusterNode node, SecurityCredentials cred)	Security credentials.
void	DiscoverySpiListener.onLocalNodeInitialized(ClusterNode locNode)	Notification of local node initialization.

Constructors in org.apache.ignite.spi.discovery with parameters of type ClusterNode

Constructor	Description
DiscoveryNotification(int eventType, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot)
DiscoveryNotification(int eventType, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot, @Nullable NavigableMap<Long,Collection<ClusterNode>> topHist, @Nullable DiscoverySpiCustomMessage customMsgData, SpanContainer spanContainer)

Constructor parameters in org.apache.ignite.spi.discovery with type arguments of type ClusterNode

Constructor	Description
DiscoveryNotification(int eventType, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot)
DiscoveryNotification(int eventType, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot, @Nullable NavigableMap<Long,Collection<ClusterNode>> topHist, @Nullable DiscoverySpiCustomMessage customMsgData, SpanContainer spanContainer)
DiscoveryNotification(int eventType, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot, @Nullable NavigableMap<Long,Collection<ClusterNode>> topHist, @Nullable DiscoverySpiCustomMessage customMsgData, SpanContainer spanContainer)

Uses of ClusterNode in org.apache.ignite.spi.discovery.isolated

Classes in org.apache.ignite.spi.discovery.isolated that implement ClusterNode

Modifier and Type	Class	Description
class	IsolatedNode	Special isolated node.

Methods in org.apache.ignite.spi.discovery.isolated that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	IsolatedDiscoverySpi.getLocalNode()	Gets local node.
ClusterNode	IsolatedDiscoverySpi.getNode(UUID nodeId)	Gets node by ID.

Methods in org.apache.ignite.spi.discovery.isolated that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	IsolatedDiscoverySpi.getRemoteNodes()	Gets collection of remote nodes in grid or empty collection if no remote nodes found.

Methods in org.apache.ignite.spi.discovery.isolated with parameters of type ClusterNode

Modifier and Type	Method	Description
void	IsolatedDiscoverySpi.resolveCommunicationFailure(ClusterNode node, Exception err)

Uses of ClusterNode in org.apache.ignite.spi.discovery.tcp

Methods in org.apache.ignite.spi.discovery.tcp that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	TcpDiscoverySpi.getLocalNode()	Gets local node.
@Nullable ClusterNode	TcpDiscoverySpi.getNode(UUID nodeId)	Gets node by ID.
ClusterNode	TcpDiscoverySpi.getNode0(UUID id)

Methods in org.apache.ignite.spi.discovery.tcp that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Collection<ClusterNode>	TcpDiscoverySpi.getRemoteNodes()	Gets collection of remote nodes in grid or empty collection if no remote nodes found.

Methods in org.apache.ignite.spi.discovery.tcp with parameters of type ClusterNode

Modifier and Type	Method	Description
void	TcpDiscoverySpi.resolveCommunicationFailure(ClusterNode node, Exception err)
protected void	TcpDiscoverySpi.writeToSocket(ClusterNode node, Socket sock, OutputStream out, TcpDiscoveryAbstractMessage msg, long timeout)

Uses of ClusterNode in org.apache.ignite.spi.discovery.tcp.internal

Classes in org.apache.ignite.spi.discovery.tcp.internal that implement ClusterNode

Modifier and Type	Class	Description
class	TcpDiscoveryNode	Node for TcpDiscoverySpi.

Constructors in org.apache.ignite.spi.discovery.tcp.internal with parameters of type ClusterNode

Constructor	Description
TcpDiscoveryNode(ClusterNode node)	IMPORTANT!

Uses of ClusterNode in org.apache.ignite.spi.discovery.tcp.messages

Methods in org.apache.ignite.spi.discovery.tcp.messages that return types with arguments of type ClusterNode

Modifier and Type	Method	Description
Map<Long,Collection<ClusterNode>>	TcpDiscoveryNodeAddedMessage.topologyHistory()	Gets topology snapshots history.

Method parameters in org.apache.ignite.spi.discovery.tcp.messages with type arguments of type ClusterNode

Modifier and Type	Method	Description
void	TcpDiscoveryNodeAddedMessage.topologyHistory(@Nullable Map<Long,Collection<ClusterNode>> topHist)	Sets topology snapshots history.

Uses of ClusterNode in org.apache.ignite.spi.failover

Methods in org.apache.ignite.spi.failover that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	FailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.
ClusterNode	FailoverContext.getBalancedNode(List<ClusterNode> top)	Gets the next balanced node for failed job.

Method parameters in org.apache.ignite.spi.failover with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	FailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.
ClusterNode	FailoverContext.getBalancedNode(List<ClusterNode> top)	Gets the next balanced node for failed job.

Uses of ClusterNode in org.apache.ignite.spi.failover.always

Methods in org.apache.ignite.spi.failover.always that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	AlwaysFailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.

Method parameters in org.apache.ignite.spi.failover.always with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	AlwaysFailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.

Uses of ClusterNode in org.apache.ignite.spi.failover.jobstealing

Methods in org.apache.ignite.spi.failover.jobstealing that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	JobStealingFailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.

Method parameters in org.apache.ignite.spi.failover.jobstealing with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	JobStealingFailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.

Uses of ClusterNode in org.apache.ignite.spi.failover.never

Methods in org.apache.ignite.spi.failover.never that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	NeverFailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.

Method parameters in org.apache.ignite.spi.failover.never with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	NeverFailoverSpi.failover(FailoverContext ctx, List<ClusterNode> top)	This method is called when method ComputeTask.result(org.apache.ignite.compute.ComputeJobResult, List) returns value ComputeJobResultPolicy.FAILOVER policy indicating that the result of job execution must be failed over.

Uses of ClusterNode in org.apache.ignite.spi.indexing

Constructors in org.apache.ignite.spi.indexing with parameters of type ClusterNode

Constructor	Description
IndexingQueryCacheFilter(GridCacheAffinityManager aff, Set<Integer> parts, AffinityTopologyVersion topVer, ClusterNode locNode)	Constructor.

Uses of ClusterNode in org.apache.ignite.spi.loadbalancing

Methods in org.apache.ignite.spi.loadbalancing that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Method parameters in org.apache.ignite.spi.loadbalancing with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ClusterNode in org.apache.ignite.spi.loadbalancing.adaptive

Methods in org.apache.ignite.spi.loadbalancing.adaptive that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	AdaptiveLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Methods in org.apache.ignite.spi.loadbalancing.adaptive with parameters of type ClusterNode

Modifier and Type	Method	Description
double	AdaptiveCpuLoadProbe.getLoad(ClusterNode node, int jobsSentSinceLastUpdate)	Calculates load value for a given node.
double	AdaptiveJobCountLoadProbe.getLoad(ClusterNode node, int jobsSentSinceLastUpdate)	Calculates load value for a given node.
double	AdaptiveLoadProbe.getLoad(ClusterNode node, int jobsSentSinceLastUpdate)	Calculates load value for a given node.
double	AdaptiveProcessingTimeLoadProbe.getLoad(ClusterNode node, int jobsSentSinceLastUpdate)	Calculates load value for a given node.

Method parameters in org.apache.ignite.spi.loadbalancing.adaptive with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	AdaptiveLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ClusterNode in org.apache.ignite.spi.loadbalancing.roundrobin

Methods in org.apache.ignite.spi.loadbalancing.roundrobin that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	RoundRobinLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Method parameters in org.apache.ignite.spi.loadbalancing.roundrobin with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	RoundRobinLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ClusterNode in org.apache.ignite.spi.loadbalancing.weightedrandom

Methods in org.apache.ignite.spi.loadbalancing.weightedrandom that return ClusterNode

Modifier and Type	Method	Description
ClusterNode	WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Method parameters in org.apache.ignite.spi.loadbalancing.weightedrandom with type arguments of type ClusterNode

Modifier and Type	Method	Description
ClusterNode	WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ClusterNode in org.apache.ignite.spi.systemview.view

Constructors in org.apache.ignite.spi.systemview.view with parameters of type ClusterNode

Constructor	Description
ClusterNodeView(ClusterNode n)
NodeMetricsView(ClusterNode node)

Uses of ClusterNode in org.apache.ignite.util

Methods in org.apache.ignite.util with parameters of type ClusterNode

Modifier and Type	Method	Description
boolean	AttributeNodeFilter.apply(ClusterNode node)	Predicate body.