| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsFullMessage |
GridCachePartitionExchangeManager.createPartitionsFullMessage(boolean compress,
boolean newCntrMap,
GridDhtPartitionExchangeId exchId,
GridCacheVersion lastVer,
IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
IgniteDhtPartitionsToReloadMap partsToReload) |
GridDhtPartitionsFullMessage |
CacheAffinityChangeMessage.partitionsMessage() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheAffinitySharedManager.applyAffinityFromFullMessage(GridDhtPartitionsExchangeFuture fut,
GridDhtPartitionsFullMessage msg)
Applies affinity diff from the received full message.
|
boolean |
GridCachePartitionExchangeManager.mergeExchanges(GridDhtPartitionsExchangeFuture curFut,
GridDhtPartitionsFullMessage msg) |
void |
CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut,
GridDhtPartitionsFullMessage msg,
AffinityTopologyVersion resTopVer) |
void |
GridCachePartitionExchangeManager.processFullPartitionUpdate(ClusterNode node,
GridDhtPartitionsFullMessage msg) |
| Constructor and Description |
|---|
CacheAffinityChangeMessage(GridDhtPartitionExchangeId exchId,
GridDhtPartitionsFullMessage partsMsg,
Map<Integer,Map<Integer,List<UUID>>> assignmentChange)
Constructor used when message is created to finish exchange.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionsExchangeFuture.addOrMergeDelayedFullMessage(ClusterNode node,
GridDhtPartitionsFullMessage fullMsg)
Add or merge updates received from coordinator while exchange in progress.
|
void |
GridDhtPartitionsFullMessage.merge(GridDhtPartitionsFullMessage other,
GridDiscoveryManager discovery)
Merges (replaces with newer) partitions map from given
other full message. |
void |
GridDhtPartitionsExchangeFuture.onReceiveFullMessage(ClusterNode node,
GridDhtPartitionsFullMessage msg) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019