| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgniteCluster.localNode()
Gets local grid node.
|
<K> ClusterNode |
IgniteCluster.mapKeyToNode(String cacheName,
K key)
Deprecated.
Use
Affinity.mapKeyToNode(Object) instead. |
| Modifier and Type | Method and Description |
|---|---|
<K> Map<ClusterNode,Collection<K>> |
IgniteCluster.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
Deprecated.
Use
Affinity.mapKeysToNodes(Collection) instead. |
Collection<ClusterNode> |
IgniteCluster.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
Affinity.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
ClusterNode |
Affinity.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
AffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
List<ClusterNode> |
AffinityFunctionContext.currentTopologySnapshot()
Gets current topology snapshot.
|
Map<ClusterNode,Collection<K>> |
Affinity.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Collection<ClusterNode> |
Affinity.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Map<Integer,ClusterNode> |
Affinity.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Collection<ClusterNode> |
Affinity.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
List<ClusterNode> |
AffinityFunctionContext.previousAssignment(int part)
Gets affinity assignment for given partition on previous topology version.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
Affinity.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
Affinity.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
boolean |
Affinity.isBackup(ClusterNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
Affinity.isPrimary(ClusterNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
Affinity.isPrimaryOrBackup(ClusterNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
This method is essentially equivalent to calling
"Affinity.isPrimary(ClusterNode, Object) || Affinity.isBackup(ClusterNode, Object))",
however it is more efficient as it makes both checks at once. |
int[] |
Affinity.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
Object |
AffinityNodeHashResolver.resolve(ClusterNode node)
Deprecated.
|
Object |
AffinityNodeAddressHashResolver.resolve(ClusterNode node)
Deprecated.
Resolve alternate hash value for the given Grid node.
|
Object |
AffinityNodeIdHashResolver.resolve(ClusterNode node)
Deprecated.
Resolve alternate hash value for the given Grid node.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
FairAffinityFunction.assignPartitions(AffinityFunctionContext ctx)
Gets affinity nodes for a partition.
|
IgniteBiPredicate<ClusterNode,ClusterNode> |
FairAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
IgniteBiPredicate<ClusterNode,ClusterNode> |
FairAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FairAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Sets optional backup filter.
|
void |
FairAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Sets optional backup filter.
|
| Constructor and Description |
|---|
FairAffinityFunction(int parts,
IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
FairAffinityFunction(int parts,
IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
RendezvousAffinityFunction.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>> |
RendezvousAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
IgniteBiPredicate<ClusterNode,ClusterNode> |
RendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
IgniteBiPredicate<ClusterNode,ClusterNode> |
RendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
RendezvousAffinityFunction.resolveNodeHash(ClusterNode node)
Resolves node hash.
|
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
RendezvousAffinityFunction.assignPartition(int part,
List<ClusterNode> nodes,
int backups,
Map<UUID,Collection<ClusterNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
List<ClusterNode> |
RendezvousAffinityFunction.assignPartition(int part,
List<ClusterNode> nodes,
int backups,
Map<UUID,Collection<ClusterNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
void |
RendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Sets optional backup filter.
|
void |
RendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Sets optional backup filter.
|
| Constructor and Description |
|---|
RendezvousAffinityFunction(int parts,
IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
RendezvousAffinityFunction(int parts,
IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
ClusterGroup.node()
Gets first node from the list of nodes in this cluster group.
|
ClusterNode |
ClusterGroup.node(UUID nid)
Gets a node for given ID from this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
ClusterGroup.nodes()
Gets the read-only collection of nodes in this cluster group.
|
IgnitePredicate<ClusterNode> |
ClusterGroup.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroup.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
ClusterGroup.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ComputeTaskContinuousMapper.send(ComputeJob job,
ClusterNode node)
Sends given job to a specific grid node.
|
| 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> |
ComputeTaskSplitAdapter.map(List<ClusterNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
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.
|
void |
ComputeTaskContinuousMapper.send(Map<? extends ComputeJob,ClusterNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
| 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.
|
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate<ClusterNode> |
CacheConfiguration.ALL_NODES
Filter that accepts all nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
CollectionConfiguration.getNodeFilter() |
IgnitePredicate<ClusterNode> |
CacheConfiguration.getNodeFilter()
Gets filter which determines on what nodes the cache should be started.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheConfiguration.IgniteAllNodesPredicate.apply(ClusterNode clusterNode)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CollectionConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter) |
CacheConfiguration<K,V> |
CacheConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets filter which determines on what nodes the cache should be started.
|
boolean |
TopologyValidator.validate(Collection<ClusterNode> nodes)
Validates topology.
|
| 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 |
EventAdapter.node()
Node where event occurred and was recorded
|
ClusterNode |
Event.node()
Node where event occurred and was recorded
|
ClusterNode |
JobEvent.taskNode()
Get node where parent task of the job has originated.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
DiscoveryEvent.topologyNodes()
Gets topology nodes from topology snapshot.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoveryEvent.topologySnapshot(long topVer,
Collection<ClusterNode> topSnapshot)
Sets the topology snapshot.
|
| 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,
String qryType,
String cacheName,
String clsName,
String clause,
IgniteBiPredicate<K,V> scanQryFilter,
CacheEntryEventSerializableFilter<K,V> contQryFilter,
Object[] args,
UUID subjId,
String taskName) |
CacheQueryReadEvent(ClusterNode node,
String msg,
int type,
String qryType,
String cacheName,
String clsName,
String clause,
IgniteBiPredicate<K,V> scanQryFilter,
CacheEntryEventSerializableFilter<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.
|
| 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.
|
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
static Comparator<ClusterNode> |
GridNodeOrderComparator.INSTANCE |
| 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 |
GridCachePluginContext.localNode()
Gets local grid node.
|
ClusterNode |
IgniteKernal.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
GridPluginContext.nodes()
Gets a collection of all grid nodes.
|
| Modifier and Type | Method and Description |
|---|---|
int |
GridNodeOrderComparator.compare(ClusterNode n1,
ClusterNode n2) |
void |
GridJobResultImpl.setNode(ClusterNode node) |
IgniteNodeValidationResult |
GridComponent.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
IgniteNodeValidationResult |
GridPluginComponent.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Constructor and Description |
|---|
ClusterLocalNodeMetricsMXBeanImpl(ClusterNode node) |
GridJobResultImpl(ComputeJob job,
IgniteUuid jobId,
ClusterNode node,
GridJobSiblingImpl sib) |
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.p
Cluster group predicate.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgniteClusterAsyncImpl.localNode()
Gets local grid node.
|
ClusterNode |
IgniteClusterImpl.localNode()
Gets local grid node.
|
<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.
|
<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.
|
ClusterNode |
ClusterGroupAdapter.node()
Gets first node from the list of nodes in this cluster group.
|
ClusterNode |
IgniteClusterAsyncImpl.node()
Gets first node from the list of nodes in this cluster group.
|
ClusterNode |
ClusterGroupAdapter.node(UUID id)
Gets a node for given ID from this cluster group.
|
ClusterNode |
IgniteClusterAsyncImpl.node(UUID id)
Gets a node for given ID from this cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
<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.
|
<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.
|
Collection<ClusterNode> |
ClusterGroupAdapter.nodes()
Gets the read-only collection of nodes in this cluster group.
|
Collection<ClusterNode> |
IgniteClusterAsyncImpl.nodes()
Gets the read-only collection of nodes in this cluster group.
|
IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
IgnitePredicate<ClusterNode> |
IgniteClusterAsyncImpl.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
Collection<ClusterNode> |
IgniteClusterAsyncImpl.topology(long topVer)
Gets a topology by version.
|
Collection<ClusterNode> |
IgniteClusterImpl.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroupAdapter.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroupAdapter.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroupAdapter.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
ClusterGroupAdapter.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forOthers(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for nodes other than the given nodes.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroupAdapter.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
IgniteClusterAsyncImpl.forNodes(Collection<? extends ClusterNode> nodes)
Creates a cluster group over a given set of nodes.
|
ClusterGroup |
ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a new cluster group which includes all nodes that pass the given predicate filter.
|
| Constructor and Description |
|---|
ClusterGroupAdapter(GridKernalContext ctx,
UUID subjId,
IgnitePredicate<ClusterNode> p) |
| Modifier and Type | Method and Description |
|---|---|
IgniteNodeValidationResult |
GridManagerAdapter.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.send(ClusterNode node,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.send(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.send(ClusterNode node,
Object topic,
Message msg,
byte plc) |
void |
GridIoManager.send(ClusterNode node,
Object topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackC) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.send(Collection<? extends ClusterNode> nodes,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.send(Collection<? extends ClusterNode> nodes,
Object topic,
Message msg,
byte plc) |
void |
GridIoManager.sendOrderedMessage(Collection<? extends ClusterNode> nodes,
Object topic,
Message msg,
byte 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.
|
| 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) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridDiscoveryManager.getAlive(UUID nodeId) |
ClusterNode |
GridDiscoveryManager.localNode() |
ClusterNode |
GridDiscoveryManager.node(AffinityTopologyVersion topVer,
UUID id)
Gets node from history for given topology version.
|
ClusterNode |
GridDiscoveryManager.node(UUID nodeId) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
GridDiscoveryManager.aliveCacheNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.aliveNodesWithCaches(AffinityTopologyVersion topVer)
Gets alive nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.aliveRemoteCacheNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache remote nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.aliveRemoteServerNodesWithCaches(AffinityTopologyVersion topVer)
Gets alive remote server nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.aliveServerNodesWithCaches(AffinityTopologyVersion topVer)
Gets alive server nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.allNodes() |
Collection<ClusterNode> |
GridDiscoveryManager.cacheAffinityNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given name that participate in affinity calculation.
|
Collection<ClusterNode> |
GridDiscoveryManager.cacheNodes(AffinityTopologyVersion topVer)
Gets all nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.cacheNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.daemonNodes() |
Collection<ClusterNode> |
GridDiscoveryManager.nodes(AffinityTopologyVersion topVer)
Gets all nodes for given topology version.
|
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(AffinityTopologyVersion topVer)
Gets cache remote nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.remoteCacheNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache remote nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.remoteNodes() |
List<ClusterNode> |
GridDiscoveryManager.serverNodes(AffinityTopologyVersion topVer) |
Collection<ClusterNode> |
GridDiscoveryManager.topology(long topVer)
Gets topology by specified version from history storage.
|
Collection<ClusterNode> |
GridDiscoveryTopologySnapshot.topologyNodes()
Gets topology nodes from topology snapshot.
|
NavigableMap<IgniteProductVersion,Collection<ClusterNode>> |
GridDiscoveryManager.topologyVersionMap()
Gets topology grouped by node versions.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDiscoveryManager.alive(ClusterNode node) |
boolean |
GridDiscoveryManager.cacheAffinityNode(ClusterNode node,
String cacheName)
Checks if node is a data node for the given cache.
|
boolean |
GridDiscoveryManager.cacheClientNode(ClusterNode node,
String cacheName) |
boolean |
GridDiscoveryManager.cacheNearNode(ClusterNode node,
String cacheName) |
boolean |
GridDiscoveryManager.cacheNode(ClusterNode node,
String cacheName) |
Map<String,CacheMode> |
GridDiscoveryManager.nodeCaches(ClusterNode node) |
void |
CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer,
ClusterNode snd,
T msg) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.setCacheFilter(String cacheName,
IgnitePredicate<ClusterNode> filter,
boolean nearEnabled,
CacheMode cacheMode)
Adds dynamic cache filter.
|
long |
GridDiscoveryManager.topologyHash(Iterable<? extends ClusterNode> nodes)
Gets topology hash for given set of nodes.
|
| Constructor and Description |
|---|
GridDiscoveryTopologySnapshot(long topVer,
Collection<ClusterNode> topNodes)
Creates a topology snapshot with given topology version and topology nodes.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p,
Collection<? extends ClusterNode> nodes,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
Object affKey,
String affCacheName) |
ClusterNode |
GridFailoverContextImpl.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
Object affKey,
String affCacheName) |
ClusterNode |
GridFailoverContextImpl.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
ComputeLoadBalancer |
GridLoadBalancerManager.getLoadBalancer(GridTaskSessionImpl ses,
List<ClusterNode> top) |
| Modifier and Type | Method and Description |
|---|---|
IgniteNodeValidationResult |
GridProcessorAdapter.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
<K> ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key)
Maps single key to a node.
|
<K> ClusterNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key,
AffinityTopologyVersion topVer)
Maps single key to a node.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridAffinityAssignment.assignment() |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer) |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer,
DiscoveryEvent discoEvt)
Calculates affinity cache for given topology version.
|
List<ClusterNode> |
GridAffinityFunctionContextImpl.currentTopologySnapshot()
Gets current topology snapshot.
|
List<ClusterNode> |
GridAffinityAssignment.get(int part)
Get affinity nodes for partition.
|
List<List<ClusterNode>> |
GridAffinityAssignmentCache.idealAssignment() |
List<List<ClusterNode>> |
GridAffinityAssignment.idealAssignment() |
<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,
AffinityTopologyVersion topVer)
Map single key to primary and backup nodes.
|
List<ClusterNode> |
GridAffinityAssignmentCache.nodes(int part,
AffinityTopologyVersion topVer)
Gets affinity nodes for specified partition.
|
List<ClusterNode> |
GridAffinityFunctionContextImpl.previousAssignment(int part)
Gets affinity assignment for given partition on previous topology version.
|
Set<ClusterNode> |
GridAffinityAssignment.primaryPartitionNodes() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridAffinityAssignmentCache.idealAssignment(List<List<ClusterNode>> assignment) |
void |
GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment)
Initializes affinity with given topology version and assignment.
|
| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridKernalContext ctx,
String cacheName,
AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
boolean locCache)
Constructs affinity cached calculations.
|
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
AffinityTopologyVersion topVer,
int backups) |
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
List<List<ClusterNode>> prevAssignment,
DiscoveryEvent discoEvt,
AffinityTopologyVersion topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridCacheSharedContext.localNode() |
ClusterNode |
GridCacheContext.localNode() |
ClusterNode |
GridCacheSharedContext.node(UUID nodeId) |
ClusterNode |
GridCacheContext.node(UUID nodeId) |
static ClusterNode |
GridCacheUtils.oldest(Collection<ClusterNode> nodes) |
static ClusterNode |
GridCacheUtils.oldestAliveCacheServerNode(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer)
Gets oldest alive server node with at least one cache configured for specified topology version.
|
ClusterNode |
GridCacheAffinityManager.primary(int part,
AffinityTopologyVersion topVer) |
static ClusterNode |
GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes) |
ClusterNode |
GridCacheAffinityManager.primary(Object key,
AffinityTopologyVersion topVer) |
static ClusterNode |
GridCacheUtils.primaryNode(GridCacheContext ctx,
Object key)
Gets primary node on which given key is cached.
|
| 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,
AffinityTopologyVersion topOrder)
Gets DHT affinity nodes.
|
static Collection<ClusterNode> |
GridCacheUtils.aliveRemoteServerNodesWithCaches(GridCacheSharedContext ctx,
AffinityTopologyVersion topOrder)
Gets alive remote nodes with at least one cache configured.
|
static Collection<ClusterNode> |
GridCacheUtils.allNodes(GridCacheContext ctx,
AffinityTopologyVersion topOrder)
Gets all nodes on which cache with the same name is started.
|
static Collection<ClusterNode> |
GridCacheUtils.allNodes(GridCacheSharedContext ctx,
AffinityTopologyVersion topOrder)
Gets all nodes with at least one cache configured.
|
List<List<ClusterNode>> |
GridCacheAffinityManager.assignments(AffinityTopologyVersion topVer) |
static Collection<ClusterNode> |
GridCacheUtils.backups(Collection<ClusterNode> nodes) |
Collection<ClusterNode> |
GridCacheAffinityManager.backups(int part,
AffinityTopologyVersion topVer) |
Collection<ClusterNode> |
GridCacheAffinityManager.backups(Object key,
AffinityTopologyVersion topVer) |
List<List<ClusterNode>> |
GridCacheAffinityManager.idealAssignment() |
Collection<ClusterNode> |
GridCacheMvccCandidate.mappedDhtNodes() |
Collection<ClusterNode> |
GridCacheMvccCandidate.mappedNearNodes() |
static Map<UUID,Collection<ClusterNode>> |
GridCacheUtils.neighbors(Collection<ClusterNode> topSnapshot)
Builds neighborhood map for all nodes in snapshot.
|
static Collection<ClusterNode> |
GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood,
Iterable<ClusterNode> nodes)
Returns neighbors for all
nodes. |
static Comparator<ClusterNode> |
GridCacheUtils.nodeComparator(boolean asc) |
List<ClusterNode> |
GridCacheAffinityManager.nodes(int part,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridCacheAffinityManager.nodes(Object key,
AffinityTopologyVersion topVer) |
static Collection<ClusterNode> |
GridCacheUtils.remoteNodes(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer)
Gets remote nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridCacheAffinityManager.remoteNodes(Iterable keys,
AffinityTopologyVersion topVer) |
| 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(ClusterNode node,
IgnitePredicate<ClusterNode> filter) |
boolean |
GridCacheAffinityManager.backup(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.belongs(ClusterNode node,
int part,
AffinityTopologyVersion topVer) |
static CacheEntryPredicate |
GridCacheUtils.cachePrimary(Affinity aff,
ClusterNode n) |
static boolean |
GridCacheUtils.clientNode(ClusterNode node) |
static boolean |
GridCacheUtils.clientNodeDirect(ClusterNode node) |
boolean |
GridCacheContext.isLocalNode(ClusterNode n) |
static boolean |
GridCacheUtils.isSwapEnabled(ClusterNode node)
Checks if swap is enabled on node.
|
void |
GridCacheProcessor.onDiscoveryEvent(int type,
ClusterNode node,
AffinityTopologyVersion topVer) |
void |
CacheAffinitySharedManager.onDiscoveryEvent(int type,
ClusterNode node,
AffinityTopologyVersion topVer)
Callback invoked from discovery thread when discovery message is received.
|
boolean |
GridCacheAffinityManager.primary(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.primary(ClusterNode n,
Object key,
AffinityTopologyVersion topVer) |
void |
GridCacheMvccCandidate.removeMappedNode(ClusterNode node) |
void |
GridCacheIoManager.send(ClusterNode node,
GridCacheMessage msg,
byte plc)
Sends communication message.
|
void |
GridCacheIoManager.sendNoRetry(ClusterNode node,
GridCacheMessage msg,
byte plc)
Sends message without retries and node ping in case of error.
|
void |
GridCacheIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
GridCacheMessage msg,
byte plc,
long timeout) |
IgniteNodeValidationResult |
GridCacheProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
GridCacheUtils.affinityNode(ClusterNode node,
IgnitePredicate<ClusterNode> filter) |
boolean |
GridCacheContext.allowFastLocalRead(int part,
List<ClusterNode> affNodes,
AffinityTopologyVersion topVer) |
static Collection<ClusterNode> |
GridCacheUtils.backups(Collection<ClusterNode> nodes) |
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheMvccCandidate.mappedNodeIds(Collection<ClusterNode> mappedDhtNodes,
Collection<ClusterNode> mappedNearNodes) |
void |
GridCacheMvccCandidate.mappedNodeIds(Collection<ClusterNode> mappedDhtNodes,
Collection<ClusterNode> mappedNearNodes) |
static Map<UUID,Collection<ClusterNode>> |
GridCacheUtils.neighbors(Collection<ClusterNode> topSnapshot)
Builds neighborhood map for all nodes in snapshot.
|
static Collection<ClusterNode> |
GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood,
Iterable<ClusterNode> nodes)
Returns neighbors for all
nodes. |
static Collection<ClusterNode> |
GridCacheUtils.neighborsForNodes(Map<UUID,Collection<ClusterNode>> neighborhood,
Iterable<ClusterNode> nodes)
Returns neighbors for all
nodes. |
static ClusterNode |
GridCacheUtils.oldest(Collection<ClusterNode> nodes) |
static ClusterNode |
GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes) |
void |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage msg,
byte plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
void |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage msg,
byte plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
GridCacheAffinityProxy.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
GridCacheAffinityImpl.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
GridCacheAffinityProxy.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
int[] |
GridCacheAffinityImpl.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node 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
"Affinity.isPrimary(ClusterNode, Object) || Affinity.isBackup(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
"Affinity.isPrimary(ClusterNode, Object) || Affinity.isBackup(ClusterNode, Object))",
however it is more efficient as it makes both checks at once. |
int[] |
GridCacheAffinityProxy.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
int[] |
GridCacheAffinityImpl.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteNodeValidationResult |
CacheObjectBinaryProcessorImpl.validateNode(ClusterNode rmtNode)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridDistributedTxMapping.node() |
| Constructor and Description |
|---|
GridDistributedTxMapping(ClusterNode node) |
| Modifier and Type | Method and Description |
|---|---|
protected ClusterNode |
CacheDistributedGetFutureAdapter.affinityNode(List<ClusterNode> affNodes)
Affinity node to send get request to.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.affinityAssignment(GridDiscoveryManager disco) |
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(GridDiscoveryManager disco) |
Set<ClusterNode> |
GridDhtTxLocalAdapter.lockTransactionNodes() |
List<ClusterNode> |
GridDhtPartitionTopology.moving(int p) |
List<ClusterNode> |
GridClientPartitionTopology.moving(int p) |
List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxLocalAdapter.addLockTransactionNode(ClusterNode node) |
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
CacheEntryPredicate[] filter0) |
void |
GridDhtCacheEntry.removeMapping(GridCacheVersion ver,
ClusterNode mappedNode) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxMapping.addMapping(List<ClusterNode> nodes)
Adds information about next mapping.
|
protected ClusterNode |
CacheDistributedGetFutureAdapter.affinityNode(List<ClusterNode> affNodes)
Affinity node to send get request to.
|
void |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(List<List<ClusterNode>> idealAffAssignment) |
GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
| Constructor and Description |
|---|
GridDhtAffinityAssignmentResponse(int cacheId,
AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment,
boolean sndNodeIds) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsExchangeFuture.onAffinityChangeMessage(ClusterNode node,
CacheAffinityChangeMessage msg)
Affinity change message callback, processed from the same thread as
GridDhtPartitionsExchangeFuture.onNodeLeft(org.apache.ignite.cluster.ClusterNode). |
void |
GridDhtPartitionsExchangeFuture.onNodeLeft(ClusterNode node)
Node left callback, processed from the same thread as
GridDhtPartitionsExchangeFuture.onAffinityChangeMessage(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.internal.processors.cache.CacheAffinityChangeMessage). |
void |
GridDhtPartitionsExchangeFuture.onReceive(ClusterNode node,
GridDhtPartitionsFullMessage msg) |
void |
GridDhtPartitionsExchangeFuture.onReceive(ClusterNode node,
GridDhtPartitionsSingleMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridNearLockMapping.node() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxLocal.addKeyMapping(IgniteTxKey key,
ClusterNode node)
Adds key mapping to dht mapping.
|
| Constructor and Description |
|---|
GridNearLockMapping(ClusterNode node,
KeyCacheObject firstKey)
Creates near lock mapping for specified node and key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDistributedQueryManager.loadPage(long id,
GridCacheQueryAdapter<?> qry,
Collection<ClusterNode> nodes,
boolean all)
Loads page.
|
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.
|
CacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed query.
|
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.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed fields 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.
|
GridCloseableIterator<Map.Entry<K,V>> |
GridCacheDistributedQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
GridCloseableIterator<Map.Entry<K,V>> |
GridCacheLocalQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
abstract GridCloseableIterator<Map.Entry<K,V>> |
GridCacheQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
| 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) |
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
boolean locOnly,
int bufSize,
long interval,
boolean autoUnsubscribe,
IgnitePredicate<ClusterNode> prjPred) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataStreamerImpl.ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgfsDataManager.affinityNode(Object affinityKey)
Maps affinity key to node.
|
| 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,
byte plc) |
| Constructor and Description |
|---|
IgfsBlockLocationImpl(long start,
long len,
Collection<ClusterNode> nodes) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobProcessor.processJobExecuteRequest(ClusterNode node,
GridJobExecuteRequest req) |
| Modifier and Type | Method and Description |
|---|---|
IgniteNodeValidationResult |
OsDiscoveryNodeValidationProcessor.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformContextImpl.addNode(ClusterNode node)
Sends node info to native platform, if necessary.
|
void |
PlatformContext.addNode(ClusterNode node)
Sends node info to native platform, if necessary.
|
void |
PlatformContextImpl.writeNode(BinaryRawWriterEx writer,
ClusterNode node)
Writes a node id to a stream and sends node info to native platform, if necessary.
|
void |
PlatformContext.writeNode(BinaryRawWriterEx writer,
ClusterNode node)
Writes a node id to a stream and sends node info to native platform, if necessary.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformContextImpl.writeNodes(BinaryRawWriterEx writer,
Collection<ClusterNode> nodes)
Writes multiple node ids to a stream and sends node info to native platform, if necessary.
|
void |
PlatformContext.writeNodes(BinaryRawWriterEx writer,
Collection<ClusterNode> nodes)
Writes multiple node ids to a stream and sends node info to native platform, if necessary.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PlatformClusterNodeFilterImpl.apply(ClusterNode clusterNode)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingSingleClosureAffinityTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformFullTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingSingleClosureAffinityTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
PlatformFullTask.map(List<ClusterNode> subgrid,
Object arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CachePluginManager.validateRemotes(CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
GridSecurityProcessor.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Authenticates grid node with it's attributes via underlying Authenticator.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
GridOsSecurityProcessor.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Authenticates grid node with it's attributes via underlying Authenticator.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridServiceAssignments.nodeFilter() |
| 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.
|
| 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).
|
| Modifier and Type | Method and Description |
|---|---|
static String |
IgniteUtils.addressesAsString(ClusterNode node)
Returns string representation of node addresses.
|
static GridCacheAttributes[] |
IgniteUtils.cacheAttributes(ClusterNode n)
Gets cache attributes for the node.
|
static boolean |
IgniteUtils.hasNearCache(ClusterNode n,
String cacheName)
Checks if given node has near cache enabled for the specified
partitioned cache.
|
static double |
IgniteUtils.heapSize(ClusterNode node,
int precision)
Gets heap size in GB rounded to specified precision.
|
static IgniteProductVersion |
IgniteUtils.productVersion(ClusterNode node)
Gets node product version based on node attributes.
|
static boolean |
IgniteUtils.sameMacs(ClusterNode loc,
ClusterNode rmt) |
static 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static <T extends ClusterNode> |
GridFunc.localNode(UUID locNodeId)
Gets predicate that evaluates to
true only for given local node ID. |
static <T extends ClusterNode> |
GridFunc.nodeForNodeId(UUID nodeId)
Creates grid node predicate evaluating on the given node ID.
|
static <T extends ClusterNode> |
GridFunc.nodeForNodeIds(Collection<UUID> nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static <T extends ClusterNode> |
GridFunc.remoteNodes(UUID locNodeId)
Gets predicate that evaluates to
false for given local node ID. |
| Modifier and Type | Method and Description |
|---|---|
static IgniteClosure<ClusterNode,UUID> |
GridFunc.node2id()
Gets closure which converts node to node ID.
|
static IgnitePredicate<ClusterNode> |
GridFunc.nodeForNodes(ClusterNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
| 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. |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Constructor and Description |
|---|
GridNodePredicate(ClusterNode... nodes)
Creates node predicate that evaluates to
true for all
provided nodes. |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridNioRecoveryDescriptor.node() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNioRecoveryDescriptor.nodeAlive(ClusterNode node) |
| Constructor and Description |
|---|
GridNioRecoveryDescriptor(int queueLimit,
ClusterNode node,
IgniteLogger log) |
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
VisorGatewayTask.map(List<ClusterNode> subgrid,
Object[] args)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
VisorGatewayTask.map(List<ClusterNode> subgrid,
Object[] args)
This method is called to map or split grid task into multiple grid jobs.
|
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<? extends ComputeJob,ClusterNode> |
VisorNodeDataCollectorTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<VisorNodeDataCollectorTaskArg> arg)
Actual map logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<? extends ComputeJob,ClusterNode> |
VisorNodeDataCollectorTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<VisorNodeDataCollectorTaskArg> arg)
Actual map logic.
|
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
VisorTaskUtils.logMapped(IgniteLogger log,
Class<?> clazz,
Collection<ClusterNode> nodes)
Log task mapped.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
PluginContext.localNode()
Gets local grid node.
|
ClusterNode |
CachePluginContext.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
PluginContext.nodes()
Gets a collection of all grid nodes.
|
| 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.
|
void |
CachePluginProvider.validateRemote(CacheConfiguration locCfg,
C locPluginCcfg,
CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ServiceConfiguration.getNodeFilter()
Gets node filter used to filter nodes on which the service will be deployed.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected ClusterNode |
IgniteSpiAdapter.getLocalNode() |
ClusterNode |
IgniteSpiContext.localNode()
Gets local grid node.
|
ClusterNode |
IgniteSpiContext.node(UUID nodeId)
Gets a node instance based on its ID.
|
| 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.
|
| 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.
|
IgniteNodeValidationResult |
IgniteSpiContext.validateNode(ClusterNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CommunicationSpi.sendMessage(ClusterNode destNode,
T msg)
Sends given message to destination node.
|
| 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.createShmemClient(ClusterNode node,
Integer port) |
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.
|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg,
IgniteInClosure<IgniteException> ackC)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
DiscoverySpi.getLocalNode()
Gets local node.
|
ClusterNode |
DiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
DiscoverySpiNodeAuthenticator.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Security credentials.
|
void |
DiscoverySpiListener.onDiscovery(int type,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot,
Map<Long,Collection<ClusterNode>> topHist,
DiscoverySpiCustomMessage data)
Notification for grid node discovery events.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DiscoverySpiListener.onDiscovery(int type,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot,
Map<Long,Collection<ClusterNode>> topHist,
DiscoverySpiCustomMessage data)
Notification for grid node discovery events.
|
void |
DiscoverySpiListener.onDiscovery(int type,
long topVer,
ClusterNode node,
Collection<ClusterNode> topSnapshot,
Map<Long,Collection<ClusterNode>> topHist,
DiscoverySpiCustomMessage data)
Notification for grid node discovery events.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
TcpDiscoverySpi.getLocalNode()
Gets local node.
|
ClusterNode |
TcpDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TcpDiscoveryNode
Node for
TcpDiscoverySpi. |
| Modifier and Type | Method and Description |
|---|---|
Map<Long,Collection<ClusterNode>> |
TcpDiscoveryNodeAddedMessage.topologyHistory()
Gets topology snapshots history.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryNodeAddedMessage.topologyHistory(Map<Long,Collection<ClusterNode>> topHist)
Sets topology snapshots history.
|
| 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.
|
| 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.
|
| 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. |
| 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. |
| 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. |
| 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. |
| 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. |
| 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. |
| 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.
|
| 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.
|
| 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.
|
| 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.
|
| 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.
|
| 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.
|
| 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.
|
| 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.
|
| 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.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.6.0 Release Date : May 18 2016