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.fair	Contains fair cache affinity for partitioned cache.
org.apache.ignite.cache.affinity.rendezvous	Contains HRW-based cache affinity for partitioned cache.
org.apache.ignite.cluster
org.apache.ignite.compute	Contains Compute Grid functionality.
org.apache.ignite.compute.gridify.aop	Contains common classes for different AOP providers.
org.apache.ignite.events	Contains Event Subscription functionality together with various events emitted by Ignite.
org.apache.ignite.igfs.mapreduce	Contains APIs for In-Memory MapReduce over IGFS.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.cluster
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.eventstorage	TODO.
org.apache.ignite.internal.managers.failover	TODO.
org.apache.ignite.internal.managers.loadbalancer	TODO.
org.apache.ignite.internal.processors	TODO.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.affinity
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.colocated
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.local
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.query.jdbc
org.apache.ignite.internal.processors.cacheobject	Cache object processor.
org.apache.ignite.internal.processors.closure	TODO.
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.hadoop	Contains Hadoop APIs.
org.apache.ignite.internal.processors.igfs	Contains high performance file system processer.
org.apache.ignite.internal.processors.job	TODO.
org.apache.ignite.internal.processors.security
org.apache.ignite.internal.processors.security.os
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.processors.streamer	TODO.
org.apache.ignite.internal.processors.streamer.task
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.lang
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.misc
org.apache.ignite.internal.visor.node
org.apache.ignite.internal.visor.query
org.apache.ignite.internal.visor.util
org.apache.ignite.plugin
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.discovery	Contains APIs for topology manager SPI.
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.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.streamer	Contains main Streaming APIs.
org.apache.ignite.streamer.router	Contains streamer event router implementations.

Uses of ClusterNode in org.apache.ignite

Methods in org.apache.ignite that return ClusterNode

Modifier and Type	Method and Description
ClusterNode	IgniteCluster.localNode() Gets local grid node.
<K> ClusterNode	IgniteCluster.mapKeyToNode(String cacheName, K key) This method provides ability to detect which cache keys are mapped to which nodes on cache instance with given name.

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

Modifier and Type	Method and Description
<K> Map<ClusterNode,Collection<K>>	IgniteCluster.mapKeysToNodes(String cacheName, Collection<? extends K> keys) This method provides ability to detect which cache keys are mapped to which nodes on cache instance with given name.
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 and Description
ClusterNode	CacheAffinity.mapKeyToNode(K key) This method provides ability to detect to which primary node the given key is mapped.
ClusterNode	CacheAffinity.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 and Description
List<List<ClusterNode>>	CacheAffinityFunction.assignPartitions(CacheAffinityFunctionContext affCtx) Gets affinity nodes for a partition.
List<ClusterNode>	CacheAffinityFunctionContext.currentTopologySnapshot() Gets current topology snapshot.
Map<ClusterNode,Collection<K>>	CacheAffinity.mapKeysToNodes(Collection<? extends K> keys) This method provides ability to detect which keys are mapped to which nodes.
Collection<ClusterNode>	CacheAffinity.mapKeyToPrimaryAndBackups(K key) Gets primary and backup nodes for the key.
Map<Integer,ClusterNode>	CacheAffinity.mapPartitionsToNodes(Collection<Integer> parts) Gets primary nodes for the given partitions.
Collection<ClusterNode>	CacheAffinity.mapPartitionToPrimaryAndBackups(int part) Gets primary and backup nodes for partition.
List<ClusterNode>	CacheAffinityFunctionContext.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 and Description
int[]	CacheAffinity.allPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has ownership (either primary or backup).
int[]	CacheAffinity.backupPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has backup ownership.
boolean	CacheAffinity.isBackup(ClusterNode n, K key) Returns true if local node is one of the backup nodes for given key.
boolean	CacheAffinity.isPrimary(ClusterNode n, K key) Returns true if given node is the primary node for given key.
boolean	CacheAffinity.isPrimaryOrBackup(ClusterNode n, K key) Returns true if local node is primary or one of the backup nodes This method is essentially equivalent to calling "CacheAffinity.isPrimary(org.apache.ignite.cluster.ClusterNode, Object) || CacheAffinity.isBackup(org.apache.ignite.cluster.ClusterNode, Object))", however it is more efficient as it makes both checks at once.
int[]	CacheAffinity.primaryPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has primary ownership.
Object	CacheAffinityNodeAddressHashResolver.resolve(ClusterNode node) Resolve alternate hash value for the given Grid node.
Object	CacheAffinityNodeHashResolver.resolve(ClusterNode node) Resolve alternate hash value for the given Grid node.
Object	CacheAffinityNodeIdHashResolver.resolve(ClusterNode node) Resolve alternate hash value for the given Grid node.

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

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

Modifier and Type	Method and Description
List<List<ClusterNode>>	CachePartitionFairAffinity.assignPartitions(CacheAffinityFunctionContext ctx) Gets affinity nodes for a partition.

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 and Description
List<ClusterNode>	CacheRendezvousAffinityFunction.assignPartition(int part, List<ClusterNode> nodes, int backups, Map<UUID,Collection<ClusterNode>> neighborhoodCache) Returns collection of nodes (primary first) for specified partition.
List<List<ClusterNode>>	CacheRendezvousAffinityFunction.assignPartitions(CacheAffinityFunctionContext affCtx) Gets affinity nodes for a partition.
IgniteBiPredicate<ClusterNode,ClusterNode>	CacheRendezvousAffinityFunction.getBackupFilter() Gets optional backup filter.
IgniteBiPredicate<ClusterNode,ClusterNode>	CacheRendezvousAffinityFunction.getBackupFilter() Gets optional backup filter.

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

Modifier and Type	Method and Description
List<ClusterNode>	CacheRendezvousAffinityFunction.assignPartition(int part, List<ClusterNode> nodes, int backups, Map<UUID,Collection<ClusterNode>> neighborhoodCache) Returns collection of nodes (primary first) for specified partition.
List<ClusterNode>	CacheRendezvousAffinityFunction.assignPartition(int part, List<ClusterNode> nodes, int backups, Map<UUID,Collection<ClusterNode>> neighborhoodCache) Returns collection of nodes (primary first) for specified partition.
void	CacheRendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter) Sets optional backup filter.
void	CacheRendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter) Sets optional backup filter.

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

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

