Uses of Class
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture

Packages that use GridDhtPartitionsExchangeFuture

Package	Description
org.apache.ignite.internal.cdc
org.apache.ignite.internal.managers.encryption	Encryption manager classes.
org.apache.ignite.internal.processors.authentication
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
org.apache.ignite.internal.processors.cache.persistence	This package contain cache with persistence implementation.
org.apache.ignite.internal.processors.cache.persistence.snapshot
org.apache.ignite.internal.processors.platform
org.apache.ignite.internal.processors.query
org.apache.ignite.internal.processors.query.stat

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.cdc

Methods in org.apache.ignite.internal.cdc with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	CdcUtilityActiveCdcManager.onDoneAfterTopologyUnlock(GridDhtPartitionsExchangeFuture fut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.managers.encryption

Methods in org.apache.ignite.internal.managers.encryption with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	GridEncryptionManager.onDoneAfterTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process completion; called after topology is unlocked.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.authentication

Methods in org.apache.ignite.internal.processors.authentication with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	IgniteAuthenticationProcessor.onDoneBeforeTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process completion; called before topology is unlocked.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
@Nullable GridDhtPartitionsExchangeFuture	GridCachePartitionExchangeManager.lastFinishedFuture()
GridDhtPartitionsExchangeFuture	GridCachePartitionExchangeManager.lastTopologyFuture()

Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
List<GridDhtPartitionsExchangeFuture>	GridCachePartitionExchangeManager.exchangeFutures()

Methods in org.apache.ignite.internal.processors.cache with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	CacheAffinitySharedManager.applyAffinityFromFullMessage(GridDhtPartitionsExchangeFuture fut, Map<Integer,CacheGroupAffinityMessage> idealAffDiff)	Applies affinity diff from the received full message.
void	WalStateManager.disableGroupDurabilityForPreloading(GridDhtPartitionsExchangeFuture fut)	Change local WAL state before exchange is done.
void	GridCachePartitionExchangeManager.dumpDebugInfo(@Nullable GridDhtPartitionsExchangeFuture exchFut)
void	CacheAffinitySharedManager.forceCloseCaches(GridDhtPartitionsExchangeFuture fut, boolean crd, ExchangeActions exchActions)	Called during the rollback of the exchange partitions procedure in order to stop the given cache even if it's not fully initialized (e.g. failed on cache init stage).
void	GridCachePartitionExchangeManager.forceReassign(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture fut)
GridDhtPreloaderAssignments	GridCachePreloaderAdapter.generateAssignments(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>>	CacheAffinitySharedManager.initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut)
IgniteInternalFuture<?>	CacheAffinitySharedManager.initCoordinatorCaches(GridDhtPartitionsExchangeFuture fut, boolean newAff)
IgniteInternalFuture<?>	CacheAffinitySharedManager.initStartedCaches(boolean crd, GridDhtPartitionsExchangeFuture fut, Collection<DynamicCacheDescriptor> descs)	Initialized affinity for cache received from node joining on this exchange.
void	GridCachePartitionExchangeManager.lastFinishedFuture(GridDhtPartitionsExchangeFuture fut)
boolean	GridCachePartitionExchangeManager.mergeExchanges(GridDhtPartitionsExchangeFuture curFut, GridDhtPartitionsFullMessage msg)
boolean	GridCachePartitionExchangeManager.mergeExchangesOnCoordinator(GridDhtPartitionsExchangeFuture curFut, @Nullable AffinityTopologyVersion threshold)
void	CacheAffinitySharedManager.onBaselineTopologyChanged(GridDhtPartitionsExchangeFuture fut, boolean crd)
IgniteInternalFuture<?>	CacheAffinitySharedManager.onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut, boolean crd, ExchangeActions exchActions)	Called on exchange initiated for cache start/stop request.
boolean	CacheAffinitySharedManager.onCentralizedAffinityChange(GridDhtPartitionsExchangeFuture fut, boolean crd)	Called on exchange initiated by server node leave or custom event with centralized affinity assignment.
void	CacheAffinitySharedManager.onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, CacheAffinityChangeMessage msg)	Called on exchange initiated by CacheAffinityChangeMessage which sent after rebalance finished.
void	CacheAffinitySharedManager.onClientEvent(GridDhtPartitionsExchangeFuture fut)	Called on exchange initiated by client node join/fail.
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onCustomEventWithEnforcedAffinityReassignment(GridDhtPartitionsExchangeFuture fut)	Calculates affinity on coordinator for custom event types that require centralized assignment.
void	CacheAffinitySharedManager.onCustomMessageNoAffinityChange(GridDhtPartitionsExchangeFuture fut, @Nullable ExchangeActions exchActions)
void	CacheAffinitySharedManager.onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, CacheAffinityChangeMessage msg)	Called when received CacheAffinityChangeMessage which should complete exchange.
void	CacheAffinitySharedManager.onExchangeFreeSwitch(GridDhtPartitionsExchangeFuture fut)	Called on exchange initiated by baseline server node leave on fully-rebalanced topology.
Set<Integer>	CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut, Map<Integer,CacheGroupAffinityMessage> receivedAff, AffinityTopologyVersion resTopVer)
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onReassignmentEnforced(GridDhtPartitionsExchangeFuture fut)	Calculates new affinity assignment on coordinator and creates affinity diff messages for other nodes.
void	CacheAffinitySharedManager.onServerJoin(GridDhtPartitionsExchangeFuture fut, boolean crd)	Called on exchange initiated by server node join.
void	CacheAffinitySharedManager.onServerJoinWithExchangeMergeProtocol(GridDhtPartitionsExchangeFuture fut, boolean crd)
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onServerLeftWithExchangeMergeProtocol(GridDhtPartitionsExchangeFuture fut)
void	GridCachePreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
void	GridCachePreloaderAdapter.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
GridDhtPartitionDemander.RebalanceFuture	GridCachePreloader.prepare(GridDhtPartitionExchangeId exchId, @Nullable GridDhtPartitionsExchangeFuture exchFut, long rebalanceId, GridDhtPartitionDemander.RebalanceFuture next, @Nullable GridCompoundFuture<Boolean,Boolean> forcedRebFut, GridCompoundFuture<Boolean,Boolean> compatibleRebFut)
GridDhtPartitionDemander.RebalanceFuture	GridCachePreloaderAdapter.prepare(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut, long rebalanceId, GridDhtPartitionDemander.RebalanceFuture next, @Nullable GridCompoundFuture<Boolean,Boolean> forcedRebFut, GridCompoundFuture<Boolean,Boolean> compatibleRebFut)
void	ExchangeDiscoveryEvents.processEvents(GridDhtPartitionsExchangeFuture fut)

