| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,CacheGroupAffinityMessage> |
CacheAffinitySharedManager.onCustomEventWithEnforcedAffinityReassignment(GridDhtPartitionsExchangeFuture fut)
Calculates affinity on coordinator for custom event types that require centralized assignment.
|
Map<Integer,CacheGroupAffinityMessage> |
CacheAffinitySharedManager.onReassignmentEnforced(GridDhtPartitionsExchangeFuture fut)
Calculates new affinity assignment on coordinator and creates affinity diff messages for other nodes.
|
Map<Integer,CacheGroupAffinityMessage> |
CacheAffinitySharedManager.onServerLeftWithExchangeMergeProtocol(GridDhtPartitionsExchangeFuture fut) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheAffinitySharedManager.applyAffinityFromFullMessage(GridDhtPartitionsExchangeFuture fut,
Map<Integer,CacheGroupAffinityMessage> idealAffDiff)
Applies affinity diff from the received full message.
|
Set<Integer> |
CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut,
Map<Integer,CacheGroupAffinityMessage> receivedAff,
AffinityTopologyVersion resTopVer) |
| Modifier and Type | Method and Description |
|---|---|
static Map<Integer,CacheGroupAffinityMessage> |
CacheGroupAffinityMessage.createAffinityDiffMessages(Map<Integer,Map<Integer,List<Long>>> affDiff) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020