Uses of ClusterNode in org.apache.ignite.cluster

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

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

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

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

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

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

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

Modifier and Type	Method and Description
ClusterGroup	ClusterGroup.forNodes(Collection<? extends ClusterNode> nodes) Creates a grid projection over a given set of nodes.
ClusterGroup	ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p) Creates a grid projection 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 and Description
ClusterNode	ComputeLoadBalancer.getBalancedNode(ComputeJob job, 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 and Description
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.
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 and 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 and Description
ClusterNode	ComputeLoadBalancer.getBalancedNode(ComputeJob job, Collection<ClusterNode> exclNodes) Gets the next balanced node according to the underlying load balancing policy.
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.
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.compute.gridify.aop

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

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

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

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

Uses of ClusterNode in org.apache.ignite.events

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

Modifier and Type	Method and Description
ClusterNode	CacheRebalancingEvent.discoveryNode() Gets shadow of the node that triggered this rebalancing event.
ClusterNode	DiscoveryEvent.eventNode() Gets node that caused this event to be generated.
ClusterNode	CacheEvent.eventNode() Gets node which initiated cache operation or null if that node is not available.
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 and Description
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 and 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 and 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 and Description
CacheEvent(String cacheName, ClusterNode node, ClusterNode evtNode, String msg, int type, int part, boolean near, Object key, IgniteUuid xid, Object lockId, Object newVal, boolean hasNewVal, Object oldVal, boolean hasOldVal, UUID subjId, String cloClsName, String taskName) Constructs cache event.
CacheQueryExecutedEvent(ClusterNode node, String msg, int type, CacheQueryType qryType, String cacheName, String clsName, String clause, IgniteBiPredicate<K,V> scanQryFilter, javax.cache.event.CacheEntryEventFilter<K,V> contQryFilter, Object[] args, UUID subjId, String taskName)
CacheQueryReadEvent(ClusterNode node, String msg, int type, CacheQueryType qryType, String cacheName, String clsName, String clause, IgniteBiPredicate<K,V> scanQryFilter, javax.cache.event.CacheEntryEventFilter<K,V> contQryFilter, Object[] args, UUID subjId, String taskName, K key, V val, V oldVal, 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.
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.
IgfsEvent(IgfsPath path, ClusterNode node, int type) Constructs an event instance.
IgfsEvent(IgfsPath path, ClusterNode node, int type, long dataSize) Constructs an event instance for close events: (EventType.EVT_IGFS_FILE_CLOSED_READ, EventType.EVT_IGFS_FILE_CLOSED_WRITE).
IgfsEvent(IgfsPath path, ClusterNode node, int type, Map<String,String> meta) Constructs an event instance for file metadata update events (EventType.EVT_IGFS_META_UPDATED).
IgfsEvent(IgfsPath path, IgfsPath newPath, ClusterNode node, int type) Constructs an event instance for path modification event (EventType.EVT_IGFS_FILE_RENAMED, EventType.EVT_IGFS_DIR_RENAMED).
JobEvent(ClusterNode node, String msg, int type) Creates job event with given parameters.
SwapSpaceEvent(ClusterNode node, String msg, int type, String space) Creates swap space event.
TaskEvent(ClusterNode node, String msg, int type, IgniteUuid sesId, String taskName, String taskClsName, boolean internal, UUID subjId) Creates task event with given parameters.

Uses of ClusterNode in org.apache.ignite.igfs.mapreduce

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

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

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

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

Uses of ClusterNode in org.apache.ignite.internal

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

Modifier and Type	Method and Description
ClusterNode	GridJobResultImpl.getNode() Gets node this job executed on.
ClusterNode	IgniteEx.localNode() Gets local grid node.
ClusterNode	GridPluginContext.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 and Description
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 and Description
int	GridNodeOrderComparator.compare(ClusterNode n1, ClusterNode n2)
void	GridJobResultImpl.setNode(ClusterNode node)
IgniteSpiNodeValidationResult	GridComponent.validateNode(ClusterNode node) Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.
IgniteSpiNodeValidationResult	GridPluginComponent.validateNode(ClusterNode node) Validates that new node can join grid topology, this method is called on coordinator node before new node joins topology.

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

Constructor and Description
ClusterLocalNodeMetricsMXBeanImpl(ClusterNode node)
GridJobResultImpl(ComputeJob job, IgniteUuid jobId, ClusterNode node, GridJobSiblingImpl sib)

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

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

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

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

Modifier and Type	Method and Description
ClusterNode	IgniteClusterImpl.localNode() Gets local grid node.
ClusterNode	IgniteClusterAsyncImpl.localNode() Gets local grid node.
<K> ClusterNode	IgniteClusterImpl.mapKeyToNode(String cacheName, K key) This method provides ability to detect which cache keys are mapped to which nodes on cache instance with given name.
<K> ClusterNode	IgniteClusterAsyncImpl.mapKeyToNode(String cacheName, K key) This method provides ability to detect which cache keys are mapped to which nodes on cache instance with given name.
ClusterNode	IgniteClusterAsyncImpl.node() Gets first node from the list of nodes in this projection.
ClusterNode	ClusterGroupAdapter.node() Gets first node from the list of nodes in this projection.
ClusterNode	IgniteClusterAsyncImpl.node(UUID id) Gets a node for given ID from this grid projection.
ClusterNode	ClusterGroupAdapter.node(UUID id) Gets a node for given ID from this grid projection.

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

Modifier and Type	Method and Description
<K> Map<ClusterNode,Collection<K>>	IgniteClusterImpl.mapKeysToNodes(String cacheName, Collection<? extends K> keys) This method provides ability to detect which cache keys are mapped to which nodes on cache instance with given name.
<K> Map<ClusterNode,Collection<K>>	IgniteClusterAsyncImpl.mapKeysToNodes(String cacheName, Collection<? extends K> keys) This method provides ability to detect which cache keys are mapped to which nodes on cache instance with given name.
Collection<ClusterNode>	IgniteClusterAsyncImpl.nodes() Gets read-only collections of nodes in this projection.
Collection<ClusterNode>	ClusterGroupAdapter.nodes() Gets read-only collections of nodes in this projection.
IgnitePredicate<ClusterNode>	IgniteClusterAsyncImpl.predicate() Gets predicate that defines a subset of nodes for this projection.
IgnitePredicate<ClusterNode>	ClusterGroupAdapter.predicate() Gets predicate that defines a subset of nodes for this projection.
Collection<ClusterNode>	IgniteClusterImpl.topology(long topVer) Gets a topology by version.
Collection<ClusterNode>	IgniteClusterAsyncImpl.topology(long topVer) Gets a topology by version.

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

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

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

Modifier and Type	Method and Description
ClusterGroup	IgniteClusterAsyncImpl.forNodes(Collection<? extends ClusterNode> nodes) Creates a grid projection over a given set of nodes.
ClusterGroup	ClusterGroupAdapter.forNodes(Collection<? extends ClusterNode> nodes) Creates a grid projection over a given set of nodes.
ClusterGroup	IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p) Creates a grid projection which includes all nodes that pass the given predicate filter.
ClusterGroup	ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p) Creates a grid projection 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 and Description
ClusterGroupAdapter(GridKernalContext ctx, UUID subjId, IgnitePredicate<ClusterNode> p)

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 and Description
IgniteSpiNodeValidationResult	GridManagerAdapter.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.managers.communication

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

