| 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 | |
| org.apache.ignite.internal.processors.cache.distributed.dht.topology |
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridDhtPartitionExchangeId |
DynamicCacheChangeFailureMessage.exchangeId() |
@Nullable GridDhtPartitionExchangeId |
CacheAffinityChangeMessage.exchangeId() |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsFullMessage |
GridCachePartitionExchangeManager.createPartitionsFullMessage(boolean compress,
boolean newCntrMap,
@Nullable GridDhtPartitionExchangeId exchId,
@Nullable GridCacheVersion lastVer,
@Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
@Nullable IgniteDhtPartitionsToReloadMap partsToReload)
Creates partitions full message for all cache groups.
|
GridDhtPartitionsFullMessage |
GridCachePartitionExchangeManager.createPartitionsFullMessage(boolean compress,
boolean newCntrMap,
@Nullable GridDhtPartitionExchangeId exchId,
@Nullable GridCacheVersion lastVer,
@Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
@Nullable IgniteDhtPartitionsToReloadMap partsToReload,
Collection<CacheGroupContext> grps)
Creates partitions full message for selected cache groups.
|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions)
Creates partitions single message for all cache groups.
|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions,
Collection<CacheGroupContext> grps)
Creates partitions single message for selected cache groups.
|
void |
GridCachePartitionExchangeManager.forceReassign(GridDhtPartitionExchangeId exchId,
GridDhtPartitionsExchangeFuture fut) |
IgniteInternalFuture<Boolean> |
GridCachePartitionExchangeManager.forceRebalance(GridDhtPartitionExchangeId exchId) |
GridDhtPreloaderAssignments |
GridCachePreloaderAdapter.generateAssignments(GridDhtPartitionExchangeId exchId,
GridDhtPartitionsExchangeFuture exchFut) |
GridDhtPartitionDemander.RebalanceFuture |
GridCachePreloaderAdapter.prepare(GridDhtPartitionExchangeId exchId,
GridDhtPartitionsExchangeFuture exchFut,
long rebalanceId,
GridDhtPartitionDemander.RebalanceFuture next,
@Nullable GridCompoundFuture<Boolean,Boolean> forcedRebFut,
GridCompoundFuture<Boolean,Boolean> compatibleRebFut) |
GridDhtPartitionDemander.RebalanceFuture |
GridCachePreloader.prepare(GridDhtPartitionExchangeId exchId,
@Nullable GridDhtPartitionsExchangeFuture exchFut,
long rebalanceId,
GridDhtPartitionDemander.RebalanceFuture next,
@Nullable GridCompoundFuture<Boolean,Boolean> forcedRebFut,
GridCompoundFuture<Boolean,Boolean> compatibleRebFut) |
| Constructor and Description |
|---|
CacheAffinityChangeMessage(GridDhtPartitionExchangeId exchId,
GridDhtPartitionsFullMessage partsMsg,
Map<Integer,Map<Integer,List<UUID>>> assignmentChange)
Constructor used when message is created to finish exchange.
|
DynamicCacheChangeFailureMessage(ClusterNode locNode,
GridDhtPartitionExchangeId exchId,
IgniteCheckedException cause,
Collection<String> cacheNames)
Creates new DynamicCacheChangeFailureMessage instance.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridDhtPartitionExchangeId |
GridDhtPartitionsAbstractMessage.exchangeId() |
GridDhtPartitionExchangeId |
RebalanceReassignExchangeTask.exchangeId() |
GridDhtPartitionExchangeId |
ForceRebalanceExchangeTask.exchangeId() |
GridDhtPartitionExchangeId |
GridDhtPartitionsExchangeFuture.exchangeId() |
| Modifier and Type | Method and Description |
|---|---|
int |
GridDhtPartitionExchangeId.compareTo(GridDhtPartitionExchangeId o) |
void |
GridDhtPartitionsAbstractMessage.exchangeId(GridDhtPartitionExchangeId exchId) |
GridDhtPreloaderAssignments |
GridDhtPreloader.generateAssignments(GridDhtPartitionExchangeId exchId,
GridDhtPartitionsExchangeFuture exchFut) |
void |
GridDhtPartitionsExchangeFuture.onEvent(GridDhtPartitionExchangeId exchId,
DiscoveryEvent discoEvt,
DiscoCache discoCache)
Event callback.
|
GridDhtPartitionDemander.RebalanceFuture |
GridDhtPreloader.prepare(GridDhtPartitionExchangeId exchId,
@Nullable GridDhtPartitionsExchangeFuture exchFut,
long rebalanceId,
GridDhtPartitionDemander.RebalanceFuture next,
@Nullable GridCompoundFuture<Boolean,Boolean> forcedRebFut,
GridCompoundFuture<Boolean,Boolean> compatibleRebFut) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionTopology.update(@Nullable GridDhtPartitionExchangeId exchId,
GridDhtPartitionMap parts,
boolean force) |
boolean |
GridDhtPartitionTopologyImpl.update(@Nullable GridDhtPartitionExchangeId exchId,
GridDhtPartitionMap parts,
boolean force) |
boolean |
GridClientPartitionTopology.update(@Nullable GridDhtPartitionExchangeId exchId,
GridDhtPartitionMap parts,
boolean force) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023