Constructors in org.apache.ignite.internal.processors.cache with parameters of type GridDhtPartitionsExchangeFuture

Constructor	Description
ExchangeContext(GridCacheSharedContext<?,?> cctx, boolean crd, GridDhtPartitionsExchangeFuture fut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that return GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
GridDhtPartitionsExchangeFuture	RebalanceReassignExchangeTask.future()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
int	GridDhtPartitionsExchangeFuture.compareTo(GridDhtPartitionsExchangeFuture fut)
void	GridDhtPartitionsExchangeFuture.copyInapplicableNodesFrom(GridDhtPartitionsExchangeFuture fut)	Marks nodes as not applicable for full and historical rebalancing.
void	GridDhtPartitionsExchangeFuture.finishMerged(AffinityTopologyVersion resVer, GridDhtPartitionsExchangeFuture exchFut)	Finish merged future to allow GridCachePartitionExchangeManager.ExchangeFutureSet cleanup.
GridDhtPreloaderAssignments	GridDhtPreloader.generateAssignments(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
void	InitNewCoordinatorFuture.init(GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionsExchangeFuture.mergeJoinExchange(GridDhtPartitionsExchangeFuture fut)	Merges this exchange with given one.
@Nullable GridDhtPartitionsSingleMessage	GridDhtPartitionsExchangeFuture.mergeJoinExchangeOnDone(GridDhtPartitionsExchangeFuture fut)
default void	PartitionsExchangeAware.onDoneAfterTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process completion; called after topology is unlocked.
default void	PartitionsExchangeAware.onDoneBeforeTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process completion; called before topology is unlocked.
default void	PartitionsExchangeAware.onInitAfterTopologyLock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process initialization; called after topology is locked.
default void	PartitionsExchangeAware.onInitBeforeTopologyLock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process initialization; called before topology is locked.
void	GridDhtPreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
GridDhtPartitionDemander.RebalanceFuture	GridDhtPreloader.prepare(GridDhtPartitionExchangeId exchId, @Nullable GridDhtPartitionsExchangeFuture exchFut, long rebalanceId, GridDhtPartitionDemander.RebalanceFuture next, @Nullable GridCompoundFuture<Boolean,Boolean> forcedRebFut, GridCompoundFuture<Boolean,Boolean> compatibleRebFut)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type GridDhtPartitionsExchangeFuture

Constructor	Description
RebalanceReassignExchangeTask(SecurityContext secCtx, GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.distributed.dht.topology

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
boolean	GridClientPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)	Post-initializes this topology.
boolean	GridDhtPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut)	Post-initializes this topology.
boolean	GridDhtPartitionTopologyImpl.afterExchange(GridDhtPartitionsExchangeFuture exchFut)	Post-initializes this topology.
void	GridClientPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean initParts, boolean updateMoving)	Pre-initializes this topology.
void	GridDhtPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean affReady, boolean updateMoving)	Pre-initializes this topology.
void	GridDhtPartitionTopologyImpl.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean affReady, boolean updateMoving)	Pre-initializes this topology.
boolean	GridClientPartitionTopology.detectLostPartitions(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture fut)	Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridDhtPartitionTopology.detectLostPartitions(AffinityTopologyVersion resTopVer, GridDhtPartitionsExchangeFuture fut)	Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridDhtPartitionTopologyImpl.detectLostPartitions(AffinityTopologyVersion resTopVer, GridDhtPartitionsExchangeFuture fut)	Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridClientPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
void	GridClientPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer)	Callback on exchange done.
void	GridDhtPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer)	Callback on exchange done.
void	GridDhtPartitionTopologyImpl.onExchangeDone(@Nullable GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer)	Callback on exchange done.
Map<UUID,Set<Integer>>	GridClientPartitionTopology.resetOwners(Map<Integer,Set<UUID>> ownersByUpdCounters, Set<Integer> haveHist, GridDhtPartitionsExchangeFuture exchFut)	Calculates nodes and partitions which have non-actual state (based on LWM value) and must be rebalanced.
Map<UUID,Set<Integer>>	GridDhtPartitionTopology.resetOwners(Map<Integer,Set<UUID>> ownersByUpdCounters, Set<Integer> haveHist, GridDhtPartitionsExchangeFuture exchFut)	Calculates nodes and partitions which have non-actual state (based on LWM value) and must be rebalanced.
Map<UUID,Set<Integer>>	GridDhtPartitionTopologyImpl.resetOwners(Map<Integer,Set<UUID>> ownersByUpdCounters, Set<Integer> haveHist, GridDhtPartitionsExchangeFuture exchFut)	Calculates nodes and partitions which have non-actual state (based on LWM value) and must be rebalanced.
boolean	GridClientPartitionTopology.update(@Nullable AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap cntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
boolean	GridDhtPartitionTopology.update(@Nullable AffinityTopologyVersion exchangeResVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap cntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
boolean	GridDhtPartitionTopologyImpl.update(@Nullable AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap incomeCntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
void	GridDhtPartitionsStateValidator.validatePartitionCountersAndSizes(GridDhtPartitionsExchangeFuture fut, GridDhtPartitionTopology top, Map<UUID,GridDhtPartitionsSingleMessage> messages)	Validates partition states - update counters and cache sizes for all nodes.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.persistence

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	GridCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture fut)
void	IgniteCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
void	GridCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture exchangeFut)
void	IgniteCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.persistence.snapshot

Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	IgniteSnapshotManager.onDoneBeforeTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process completion; called before topology is unlocked.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.platform

Methods in org.apache.ignite.internal.processors.platform with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	PlatformContextImpl.onDoneBeforeTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Callback from exchange process completion; called before topology is unlocked.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	GridQueryProcessor.beforeExchange(GridDhtPartitionsExchangeFuture fut)	Prepare index rebuild futures if needed before exchange.
boolean	GridQueryProcessor.rebuildIndexOnExchange(int cacheId, GridDhtPartitionsExchangeFuture fut)	Checks that the indexes need to be rebuilt on the exchange.
void	GridQueryProcessor.removeIndexRebuildFuturesOnExchange(GridDhtPartitionsExchangeFuture fut, @Nullable Set<Integer> cacheIds)	Removing futures of rebuilding indexes that should have been rebuilt on the exchange.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.query.stat

Methods in org.apache.ignite.internal.processors.query.stat with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method	Description
void	IgniteStatisticsConfigurationManager.afterTopologyUnlock(GridDhtPartitionsExchangeFuture fut)	Update statistics after topology change, if necessary.