Modifier and Type	Method and Description
void	GridIoManager.send(ClusterNode node, GridTopic topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(ClusterNode node, Object topic, Message msg, GridIoPolicy plc)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, Message msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)

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

Modifier and Type	Method and Description
void	GridIoManager.send(Collection<? extends ClusterNode> nodes, GridTopic topic, Message msg, GridIoPolicy plc)
void	GridIoManager.send(Collection<? extends ClusterNode> nodes, Object topic, Message msg, GridIoPolicy plc)
void	GridIoManager.sendOrderedMessage(Collection<? extends ClusterNode> nodes, Object topic, Message msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes, Object msg) Sends a peer deployable user message.
void	GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes, Object msg, Object topic, boolean ordered, long timeout) Sends a peer deployable user message.

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

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

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

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

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

Modifier and Type	Method and Description
ClusterNode	GridDiscoveryManager.localNode()
ClusterNode	GridDiscoveryManager.node(UUID nodeId)

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

Modifier and Type	Method and Description
Collection<ClusterNode>	GridDiscoveryManager.aliveCacheNodes(String cacheName, long topVer) Gets cache nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.aliveNodesWithCaches(long topVer) Gets alive nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.aliveRemoteCacheNodes(String cacheName, long topVer) Gets cache remote nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.aliveRemoteNodesWithCaches(long topVer) Gets alive remote nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.allNodes()
Collection<ClusterNode>	GridDiscoveryManager.cacheAffinityNodes(String cacheName, long topVer) Gets cache nodes for cache with given name that participate in affinity calculation.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(long topVer) Gets all nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(String cacheName, long topVer) Gets cache nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.daemonNodes()
Collection<ClusterNode>	GridDiscoveryManager.nodes(Collection<UUID> ids, IgnitePredicate<UUID>... p) Gets collection of node for given node IDs and predicates.
Collection<ClusterNode>	GridDiscoveryManager.nodes(long topVer) Gets all nodes for given topology version.
Collection<ClusterNode>	GridDiscoveryManager.remoteCacheNodes(long topVer) Gets cache remote nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.remoteCacheNodes(String cacheName, long topVer) Gets cache remote nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.remoteNodes()
Collection<ClusterNode>	GridDiscoveryManager.topology(long topVer) Gets topology by specified version from history storage.
Collection<ClusterNode>	GridDiscoveryTopologySnapshot.topologyNodes()
NavigableMap<IgniteProductVersion,Collection<ClusterNode>>	GridDiscoveryManager.topologyVersionMap() Gets topology grouped by node versions.

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

Modifier and Type	Method and Description
boolean	GridDiscoveryManager.alive(ClusterNode node)

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

Modifier and Type	Method and Description
long	GridDiscoveryManager.topologyHash(Iterable<? extends ClusterNode> nodes) Gets topology hash for given set of nodes.

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

Constructor and 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.eventstorage

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

Modifier and Type	Method and 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 and Description
ClusterNode	GridFailoverManager.failover(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, List<ClusterNode> top)
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 and Description
ClusterNode	GridFailoverManager.failover(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, List<ClusterNode> top)
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 and 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 and 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 and Description
IgniteSpiNodeValidationResult	GridProcessorAdapter.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.affinity

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

Modifier and Type	Method and Description
<K> ClusterNode	GridAffinityProcessor.mapKeyToNode(K key) Maps single key to a node on default cache.
<K> ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key) Maps single key to a node.
<K> ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key, long topVer) Maps single key to a node.

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

Modifier and Type	Method and Description
List<List<ClusterNode>>	GridAffinityAssignmentCache.assignments(long topVer)
List<List<ClusterNode>>	GridAffinityAssignmentCache.calculate(long topVer, DiscoveryEvent discoEvt) Calculates affinity cache for given topology version.
List<ClusterNode>	GridCacheAffinityFunctionContextImpl.currentTopologySnapshot() Gets current topology snapshot.
<K> Map<ClusterNode,Collection<K>>	GridAffinityProcessor.mapKeysToNodes(Collection<? extends K> keys) Maps keys to nodes on default cache.
<K> Map<ClusterNode,Collection<K>>	GridAffinityProcessor.mapKeysToNodes(String cacheName, Collection<? extends K> keys) Maps keys to nodes for given cache.
<K> List<ClusterNode>	GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName, K key) Map single key to primary and backup nodes.
List<ClusterNode>	GridAffinityAssignmentCache.nodes(int part, long topVer) Gets affinity nodes for specified partition.
List<ClusterNode>	GridCacheAffinityFunctionContextImpl.previousAssignment(int part) Gets affinity assignment for given partition on previous topology version.

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

Modifier and Type	Method and Description
void	GridAffinityAssignmentCache.initialize(long topVer, List<List<ClusterNode>> affAssignment) Initializes affinity with given topology version and assignment.

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

