| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgniteCluster.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
| 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,List<ClusterNode>> |
RendezvousAffinityFunction.getAffinityBackupFilter()
Gets optional backup filter.
|
IgniteBiPredicate<ClusterNode,List<ClusterNode>> |
RendezvousAffinityFunction.getAffinityBackupFilter()
Gets optional backup filter.
|
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.
|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setAffinityBackupFilter(IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setAffinityBackupFilter(IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.
Use
affinityBackupFilter instead. |
RendezvousAffinityFunction |
RendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.
Use
affinityBackupFilter instead. |
| 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 node)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
CollectionConfiguration |
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.
|
TaskEvent(ClusterNode node,
String msg,
int type,
IgniteUuid sesId,
String taskName,
String taskClsName,
boolean internal,
UUID subjId)
Creates task event with given parameters.
|
WalSegmentArchivedEvent(ClusterNode node,
long absWalSegmentIdx,
File archiveFile)
Creates WAL segment event
|
| 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 |
|---|---|
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 | Method and Description |
|---|---|
ClusterNode |
GridJobResultImpl.getNode()
Gets node this job executed on.
|
ClusterNode |
GridCachePluginContext.localNode()
Gets local grid node.
|
ClusterNode |
IgniteEx.localNode()
Gets local grid node.
|
ClusterNode |
IgniteKernal.localNode()
Gets local grid node.
|
ClusterNode |
GridPluginContext.localNode()
Gets local grid node.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridJobExecuteRequest.getTopologyPredicate() |
IgnitePredicate<ClusterNode> |
GridTaskSessionImpl.getTopologyPredicate() |
Collection<ClusterNode> |
GridPluginContext.nodes()
Gets a collection of all grid nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture |
IgniteKernal.sendIoTest(ClusterNode node,
byte[] payload,
boolean procFromNioThread) |
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.
|
IgniteNodeValidationResult |
GridComponent.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData) |
IgniteNodeValidationResult |
GridPluginComponent.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture |
IgniteKernal.sendIoTest(List<ClusterNode> nodes,
byte[] payload,
boolean procFromNioThread) |
| Constructor and Description |
|---|
GridJobResultImpl(ComputeJob job,
IgniteUuid jobId,
ClusterNode node,
GridJobSiblingImpl sib) |
IgniteNeedReconnectException(ClusterNode locNode,
Throwable cause) |
| Constructor and Description |
|---|
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
IgnitePredicate<ClusterNode> topPred,
byte[] topPredBytes,
byte[] siblingsBytes,
Collection<ComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
IgniteUuid clsLdrId,
DeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,IgniteUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal,
UUID subjId,
int[] cacheIds,
int part,
AffinityTopologyVersion topVer,
String execName) |
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
IgniteUuid sesId,
Collection<UUID> top,
IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup,
boolean internal,
UUID subjId,
String execName) |
| Modifier and Type | Class and Description |
|---|---|
class |
DetachedClusterNode
Representation of cluster node that isn't currently present in cluster.
|
| Modifier and Type | Field and Description |
|---|---|
static Comparator<ClusterNode> |
NodeOrderLegacyComparator.INSTANCE |
protected IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.p
Cluster group predicate.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgniteClusterImpl.localNode()
Gets local grid node.
|
ClusterNode |
IgniteClusterAsyncImpl.localNode()
Gets local grid node.
|
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 |
|---|---|
static Comparator<ClusterNode> |
NodeOrderComparator.getInstance() |
Collection<ClusterNode> |
ClusterGroupAdapter.nodes()
Gets the read-only collection of nodes in this cluster group.
|
Collection<ClusterNode> |
IgniteClusterAsyncImpl.nodes()
Gets the read-only collection of nodes in this cluster group.
|
IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
IgnitePredicate<ClusterNode> |
IgniteClusterAsyncImpl.predicate()
Gets predicate that defines a subset of nodes for this cluster group.
|
Collection<ClusterNode> |
IgniteClusterImpl.topology(long topVer)
Gets a topology by version.
|
Collection<ClusterNode> |
IgniteClusterAsyncImpl.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
int |
NodeOrderLegacyComparator.compare(ClusterNode n1,
ClusterNode n2) |
int |
NodeOrderComparator.compare(ClusterNode n1,
ClusterNode n2) |
ClusterGroup |
ClusterGroupAdapter.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
IgniteClusterAsyncImpl.forHost(ClusterNode node)
Gets cluster group consisting from the nodes in this cluster group residing on the
same host as the given node.
|
ClusterGroup |
ClusterGroupAdapter.forNode(ClusterNode node,
ClusterNode... nodes)
Creates a cluster group for the given node.
|
ClusterGroup |
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.
|
IgniteNodeValidationResult |
GridManagerAdapter.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.sendGeneric(ClusterNode node,
Object topic,
int topicOrd,
Message msg,
byte plc) |
IgniteInternalFuture<List<IgniteIoTestMessage>> |
GridIoManager.sendIoTest(ClusterNode node,
byte[] payload,
boolean procFromNioThread) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToCustomTopic(ClusterNode node,
Object topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.runIoTest(long warmup,
long duration,
int threads,
long latencyLimit,
int rangesCnt,
int payLoadSize,
boolean procFromNioThread,
List<ClusterNode> nodes) |
IgniteInternalFuture |
GridIoManager.sendIoTest(List<ClusterNode> nodes,
byte[] payload,
boolean procFromNioThread) |
void |
GridIoManager.sendToGridTopic(Collection<? extends ClusterNode> nodes,
GridTopic topic,
Message msg,
byte plc) |
void |
GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes,
Object msg,
Object topic,
boolean ordered,
long timeout,
boolean async)
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 |
DiscoCache.localNode() |
ClusterNode |
GridDiscoveryManager.node(AffinityTopologyVersion topVer,
UUID id)
Gets node from history for given topology version.
|
ClusterNode |
GridDiscoveryManager.node(UUID nodeId) |
ClusterNode |
DiscoCache.node(UUID id) |
ClusterNode |
DiscoCache.oldestAliveServerNode() |
ClusterNode |
GridDiscoveryManager.oldestAliveServerNode(AffinityTopologyVersion topVer) |
ClusterNode |
DiscoCache.serverNodeByOrder(long order) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
DiscoCache.aliveBaselineNodes()
Returns a collection of live baseline nodes.
|
Collection<ClusterNode> |
GridDiscoveryManager.aliveServerNodes() |
Collection<ClusterNode> |
DiscoCache.aliveServerNodes()
Gets collection of server nodes with at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.allNodes() |
List<ClusterNode> |
DiscoCache.allNodes() |
List<ClusterNode> |
DiscoCache.cacheGroupAffinityNodes(int grpId) |
Collection<ClusterNode> |
GridDiscoveryManager.cacheGroupAffinityNodes(int grpId,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given ID that participate in affinity calculation.
|
List<ClusterNode> |
DiscoCache.cacheNodes(Integer cacheId)
Gets all nodes that have cache with given ID.
|
List<ClusterNode> |
DiscoCache.cacheNodes(String cacheName)
Gets all nodes that have cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.cacheNodes(String cacheName,
AffinityTopologyVersion topVer)
Gets cache nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.daemonNodes() |
List<ClusterNode> |
DiscoCache.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> |
DiscoCache.remoteAliveNodesWithCaches()
Gets all alive remote nodes that have at least one cache configured.
|
Collection<ClusterNode> |
GridDiscoveryManager.remoteAliveNodesWithCaches(AffinityTopologyVersion topVer)
Gets cache remote nodes for cache with given name.
|
Collection<ClusterNode> |
GridDiscoveryManager.remoteNodes() |
List<ClusterNode> |
DiscoCache.remoteNodes() |
List<ClusterNode> |
DiscoCache.serverNodes() |
List<ClusterNode> |
GridDiscoveryManager.serverNodes(AffinityTopologyVersion topVer) |
Collection<ClusterNode> |
GridDiscoveryManager.serverTopologyNodes(long topVer)
Gets server nodes topology by specified version from snapshots history storage.
|
Collection<ClusterNode> |
GridDiscoveryManager.topology(long topVer)
Gets topology by specified version from history storage.
|
Collection<ClusterNode> |
GridDiscoveryTopologySnapshot.topologyNodes()
Gets topology nodes from topology snapshot.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDiscoveryManager.alive(ClusterNode node) |
boolean |
DiscoCache.baselineNode(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.cacheGroupAffinityNode(ClusterNode node,
int grpId)
Checks if node is a data node for the given cache group.
|
boolean |
GridDiscoveryManager.cacheNearNode(ClusterNode node,
String cacheName) |
boolean |
GridDiscoveryManager.cacheNode(ClusterNode node,
String cacheName) |
Map<String,CacheConfiguration> |
GridDiscoveryManager.nodePublicCaches(ClusterNode node) |
void |
CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer,
ClusterNode snd,
T msg) |
void |
DiscoCache.updateAlives(ClusterNode rmvd)
Removes left node from alives lists.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.addCacheGroup(CacheGroupDescriptor grpDesc,
IgnitePredicate<ClusterNode> filter,
CacheMode cacheMode) |
void |
GridDiscoveryManager.addLocalNodeInitializedEventListener(IgniteInClosure<ClusterNode> lsnr)
Adds a listener for local node initialized event.
|
| Constructor 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,
int affPartId,
String affCacheName,
AffinityTopologyVersion topVer) |
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,
int affPartId,
String affCacheName,
AffinityTopologyVersion topVer) |
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.
|
IgniteNodeValidationResult |
GridProcessorAdapter.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData) |
| 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.
|
ClusterNode |
GridAffinityProcessor.mapPartitionToNode(String cacheName,
int partId,
AffinityTopologyVersion topVer)
Maps partition to a node.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
HistoryAffinityAssignment.assignment() |
List<List<ClusterNode>> |
AffinityAssignment.assignment() |
List<List<ClusterNode>> |
GridAffinityAssignment.assignment() |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer) |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Calculates affinity cache for given topology version.
|
List<ClusterNode> |
GridAffinityFunctionContextImpl.currentTopologySnapshot()
Gets current topology snapshot.
|
List<ClusterNode> |
HistoryAffinityAssignment.get(int part)
Get affinity nodes for partition.
|
List<ClusterNode> |
AffinityAssignment.get(int part)
Get affinity nodes for partition.
|
List<ClusterNode> |
GridAffinityAssignment.get(int part)
Get affinity nodes for partition.
|
List<List<ClusterNode>> |
HistoryAffinityAssignment.idealAssignment() |
List<List<ClusterNode>> |
AffinityAssignment.idealAssignment() |
List<List<ClusterNode>> |
GridAffinityAssignment.idealAssignment() |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.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.
|
Set<ClusterNode> |
HistoryAffinityAssignment.nodes() |
Set<ClusterNode> |
AffinityAssignment.nodes() |
Set<ClusterNode> |
GridAffinityAssignment.nodes() |
List<ClusterNode> |
GridAffinityAssignmentCache.nodes(int part,
AffinityTopologyVersion topVer)
Gets affinity nodes for specified partition.
|
List<List<ClusterNode>> |
GridAffinityFunctionContextImpl.prevAssignment()
Gets the previous assignment.
|
List<ClusterNode> |
GridAffinityFunctionContextImpl.previousAssignment(int part)
Gets affinity assignment for given partition on previous topology version.
|
Set<ClusterNode> |
HistoryAffinityAssignment.primaryPartitionNodes() |
Set<ClusterNode> |
AffinityAssignment.primaryPartitionNodes() |
Set<ClusterNode> |
GridAffinityAssignment.primaryPartitionNodes() |
List<List<ClusterNode>> |
GridAffinityAssignmentCache.readyAssignments(AffinityTopologyVersion topVer) |
| 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.
|
Object |
GridAffinityProcessor.similaryAffinityKey(AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
int parts) |
| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridKernalContext ctx,
String cacheOrGrpName,
int grpId,
AffinityFunction aff,
IgnitePredicate<ClusterNode> nodeFilter,
int backups,
boolean locCache,
boolean persistentCache)
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 |
GridCacheContext.localNode() |
ClusterNode |
GridCacheSharedContext.localNode() |
ClusterNode |
WalStateNodeLeaveExchangeTask.node() |
ClusterNode |
GridCacheContext.node(UUID nodeId) |
ClusterNode |
GridCacheSharedContext.node(UUID nodeId) |
static ClusterNode |
GridCacheUtils.oldest(Collection<ClusterNode> nodes) |
static ClusterNode |
GridCacheUtils.primary(Iterable<? extends ClusterNode> nodes) |
ClusterNode |
GridCacheAffinityManager.primaryByKey(Object key,
AffinityTopologyVersion topVer) |
ClusterNode |
GridCacheAffinityManager.primaryByPartition(int part,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheGroupContext.addRebalanceEvent(int part,
int type,
ClusterNode discoNode,
int discoType,
long discoTs)
Adds rebalancing event.
|
static boolean |
GridCacheUtils.affinityNode(ClusterNode node,
IgnitePredicate<ClusterNode> filter) |
boolean |
GridCacheAffinityManager.backupByPartition(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
static boolean |
GridCacheUtils.baselineNode(ClusterNode node,
DiscoveryDataClusterState discoveryDataClusterState) |
static boolean |
GridCacheUtils.clientNode(ClusterNode node) |
static boolean |
GridCacheUtils.clientNodeDirect(ClusterNode node) |
boolean |
GridCacheContext.isLocalNode(ClusterNode n) |
boolean |
GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg,
AffinityTopologyVersion topVer,
ClusterNode node)
Callback invoked from discovery thread when discovery custom message is received.
|
void |
GridCacheProcessor.onDiscoveryEvent(int type,
DiscoveryCustomMessage customMsg,
ClusterNode node,
AffinityTopologyVersion topVer,
DiscoveryDataClusterState state) |
boolean |
GridCacheAffinityManager.partitionBelongs(ClusterNode node,
int part,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.primaryByKey(ClusterNode n,
Object key,
AffinityTopologyVersion topVer) |
boolean |
GridCacheAffinityManager.primaryByPartition(ClusterNode n,
int part,
AffinityTopologyVersion topVer) |
void |
GridCacheMvccCandidate.removeMappedNode(ClusterNode node) |
void |
GridCacheIoManager.send(ClusterNode node,
GridCacheMessage msg,
byte plc)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
GridCacheMessage msg,
byte plc,
long timeout) |
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.
|
| Constructor and Description |
|---|
WalStateNodeLeaveExchangeTask(ClusterNode node)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridCacheAffinityImpl.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
ClusterNode |
GridCacheAffinityProxy.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
ClusterNode |
GridCacheAffinityImpl.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
ClusterNode |
GridCacheAffinityProxy.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
| Modifier and Type | Method and Description |
|---|---|
Map<ClusterNode,Collection<K>> |
GridCacheAffinityImpl.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Map<ClusterNode,Collection<K>> |
GridCacheAffinityProxy.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Collection<ClusterNode> |
GridCacheAffinityImpl.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Collection<ClusterNode> |
GridCacheAffinityProxy.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Map<Integer,ClusterNode> |
GridCacheAffinityImpl.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Map<Integer,ClusterNode> |
GridCacheAffinityProxy.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Collection<ClusterNode> |
GridCacheAffinityImpl.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
Collection<ClusterNode> |
GridCacheAffinityProxy.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
GridCacheAffinityImpl.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
GridCacheAffinityProxy.allPartitions(ClusterNode n)
Gets partition ids for which given cluster node has any ownership
(either primary or backup).
|
int[] |
GridCacheAffinityImpl.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
int[] |
GridCacheAffinityProxy.backupPartitions(ClusterNode n)
Gets partition ids for which given cluster node has backup ownership.
|
boolean |
GridCacheAffinityImpl.isBackup(ClusterNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinityProxy.isBackup(ClusterNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinityImpl.isPrimary(ClusterNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinityProxy.isPrimary(ClusterNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinityImpl.isPrimaryOrBackup(ClusterNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
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 |
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. |
int[] |
GridCacheAffinityImpl.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
int[] |
GridCacheAffinityProxy.primaryPartitions(ClusterNode n)
Gets partition ids for which the given cluster node has primary ownership.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteNodeValidationResult |
CacheObjectBinaryProcessorImpl.validateNode(ClusterNode rmtNode,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridDistributedTxMapping.primary() |
| Constructor and Description |
|---|
GridDistributedTxMapping(ClusterNode primary) |
| 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(DiscoCache discoCache) |
List<List<ClusterNode>> |
GridDhtAffinityAssignmentResponse.idealAffinityAssignment(DiscoCache discoCache) |
List<ClusterNode> |
GridDhtPartitionTopology.moving(int p) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.moving(int p) |
List<ClusterNode> |
GridClientPartitionTopology.moving(int p) |
List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.owners(int p) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p) |
List<ClusterNode> |
GridDhtPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.owners(int p,
AffinityTopologyVersion topVer) |
List<ClusterNode> |
GridClientPartitionTopology.owners(int p,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest req,
CacheEntryPredicate[] filter0) |
protected abstract void |
GridDhtCacheAdapter.MessageHandler.onMessage(ClusterNode node,
M msg) |
protected void |
GridDhtCacheAdapter.processForceKeyResponse(ClusterNode node,
GridDhtForceKeysResponse msg) |
protected void |
GridDhtCacheAdapter.processForceKeysRequest(ClusterNode node,
GridDhtForceKeysRequest msg) |
void |
GridDhtCacheEntry.removeMapping(GridCacheVersion ver,
ClusterNode mappedNode) |
| 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.
|
List<ClusterNode> |
GridDhtPartitionTopology.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
List<ClusterNode> |
GridDhtPartitionTopologyImpl.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
List<ClusterNode> |
GridClientPartitionTopology.nodes(int p,
AffinityAssignment affAssignment,
List<ClusterNode> affNodes) |
void |
ClientCacheDhtTopologyFuture.validate(CacheGroupContext grp,
Collection<ClusterNode> topNodes) |
protected GridDhtTopologyFutureAdapter.CacheValidation |
GridDhtTopologyFutureAdapter.validateCacheGroup(CacheGroupContext grp,
Collection<ClusterNode> topNodes) |
| Constructor and Description |
|---|
GridDhtAffinityAssignmentResponse(long futId,
int grpId,
AffinityTopologyVersion topVer,
List<List<ClusterNode>> affAssignment) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
GridDhtAtomicAbstractUpdateFuture.addDhtKey(KeyCacheObject key,
List<ClusterNode> dhtNodes) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridDhtPartitionExchangeId.eventNode() |
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createIdealAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
static List<ClusterNode> |
CacheGroupAffinityMessage.toNodes(GridLongList assign,
Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
| Modifier and Type | Method and Description |
|---|---|
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
List<List<ClusterNode>> |
CacheGroupAffinityMessage.createIdealAssignments(Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
static List<ClusterNode> |
CacheGroupAffinityMessage.toNodes(GridLongList assign,
Map<Long,ClusterNode> nodesByOrder,
DiscoCache discoCache) |
| 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 |
|---|---|
ClusterNode |
StandaloneNoopDiscoverySpi.getLocalNode()
Gets local node.
|
ClusterNode |
StandaloneNoopDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
StandaloneNoopDiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StandaloneNoopCommunicationSpi.sendMessage(ClusterNode destNode,
Serializable msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheLocalQueryManager.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.
|
abstract void |
GridCacheQueryManager.loadPage(long id,
GridCacheQueryAdapter<?> qry,
Collection<ClusterNode> nodes,
boolean all)
Loads page.
|
CacheQueryFuture<?> |
GridCacheLocalQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed query.
|
CacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed query.
|
abstract CacheQueryFuture<?> |
GridCacheQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed query.
|
CacheQueryFuture<?> |
GridCacheLocalQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed fields query.
|
CacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed fields query.
|
abstract CacheQueryFuture<?> |
GridCacheQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<ClusterNode> nodes)
Executes distributed fields query.
|
GridCloseableIterator |
GridCacheLocalQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
GridCloseableIterator |
GridCacheDistributedQueryManager.scanQueryDistributed(GridCacheQueryAdapter qry,
Collection<ClusterNode> nodes)
Executes distributed SCAN query.
|
abstract GridCloseableIterator |
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 |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid,
Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
CollectConflictPartitionKeysTask.map(List<ClusterNode> subgrid,
PartitionKey partKey)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsTask.map(List<ClusterNode> subgrid,
Set<String> cacheNames)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid,
Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
CollectConflictPartitionKeysTask.map(List<ClusterNode> subgrid,
PartitionKey partKey)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsTask.map(List<ClusterNode> subgrid,
Set<String> cacheNames)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
BaselineTopology.baselineNode(Object consId) |
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
BaselineTopology.createBaselineView(List<ClusterNode> aliveNodes,
IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
ChangeGlobalStateFinishMessage |
GridClusterStateProcessor.onNodeLeft(ClusterNode node) |
ChangeGlobalStateFinishMessage |
IGridClusterStateProcessor.onNodeLeft(ClusterNode node) |
IgniteNodeValidationResult |
GridClusterStateProcessor.validateNode(ClusterNode node,
DiscoveryDataBag.JoiningNodeDiscoveryData discoData) |
| Modifier and Type | Method and Description |
|---|---|
List<ClusterNode> |
BaselineTopology.createBaselineView(List<ClusterNode> aliveNodes,
IgnitePredicate<ClusterNode> nodeFilter) |
List<ClusterNode> |
BaselineTopology.createBaselineView(List<ClusterNode> aliveNodes,
IgnitePredicate<ClusterNode> nodeFilter) |
boolean |
BaselineTopology.isSatisfied(Collection<ClusterNode> presentedNodes) |
| Modifier and Type | Method and Description |
|---|---|
UUID |
GridContinuousProcessor.registerStaticRoutine(String cacheName,
javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr,
CacheEntryEventSerializableFilter rmtFilter,
IgnitePredicate<ClusterNode> prjPred)
Registers routine info to be sent in discovery data during this node join
(to be used for internal queries started from client nodes).
|
IgniteInternalFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
boolean locOnly,
int bufSize,
long interval,
boolean autoUnsubscribe,
IgnitePredicate<ClusterNode> prjPred) |
| Modifier and Type | Method and Description |
|---|---|
static byte |
DataStreamProcessor.ioPolicy(IgniteClosure<ClusterNode,Byte> rslvr,
ClusterNode node)
Get IO policy for particular node with provided resolver.
|
| Modifier and Type | Method and Description |
|---|---|
static byte |
DataStreamProcessor.ioPolicy(IgniteClosure<ClusterNode,Byte> rslvr,
ClusterNode node)
Get IO policy for particular node with provided resolver.
|
void |
DataStreamerImpl.ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
IgfsDataManager.affinityNode(Object affinityKey)
Maps affinity key to node.
|
ClusterNode |
IgfsContext.localNode()
Get local node.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
IgfsDataManager.affinityNodes(Object affinityKey)
Maps affinity key to node.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgfsNodePredicate.apply(ClusterNode node)
Predicate body.
|
boolean |
IgfsContext.igfsNode(ClusterNode node)
Checks if given node is a IGFS node.
|
static boolean |
IgfsUtils.isIgfsNode(ClusterNode node,
String igfsName)
Check whether provided node contains IGFS with the given name.
|
| 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 |
|---|---|
List<List<ClusterNode>> |
PlatformAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
static List<List<ClusterNode>> |
PlatformAffinityUtils.readPartitionAssignment(BinaryRawReader reader,
PlatformContext ctx)
Reads the partition assignment.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformAffinityUtils.writePartitionAssignment(Collection<List<ClusterNode>> partitions,
BinaryRawWriterEx writer,
PlatformContext ctx)
Writes the partition assignment to a stream.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PlatformClusterNodeFilterImpl.apply(ClusterNode clusterNode)
Predicate body.
|
| Modifier and Type | Method and Description |
|---|---|
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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 |
|---|---|
void |
GridQueryProcessor.onNodeLeave(ClusterNode node)
Handle node leave.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
SchemaNodeLeaveExchangeWorkerTask.node() |
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaOperationManager.onNodeLeave(UUID nodeId,
ClusterNode curCrd)
Handle node leave event.
|
| Constructor and Description |
|---|
SchemaNodeLeaveExchangeWorkerTask(ClusterNode node)
Constructor.
|
SchemaOperationManager(GridKernalContext ctx,
GridQueryProcessor qryProc,
SchemaOperationWorker worker,
ClusterNode crd)
Constructor.
|
| 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 |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId,
UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
Collection<UUID> top,
IgnitePredicate<ClusterNode> topPred,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup,
boolean internal,
UUID subjId,
String execName) |
| 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 double |
IgniteUtils.offheapSize(Iterable<ClusterNode> nodes,
int precision)
Gets total offheap size in GB rounded to specified precision.
|
static ClusterNode |
IgniteUtils.oldest(Collection<ClusterNode> c,
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 |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
IgniteRemoteMapTask.map(List<ClusterNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends ComputeJob,ClusterNode> |
IgniteRemoteMapTask.map(List<ClusterNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Constructor and Description |
|---|
IgniteRemoteMapTask(ClusterNode node,
ComputeTask<T,R> remoteTask) |
| 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<Object> |
GridFunc.nodeConsistentIds(Collection<? extends ClusterNode> nodes)
Convenient utility method that returns collection of node consistent IDs 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 | Class and Description |
|---|---|
class |
ContainsNodeIdsPredicate<T extends ClusterNode>
Grid node predicate evaluating on the given node IDs.
|
class |
EqualsClusterNodeIdPredicate<T extends ClusterNode>
Creates grid node predicate evaluating on the given node ID.
|
class |
HasEqualIdPredicate<T extends ClusterNode>
ClusterNode has equal id predicate. |
class |
HasNotEqualIdPredicate<T extends ClusterNode>
ClusterNode node has NOT equal id predicate. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
EqualsClusterNodeIdPredicate.apply(ClusterNode e)
Predicate body.
|
boolean |
ContainsNodeIdsPredicate.apply(ClusterNode e)
Predicate body.
|
UUID |
ClusterNodeGetIdClosure.apply(ClusterNode n)
Closure body.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridNioRecoveryDescriptor.node() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNioRecoveryDescriptor.nodeAlive(ClusterNode node) |
| Constructor and Description |
|---|
GridNioRecoveryDescriptor(boolean pairedConnections,
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> |
VisorQueryCleanupTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<VisorQueryCleanupTaskArg> arg)
Actual map logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<? extends ComputeJob,ClusterNode> |
VisorQueryCleanupTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<VisorQueryCleanupTaskArg> 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 |
|---|---|
List<List<ClusterNode>> |
PlatformDotNetAffinityFunction.assignPartitions(AffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
CachePluginContext.localNode()
Gets local grid node.
|
ClusterNode |
PluginContext.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,
CacheConfiguration rmtCfg,
ClusterNode rmtNode)
Checks that remote caches has configuration compatible with the local.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<ClusterNode> |
ServiceConfiguration.nodeFilter
Node filter.
|
| 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 |
|---|---|
ServiceConfiguration |
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.
|
IgniteNodeValidationResult |
IgniteSpiContext.validateNode(ClusterNode node,
DiscoveryDataBag discoData) |
| 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.createTcpClient(ClusterNode node,
int connIdx)
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.
|
void |
DiscoverySpiListener.onLocalNodeInitialized(ClusterNode locNode)
Notification of local node initialization.
|
| 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.
|
ClusterNode |
TcpDiscoverySpi.getNode0(UUID 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 | Method and Description |
|---|---|
protected void |
TcpDiscoverySpi.writeToSocket(ClusterNode node,
Socket sock,
OutputStream out,
TcpDiscoveryAbstractMessage msg,
long timeout) |
| Modifier and Type | Class and Description |
|---|---|
class |
TcpDiscoveryNode
Node for
TcpDiscoverySpi. |
| Constructor and Description |
|---|
TcpDiscoveryNode(ClusterNode node)
IMPORTANT!
|
| 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. |
| Constructor and Description |
|---|
IndexingQueryCacheFilter(GridCacheAffinityManager aff,
Set<Integer> parts,
AffinityTopologyVersion topVer,
ClusterNode locNode)
Constructor.
|
| 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 |
AdaptiveProcessingTimeLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
AdaptiveCpuLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
AdaptiveJobCountLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
AdaptiveLoadProbe.getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
AttributeNodeFilter.apply(ClusterNode node)
Predicate body.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.4.0 Release Date : March 5 2018