| Modifier and Type | Method and Description |
|---|---|
List<GridDhtPartitionsExchangeFuture> |
GridCachePartitionExchangeManager.exchangeFutures() |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPreloaderAssignments |
GridCachePreloaderAdapter.assign(GridDhtPartitionsExchangeFuture exchFut) |
GridDhtPreloaderAssignments |
GridCachePreloader.assign(GridDhtPartitionsExchangeFuture exchFut) |
GridDhtPartitionTopology |
GridCachePartitionExchangeManager.clientTopology(int grpId,
GridDhtPartitionsExchangeFuture exchFut) |
void |
GridCachePartitionExchangeManager.dumpDebugInfo(GridDhtPartitionsExchangeFuture exchFut) |
void |
GridCachePartitionExchangeManager.forceDummyExchange(boolean reassign,
GridDhtPartitionsExchangeFuture exchFut) |
IgniteInternalFuture<Boolean> |
GridCachePartitionExchangeManager.forceRebalance(GridDhtPartitionsExchangeFuture exchFut)
Forces preload exchange.
|
IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>> |
CacheAffinitySharedManager.initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut) |
void |
CacheAffinitySharedManager.initStartedCaches(boolean crd,
GridDhtPartitionsExchangeFuture fut,
Collection<DynamicCacheDescriptor> descs)
Initialized affinity for cache received from node joining on this exchange.
|
void |
CacheAffinitySharedManager.onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut,
boolean crd,
ExchangeActions exchActions)
Called on exchange initiated for cache start/stop request.
|
void |
CacheAffinitySharedManager.onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut,
boolean crd,
CacheAffinityChangeMessage msg)
Called on exchange initiated by
CacheAffinityChangeMessage which sent after rebalance finished. |
void |
CacheAffinitySharedManager.onClientEvent(GridDhtPartitionsExchangeFuture fut,
boolean crd)
Called on exchange initiated by client node join/fail.
|
void |
CacheAffinitySharedManager.onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut,
boolean crd,
CacheAffinityChangeMessage msg)
Called when received
CacheAffinityChangeMessage which should complete exchange. |
void |
GridCachePartitionExchangeManager.onExchangeDone(GridDhtPartitionsExchangeFuture exchFut,
Throwable err) |
void |
CacheAffinitySharedManager.onServerJoin(GridDhtPartitionsExchangeFuture fut,
boolean crd)
Called on exchange initiated by server node join.
|
boolean |
CacheAffinitySharedManager.onServerLeft(GridDhtPartitionsExchangeFuture fut)
Called on exchange initiated by server node leave.
|
void |
GridCachePreloaderAdapter.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut) |
void |
GridCachePreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionTopologyImpl.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
boolean |
GridClientPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
boolean |
GridDhtPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)
Post-initializes this topology.
|
void |
GridDhtPartitionTopologyImpl.beforeExchange(GridDhtPartitionsExchangeFuture exchFut,
boolean affReady)
Pre-initializes this topology.
|
void |
GridClientPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut,
boolean initParts)
Pre-initializes this topology.
|
void |
GridDhtPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut,
boolean affReady)
Pre-initializes this topology.
|
void |
GridDhtPartitionTopologyImpl.initPartitions(GridDhtPartitionsExchangeFuture exchFut) |
void |
GridClientPartitionTopology.initPartitions(GridDhtPartitionsExchangeFuture exchFut) |
void |
GridDhtPartitionTopology.initPartitions(GridDhtPartitionsExchangeFuture exchFut) |
| Constructor and Description |
|---|
GridClientPartitionTopology(GridCacheSharedContext cctx,
int grpId,
GridDhtPartitionsExchangeFuture exchFut,
Object similarAffKey) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPreloaderAssignments |
GridDhtPreloader.assign(GridDhtPartitionsExchangeFuture exchFut) |
int |
GridDhtPartitionsExchangeFuture.compareTo(GridDhtPartitionsExchangeFuture fut) |
void |
GridDhtPreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut) |
| Constructor and Description |
|---|
GridDhtPreloaderAssignments(GridDhtPartitionsExchangeFuture exchFut,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture discoEvt) |
void |
GridCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture fut) |
Follow @ApacheIgnite
Ignite Fabric : ver. 2.2.0 Release Date : September 15 2017