Constructor and Description
GridCacheAffinityFunctionContextImpl(List<ClusterNode> topSnapshot, List<List<ClusterNode>> prevAssignment, DiscoveryEvent discoEvt, long topVer, int backups)
GridCacheAffinityFunctionContextImpl(List<ClusterNode> topSnapshot, List<List<ClusterNode>> prevAssignment, DiscoveryEvent discoEvt, long topVer, int backups)

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 and Description
ClusterNode	GridCacheContext.localNode()
ClusterNode	GridCacheSharedContext.localNode()
static ClusterNode	GridCacheUtils.localOrPrimary(Iterable<ClusterNode> nodes, UUID locId)
ClusterNode	GridCacheContext.node(UUID nodeId)
ClusterNode	GridCacheSharedContext.node(UUID nodeId)
static ClusterNode	GridCacheUtils.oldest(GridCacheContext cctx) Gets oldest alive node for specified topology version.
static ClusterNode	GridCacheUtils.oldest(GridCacheContext cctx, long topOrder) Gets oldest alive node for specified topology version.
static ClusterNode	GridCacheUtils.oldest(GridCacheSharedContext ctx) Gets oldest alive node across nodes with at least one cache configured.
static ClusterNode	GridCacheUtils.oldest(GridCacheSharedContext cctx, long topOrder) Gets oldest alive node with at least one cache configured for specified topology version.
ClusterNode	GridCacheAffinityManager.primary(int part, long topVer)
static ClusterNode	GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes)
ClusterNode	GridCacheAffinityManager.primary(Object key, long topVer)
static ClusterNode	GridCacheUtils.primaryNode(GridCacheContext ctx, Object key) Gets primary node on which given key is cached.

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

Modifier and Type	Method and Description
static Collection<ClusterNode>	GridCacheUtils.affinityNodes(GridCacheContext ctx) Gets all nodes on which cache with the same name is started and the local DHT storage is enabled.
static Collection<ClusterNode>	GridCacheUtils.affinityNodes(GridCacheContext ctx, long topOrder) Gets DHT affinity nodes.
static Collection<ClusterNode>	GridCacheUtils.aliveCacheNodes(GridCacheSharedContext ctx, long topOrder) Gets alive nodes with at least one cache configured.
static Collection<ClusterNode>	GridCacheUtils.aliveNodes(GridCacheContext ctx, long topOrder) Gets alive nodes.
static Collection<ClusterNode>	GridCacheUtils.aliveRemoteCacheNodes(GridCacheSharedContext ctx, long topOrder) Gets alive remote nodes with at least one cache configured.
static Collection<ClusterNode>	GridCacheUtils.aliveRemoteNodes(GridCacheContext ctx, long topOrder) Gets alive nodes.
static Collection<ClusterNode>	GridCacheUtils.allNodes(GridCacheContext ctx) Gets all nodes on which cache with the same name is started.
static Collection<ClusterNode>	GridCacheUtils.allNodes(GridCacheContext ctx, long topOrder) Gets all nodes on which cache with the same name is started.
static Collection<ClusterNode>	GridCacheUtils.allNodes(GridCacheSharedContext ctx, long topOrder) Gets all nodes with at least one cache configured.
List<List<ClusterNode>>	GridCacheAffinityManager.assignments(long topVer)
static Collection<ClusterNode>	GridCacheUtils.backups(Collection<ClusterNode> nodes)
Collection<ClusterNode>	GridCacheAffinityManager.backups(int part, long topVer)
Collection<ClusterNode>	GridCacheAffinityManager.backups(Object key, long topVer)
List<List<ClusterNode>>	GridCacheAffinityManager.calculateAffinity(long topVer, DiscoveryEvent discoEvt) Calculates affinity cache for given topology version.
static <K> Map<ClusterNode,Collection<K>>	GridCacheUtils.mapKeysToNodes(GridCacheContext<K,?> ctx, Collection<? extends K> keys)
static Comparator<ClusterNode>	GridCacheUtils.nodeComparator(boolean asc)
Collection<? extends ClusterNode>	GridCacheFuture.nodes()
List<ClusterNode>	GridCacheAffinityManager.nodes(int part, long topVer)
List<ClusterNode>	GridCacheAffinityManager.nodes(Object key, long topVer)
static Collection<ClusterNode>	GridCacheUtils.remoteNodes(GridCacheContext ctx) Gets remote nodes on which cache with the same name is started.
static Collection<ClusterNode>	GridCacheUtils.remoteNodes(GridCacheContext ctx, long topOrder) Gets remote nodes on which cache with the same name is started.
static Collection<ClusterNode>	GridCacheUtils.remoteNodes(GridCacheSharedContext ctx) Gets remote node with at least one cache configured.
static Collection<ClusterNode>	GridCacheUtils.remoteNodes(GridCacheSharedContext ctx, long topVer) Gets remote nodes with at least one cache configured.
Collection<ClusterNode>	GridCacheAffinityManager.remoteNodes(Iterable keys, long topVer)

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

Modifier and Type	Method and Description
void	GridCacheEventManager.addPreloadEvent(int part, int type, ClusterNode discoNode, int discoType, long discoTs) Adds preloading event.
static boolean	GridCacheUtils.affinityNode(GridCacheContext ctx, ClusterNode s) Checks if given node has specified cache started and the local DHT storage is enabled.
boolean	GridCacheAffinityManager.belongs(ClusterNode node, int part, long topVer)
boolean	GridCacheAffinityManager.belongs(ClusterNode node, Object key, long topVer)
static boolean	GridCacheUtils.cacheNode(GridCacheContext ctx, ClusterNode node) Checks if given node contains configured cache with the name as described by given cache context.
static boolean	GridCacheUtils.cacheNode(String cacheName, ClusterNode node) Checks if given node has specified cache started.
static CacheEntryPredicate	GridCacheUtils.cachePrimary(CacheAffinity aff, ClusterNode n)
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>	GridCacheUtils.cachePrimary0(CacheAffinity<K> aff, ClusterNode n)
static void	GridCacheUtils.checkAttributeMismatch(IgniteLogger log, CacheConfiguration locCfg, CacheConfiguration rmtCfg, ClusterNode rmt, T2<String,String> attr, boolean fail) Checks that local and remove configurations have the same value of given attribute.
static void	GridCacheUtils.checkAttributeMismatch(IgniteLogger log, String cfgName, ClusterNode rmt, String attrName, String attrMsg, Object locVal, Object rmtVal, boolean fail) Checks that cache configuration attribute has the same value in local and remote cache configurations.
boolean	GridCacheContext.isLocalNode(ClusterNode n)
boolean	GridCacheAffinityManager.primary(ClusterNode n, int part, long topVer)
boolean	GridCacheAffinityManager.primary(ClusterNode n, Object key, long topVer)
void	GridCacheIoManager.send(ClusterNode node, GridCacheMessage msg, GridIoPolicy plc) Sends communication message.
void	GridCacheIoManager.sendOrderedMessage(ClusterNode node, Object topic, GridCacheMessage msg, GridIoPolicy plc, long timeout)
IgniteSpiNodeValidationResult	GridCacheProcessor.validateNode(ClusterNode node) 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 and Description
static Collection<ClusterNode>	GridCacheUtils.backups(Collection<ClusterNode> nodes)
boolean	GridCacheContext.dhtMap(UUID nearNodeId, long topVer, GridDhtCacheEntry entry, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
boolean	GridCacheContext.dhtMap(UUID nearNodeId, long topVer, GridDhtCacheEntry entry, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
void	GridCacheAffinityManager.initializeAffinity(long topVer, List<List<ClusterNode>> affAssignment) Initializes affinity for joined node.
static ClusterNode	GridCacheUtils.localOrPrimary(Iterable<ClusterNode> nodes, UUID locId)
static ClusterNode	GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes)
boolean	GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes, GridCacheMessage msg, GridIoPolicy plc, IgnitePredicate<ClusterNode> fallback) Sends message and automatically accounts for lefts nodes.
boolean	GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes, GridCacheMessage msg, GridIoPolicy plc, IgnitePredicate<ClusterNode> fallback) Sends message and automatically accounts for lefts nodes.

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 and Description
ClusterNode	GridCacheAffinityProxy.mapKeyToNode(K key) This method provides ability to detect to which primary node the given key is mapped.
ClusterNode	GridCacheAffinityImpl.mapKeyToNode(K key) This method provides ability to detect to which primary node the given key is mapped.
ClusterNode	GridCacheAffinityProxy.mapPartitionToNode(int part) Gets primary node for the given partition.
ClusterNode	GridCacheAffinityImpl.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 and Description
Map<ClusterNode,Collection<K>>	GridCacheAffinityProxy.mapKeysToNodes(Collection<? extends K> keys) This method provides ability to detect which keys are mapped to which nodes.
Map<ClusterNode,Collection<K>>	GridCacheAffinityImpl.mapKeysToNodes(Collection<? extends K> keys) This method provides ability to detect which keys are mapped to which nodes.
Collection<ClusterNode>	GridCacheAffinityProxy.mapKeyToPrimaryAndBackups(K key) Gets primary and backup nodes for the key.
Collection<ClusterNode>	GridCacheAffinityImpl.mapKeyToPrimaryAndBackups(K key) Gets primary and backup nodes for the key.
Map<Integer,ClusterNode>	GridCacheAffinityProxy.mapPartitionsToNodes(Collection<Integer> parts) Gets primary nodes for the given partitions.
Map<Integer,ClusterNode>	GridCacheAffinityImpl.mapPartitionsToNodes(Collection<Integer> parts) Gets primary nodes for the given partitions.
Collection<ClusterNode>	GridCacheAffinityProxy.mapPartitionToPrimaryAndBackups(int part) Gets primary and backup nodes for partition.
Collection<ClusterNode>	GridCacheAffinityImpl.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 and Description
int[]	GridCacheAffinityProxy.allPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has ownership (either primary or backup).
int[]	GridCacheAffinityImpl.allPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has ownership (either primary or backup).
int[]	GridCacheAffinityProxy.backupPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has backup ownership.
int[]	GridCacheAffinityImpl.backupPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has backup ownership.
boolean	GridCacheAffinityProxy.isBackup(ClusterNode n, K key) Returns true if local node is one of the backup nodes for given key.
boolean	GridCacheAffinityImpl.isBackup(ClusterNode n, K key) Returns true if local node is one of the backup nodes for given key.
boolean	GridCacheAffinityProxy.isPrimary(ClusterNode n, K key) Returns true if given node is the primary node for given key.
boolean	GridCacheAffinityImpl.isPrimary(ClusterNode n, K key) Returns true if given node is the primary node for given key.
boolean	GridCacheAffinityProxy.isPrimaryOrBackup(ClusterNode n, K key) Returns true if local node is primary or one of the backup nodes This method is essentially equivalent to calling "CacheAffinity.isPrimary(org.apache.ignite.cluster.ClusterNode, Object) || CacheAffinity.isBackup(org.apache.ignite.cluster.ClusterNode, Object))", however it is more efficient as it makes both checks at once.
boolean	GridCacheAffinityImpl.isPrimaryOrBackup(ClusterNode n, K key) Returns true if local node is primary or one of the backup nodes This method is essentially equivalent to calling "CacheAffinity.isPrimary(org.apache.ignite.cluster.ClusterNode, Object) || CacheAffinity.isBackup(org.apache.ignite.cluster.ClusterNode, Object))", however it is more efficient as it makes both checks at once.
int[]	GridCacheAffinityProxy.primaryPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has primary ownership.
int[]	GridCacheAffinityImpl.primaryPartitions(ClusterNode n) Gets partition ids for which nodes of the given projection has primary ownership.

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 and Description
ClusterNode	GridDistributedTxMapping.node()

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

Modifier and Type	Method and Description
Collection<? extends ClusterNode>	GridCacheOptimisticCheckPreparedTxFuture.nodes()

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

Constructor and Description
GridDistributedTxMapping(ClusterNode node)

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

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

Modifier and Type	Method and Description
List<List<ClusterNode>>	GridDhtAffinityAssignmentResponse.affinityAssignment()
List<ClusterNode>	GridDhtPartitionTopology.moving(int p)
List<ClusterNode>	GridClientPartitionTopology.moving(int p)
Collection<? extends ClusterNode>	GridPartitionedGetFuture.nodes()
Collection<? extends ClusterNode>	GridDhtTxFinishFuture.nodes()
Collection<? extends ClusterNode>	GridDhtLockFuture.nodes()
Collection<? extends ClusterNode>	GridDhtTxPrepareFuture.nodes()
Collection<ClusterNode>	GridDhtPartitionTopology.nodes(int p, long topVer)
Collection<ClusterNode>	GridClientPartitionTopology.nodes(int p, long topVer)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p)
List<ClusterNode>	GridClientPartitionTopology.owners(int p)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p, long topVer)
List<ClusterNode>	GridClientPartitionTopology.owners(int p, long topVer)

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

Modifier and Type	Method and Description
IgniteInternalFuture<GridNearLockResponse>	GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<K,V> cacheCtx, ClusterNode nearNode, GridNearLockRequest req, CacheEntryPredicate[] filter0)
void	GridDhtAssignmentFetchFuture.onResponse(ClusterNode node, GridDhtAffinityAssignmentResponse res)

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

Modifier and Type	Method and Description
void	GridDhtTxMapping.addMapping(List<ClusterNode> nodes) Adds information about next mapping.
boolean	GridDhtAssignmentFetchFuture.onDone(List<List<ClusterNode>> res, Throwable err) Callback to notify that future is finished.

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

Constructor and Description
GridDhtAffinityAssignmentResponse(int cacheId, long topVer, List<List<ClusterNode>> affAssignment)
GridDhtAssignmentFetchFuture(GridCacheContext ctx, long topVer, Collection<ClusterNode> availableNodes)

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

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

Modifier and Type	Method and Description
Collection<? extends ClusterNode>	GridNearAtomicUpdateFuture.nodes()
Collection<? extends ClusterNode>	GridDhtAtomicUpdateFuture.nodes()

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

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

Modifier and Type	Method and Description
Collection<? extends ClusterNode>	GridDhtColocatedLockFuture.nodes()

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 and Description
ClusterNode	GridNearLockMapping.node()

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

Modifier and Type	Method and Description
Collection<? extends ClusterNode>	GridNearTxPrepareFuture.nodes()
Collection<? extends ClusterNode>	GridNearGetFuture.nodes()
Collection<? extends ClusterNode>	GridNearTxFinishFuture.nodes()
Collection<? extends ClusterNode>	GridNearLockFuture.nodes()

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

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

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

Constructor and 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.local

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

Modifier and Type	Method and Description
Collection<? extends ClusterNode>	GridLocalLockFuture.nodes()

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 and Description
void	GridCacheLocalQueryManager.loadPage(long id, GridCacheQueryAdapter<?> qry, Collection<ClusterNode> nodes, boolean all) Loads page.
abstract void	GridCacheQueryManager.loadPage(long id, GridCacheQueryAdapter<?> qry, Collection<ClusterNode> nodes, boolean all) Loads page.
void	GridCacheDistributedQueryManager.loadPage(long id, GridCacheQueryAdapter<?> qry, Collection<ClusterNode> nodes, boolean all) Loads page.
CacheQueryFuture<?>	GridCacheLocalQueryManager.queryDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) Executes distributed query.
abstract CacheQueryFuture<?>	GridCacheQueryManager.queryDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) Executes distributed query.
CacheQueryFuture<?>	GridCacheDistributedQueryManager.queryDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) Executes distributed query.
CacheQueryFuture<?>	GridCacheLocalQueryManager.queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) Executes distributed fields query.
abstract CacheQueryFuture<?>	GridCacheQueryManager.queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) Executes distributed fields query.
CacheQueryFuture<?>	GridCacheDistributedQueryManager.queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes) Executes distributed fields query.

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

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

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

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

Modifier and Type	Method and Description
Map<? extends ComputeJob,ClusterNode>	GridCacheQueryJdbcTask.map(List<ClusterNode> subgrid, byte[] arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	GridCacheQueryJdbcMetadataTask.map(List<ClusterNode> subgrid, String cacheName) This method is called to map or split grid task into multiple grid jobs.

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

Modifier and Type	Method and Description
Map<? extends ComputeJob,ClusterNode>	GridCacheQueryJdbcTask.map(List<ClusterNode> subgrid, byte[] arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	GridCacheQueryJdbcMetadataTask.map(List<ClusterNode> subgrid, String cacheName) This method is called to map or split grid task into multiple grid jobs.

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

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

Modifier and Type	Method and Description
CacheObjectContext	IgniteCacheObjectProcessorImpl.contextForCache(ClusterNode node, String cacheName)
CacheObjectContext	IgniteCacheObjectProcessor.contextForCache(ClusterNode node, String cacheName)

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

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

Modifier and Type	Method and Description
<R> ComputeTaskInternalFuture<R>	GridClosureProcessor.affinityCall(String cacheName, Object affKey, Callable<R> job, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	GridClosureProcessor.affinityRun(String cacheName, Object affKey, Runnable job, Collection<ClusterNode> nodes)
<T,R> IgniteInternalFuture<Collection<R>>	GridClosureProcessor.broadcast(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)
<T,R> IgniteInternalFuture<Collection<R>>	GridClosureProcessor.broadcastNoFailover(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)
<R> ComputeTaskInternalFuture<R>	GridClosureProcessor.callAsync(GridClosureCallMode mode, Callable<R> job, Collection<ClusterNode> nodes)
<R> ComputeTaskInternalFuture<R>	GridClosureProcessor.callAsync(GridClosureCallMode mode, Callable<R> job, Collection<ClusterNode> nodes, boolean sys)
<R> ComputeTaskInternalFuture<Collection<R>>	GridClosureProcessor.callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<ClusterNode> nodes)
<R> ComputeTaskInternalFuture<Collection<R>>	GridClosureProcessor.callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<ClusterNode> nodes, boolean sys)
<T,R> ComputeTaskInternalFuture<Collection<R>>	GridClosureProcessor.callAsync(IgniteClosure<T,R> job, Collection<? extends T> args, Collection<ClusterNode> nodes)
<T,R> ComputeTaskInternalFuture<R>	GridClosureProcessor.callAsync(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)
<T,R1,R2> ComputeTaskInternalFuture<R2>	GridClosureProcessor.callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)
<R> IgniteInternalFuture<R>	GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode, Callable<R> job, Collection<ClusterNode> nodes, boolean sys)
<R> IgniteInternalFuture<Collection<R>>	GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<ClusterNode> nodes, boolean sys)
<R1,R2> ComputeTaskInternalFuture<R2>	GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode, Collection<? extends Callable<R1>> jobs, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	GridClosureProcessor.runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	GridClosureProcessor.runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, Collection<ClusterNode> nodes, boolean sys)
ComputeTaskInternalFuture<?>	GridClosureProcessor.runAsync(GridClosureCallMode mode, Runnable job, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	GridClosureProcessor.runAsync(GridClosureCallMode mode, Runnable job, Collection<ClusterNode> nodes, boolean sys)

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 and Description
IgniteInternalFuture<UUID>	GridContinuousProcessor.startRoutine(GridContinuousHandler hnd, int bufSize, long interval, boolean autoUnsubscribe, IgnitePredicate<ClusterNode> prjPred)

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

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

Modifier and Type	Method and Description
HadoopMapReducePlan	HadoopMapReducePlanner.preparePlan(HadoopJob job, Collection<ClusterNode> top, HadoopMapReducePlan oldPlan) Prepares map-reduce execution plan for the given job and topology.

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

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

Modifier and Type	Method and Description
ClusterNode	IgfsDataManager.affinityNode(Object affinityKey) Maps affinity key to node.

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

Modifier and Type	Method and Description
boolean	IgfsContext.igfsNode(ClusterNode node) Checks if given node is a IGFS node.
void	IgfsContext.send(ClusterNode node, Object topic, IgfsCommunicationMessage msg, GridIoPolicy plc)

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

Constructor and Description
IgfsBlockLocationImpl(long start, long len, Collection<ClusterNode> nodes)

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

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

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

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 and Description
SecurityContext	GridSecurityProcessor.authenticateNode(ClusterNode node, GridSecurityCredentials cred) Authenticates grid node with it's attributes via underlying Authenticator.

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

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

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

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 and Description
IgnitePredicate<ClusterNode>	GridServiceAssignments.nodeFilter()

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

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

Modifier and Type	Method and Description
void	GridStreamerContextImpl.broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
void	GridStreamerContextDelegate.broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextImpl.query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextDelegate.query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.

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

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

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

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

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

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

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

Modifier and Type	Method and Description
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, IgnitePredicate<ClusterNode> p) Gets oldest node out of collection of nodes.
static ClusterNode	IgniteUtils.youngest(Collection<ClusterNode> c, 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 and 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 and Description
static String	IgniteUtils.addressesAsString(ClusterNode node) Returns string representation of node addresses.
static CacheAtomicityMode	IgniteUtils.atomicityMode(ClusterNode n, String cacheName) Gets cache mode or a cache on given node or null if cache is not present on given node.
static GridCacheAttributes[]	IgniteUtils.cacheAttributes(ClusterNode n) Gets cache attributes for the node.
static GridCacheAttributes	IgniteUtils.cacheAttributes(ClusterNode n, String cacheName) Gets cache attributes from the given node for the given cache name.
static CacheMode	IgniteUtils.cacheMode(ClusterNode n, String cacheName) Gets cache mode or a cache on given node or null if cache is not present on given node.
static Collection<String>	IgniteUtils.cacheNames(ClusterNode n) Gets view on all cache names started on the node.
static CacheDistributionMode	IgniteUtils.distributionMode(ClusterNode n, String cacheName) Gets cache distribution mode on given node or null if cache is not present on given node.
static boolean	IgniteUtils.hasCache(ClusterNode n, String cacheName) Checks if given node has specified cache started.
static boolean	IgniteUtils.hasCaches(ClusterNode n) Checks if given node has at least one cache.
static boolean	IgniteUtils.hasNearCache(ClusterNode n, String cacheName) Checks if given node has near cache enabled for the specified partitioned cache.
static boolean	IgniteUtils.hasStreamer(ClusterNode n, String streamerName) Checks if given node has specified streamer started.
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 Collection<InetAddress>	IgniteUtils.toInetAddresses(ClusterNode node) Returns tha list of resolved inet addresses.
static String	IgniteUtils.toShortString(ClusterNode n) Short node representation.
static Collection<InetSocketAddress>	IgniteUtils.toSocketAddresses(ClusterNode node, int port) Returns tha list of resolved socket addresses.

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

Modifier and Type	Method and Description
static double	IgniteUtils.heapSize(Iterable<ClusterNode> nodes, int precision) Gets total heap size in GB rounded to specified precision.
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(Collection<? extends ClusterNode> nodes) Converts collection of nodes to collection of node IDs.
static Collection<String>	IgniteUtils.nodes2names(Collection<? extends ClusterNode> nodes) Converts collection of grid nodes to collection of grid names.
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, IgnitePredicate<ClusterNode> p) Gets oldest node out of collection of nodes.
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, 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, IgnitePredicate<ClusterNode> p) Gets youngest node out of collection of nodes.
static ClusterNode	IgniteUtils.youngest(Collection<ClusterNode> c, IgnitePredicate<ClusterNode> p) Gets youngest node out of collection of nodes.

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 and 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(Collection<UUID> nodeIds) Creates grid node predicate evaluating on the given node IDs.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.nodeForNodeIds(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 and Description
static IgnitePredicate<ClusterNode>	GridFunc.cacheNodesForNames(String... cacheNames) Gets node predicate which returns true for all nodes which have given cache names started.
static IgniteClosure<ClusterNode,UUID>	GridFunc.node2id() Gets closure which converts node to node ID.
static IgniteClosure<ClusterNode,String>	GridFunc.node2id8() Gets closure which converts node to node ID8 representation (shorter and good enough).
static IgnitePredicate<ClusterNode>	GridFunc.nodeForNodes(ClusterNode... nodes) Creates predicates that evaluates to true for each node in given collection.
static IgnitePredicate<ClusterNode>	GridFunc.nodeForNodes(Collection<? extends ClusterNode> nodes) Creates predicates that evaluates to true for each node in given collection.
static IgniteClosure<ClusterGroup,IgnitePredicate<ClusterNode>>	GridFunc.predicate() Gets closure that transform a grid projection into its predicate.

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

Modifier and Type	Method and 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 and Description
static IgnitePredicate<Event>	GridFunc.eventNode(Collection<? extends ClusterNode> nodes) Gets event predicate that returns true only if node that produced the event is one of the given.
static <T> Collection<T>	GridFunc.nodeAttributes(Collection<? extends ClusterNode> nodes, String attr) Convenient utility method that returns collection of node attributes for a given collection of grid nodes.
static IgnitePredicate<ClusterNode>	GridFunc.nodeForNodes(Collection<? extends ClusterNode> nodes) Creates predicates that evaluates to true for each node in given collection.
static Collection<String>	GridFunc.nodeId8s(Collection<? extends ClusterNode> nodes) Convenient utility method that returns collection of node ID8s for a given collection of grid nodes.
static Collection<UUID>	GridFunc.nodeIds(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 and Description
GridNodePredicate(ClusterNode... nodes) Creates node predicate that evaluates to true for all provided nodes.

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 and Description
ClusterNode	GridNioRecoveryDescriptor.node()

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

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

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

Constructor and Description
GridNioRecoveryDescriptor(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 and Description
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 and Description
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.misc

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

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

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

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

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

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

Modifier and Type	Method and Description
protected Map<? extends ComputeJob,ClusterNode>	VisorNodeDataCollectorTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<VisorNodeDataCollectorTaskArg> arg) Actual map logic.

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

Modifier and Type	Method and Description
protected Map<? extends ComputeJob,ClusterNode>	VisorNodeDataCollectorTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<VisorNodeDataCollectorTaskArg> arg) Actual map logic.

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

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

Modifier and Type	Method and Description
protected Map<? extends ComputeJob,ClusterNode>	VisorQueryCleanupTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<Map<UUID,Collection<String>>> arg) Actual map logic.

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

Modifier and Type	Method and Description
protected Map<? extends ComputeJob,ClusterNode>	VisorQueryCleanupTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<Map<UUID,Collection<String>>> 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 and Description
static void	VisorTaskUtils.logMapped(IgniteLogger log, Class<?> clazz, Collection<ClusterNode> nodes) Log task mapped.

Uses of ClusterNode in org.apache.ignite.plugin

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

Modifier and Type	Method and Description
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 and 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 and Description
void	PluginProvider.validateNewNode(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.services

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

Modifier and Type	Method and 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 and Description
void	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 and Description
ClusterNode	IgniteSpiContext.localNode() Gets local grid node.
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 and Description
Collection<ClusterNode>	IgniteSpiContext.nodes() Gets a collection of all grid nodes.
Collection<ClusterNode>	IgniteSpiContext.remoteDaemonNodes() Gets a collection of all remote daemon nodes in topology.
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 and Description
protected void	IgniteSpiAdapter.checkConfigurationConsistency0(IgniteSpiContext spiCtx, ClusterNode node, boolean starting) Method which is called in the end of checkConfigurationConsistency() method.
void	IgniteSpiContext.send(ClusterNode node, Serializable msg, String topic) Sends a message to a remote node.
IgniteSpiNodeValidationResult	IgniteSpiContext.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.spi.communication

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

Modifier and Type	Method and 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 and Description
protected void	TcpCommunicationSpi.checkConfigurationConsistency0(IgniteSpiContext spiCtx, ClusterNode node, boolean starting) Method which is called in the end of checkConfigurationConsistency() method.
protected GridCommunicationClient	TcpCommunicationSpi.createNioClient(ClusterNode node)
protected GridCommunicationClient	TcpCommunicationSpi.createTcpClient(ClusterNode node) Establish TCP connection to remote node and returns client.
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg) Sends given message to destination node.

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

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

Modifier and Type	Method and Description
ClusterNode	DiscoverySpi.getLocalNode() Gets local node.
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 and Description
Collection<ClusterNode>	DiscoverySpi.getRemoteNodes() Gets collection of remote nodes in grid or empty collection if no remote nodes found.

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

Modifier and Type	Method and Description
SecurityContext	DiscoverySpiNodeAuthenticator.authenticateNode(ClusterNode node, GridSecurityCredentials cred) Security credentials.
void	DiscoverySpiListener.onDiscovery(int type, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot, Map<Long,Collection<ClusterNode>> topHist, Serializable data) Notification for grid node discovery events.

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

Modifier and Type	Method and Description
void	DiscoverySpiListener.onDiscovery(int type, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot, Map<Long,Collection<ClusterNode>> topHist, Serializable data) Notification for grid node discovery events.
void	DiscoverySpiListener.onDiscovery(int type, long topVer, ClusterNode node, Collection<ClusterNode> topSnapshot, Map<Long,Collection<ClusterNode>> topHist, Serializable data) Notification for grid node discovery events.

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 and Description
ClusterNode	TcpDiscoverySpi.getNode(UUID nodeId) Gets node by ID.
ClusterNode	TcpClientDiscoverySpi.getNode(UUID nodeId) Gets node by ID.

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

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

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 and Description
class	TcpDiscoveryNode Node for TcpDiscoverySpi.

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 and 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 and Description
void	TcpDiscoveryNodeAddedMessage.topologyHistory(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 and 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 and 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 and 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 and 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 and 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 and 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 and 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 and 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.loadbalancing

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

Modifier and Type	Method and 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 and 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 and 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 and Description
double	AdaptiveCpuLoadProbe.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.
double	AdaptiveLoadProbe.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.

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

Modifier and Type	Method and 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 and 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 and 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 and 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 and 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.streamer

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

Modifier and Type	Method and Description
<T> ClusterNode	StreamerEventRouter.route(StreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.

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

Modifier and Type	Method and Description
<T> Map<ClusterNode,Collection<T>>	StreamerEventRouter.route(StreamerContext ctx, String stageName, Collection<T> evts) Selects a node for given events that should be processed by a stage with given name.
<T> Map<ClusterNode,Collection<T>>	StreamerEventRouterAdapter.route(StreamerContext ctx, String stageName, Collection<T> evts) Selects a node for given events that should be processed by a stage with given name.

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

Modifier and Type	Method and Description
void	StreamerContext.broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	StreamerContext.query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.

Uses of ClusterNode in org.apache.ignite.streamer.router

Methods in org.apache.ignite.streamer.router that return ClusterNode

Modifier and Type	Method and Description
ClusterNode	StreamerRandomEventRouter.route(StreamerContext ctx, String stageName, Object evt) Selects a node for given event that should be processed by a stage with given name.
ClusterNode	StreamerRoundRobinEventRouter.route(StreamerContext ctx, String stageName, Object evt) Selects a node for given event that should be processed by a stage with given name.
<T> ClusterNode	StreamerCacheAffinityEventRouter.route(StreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.
<T> ClusterNode	StreamerLocalEventRouter.route(StreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.
<T> ClusterNode	StreamerAffinityEventRouter.route(StreamerContext ctx, String stageName, T evt) Selects a node for given event that should be processed by a stage with given name.

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

Modifier and Type	Method and Description
<T> Map<ClusterNode,Collection<T>>	StreamerLocalEventRouter.route(StreamerContext ctx, String stageName, Collection<T> evts) Selects a node for given events that should be processed by a stage with given name.

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

Constructor and Description
StreamerRandomEventRouter(Collection<IgnitePredicate<ClusterNode>> predicates) Constructs random event router with optional set of filters to apply to streamer projection.