Uses of Class
org.apache.ignite.internal.processors.cache.CacheAffinityChangeMessage
-
Packages that use CacheAffinityChangeMessage 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 -
-
Uses of CacheAffinityChangeMessage in org.apache.ignite.internal.processors.cache
Methods in org.apache.ignite.internal.processors.cache with parameters of type CacheAffinityChangeMessage Modifier and Type Method Description voidCacheAffinitySharedManager. onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, CacheAffinityChangeMessage msg)Called on exchange initiated byCacheAffinityChangeMessagewhich sent after rebalance finished.voidCacheAffinitySharedManager. onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, CacheAffinityChangeMessage msg)Called when receivedCacheAffinityChangeMessagewhich should complete exchange. -
Uses of CacheAffinityChangeMessage in org.apache.ignite.internal.processors.cache.distributed.dht.preloader
Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type CacheAffinityChangeMessage Modifier and Type Method Description voidGridDhtPartitionsExchangeFuture. affinityChangeMessage(CacheAffinityChangeMessage affChangeMsg)Sets affinity change message associated with the exchange.voidGridDhtPartitionsExchangeFuture. onAffinityChangeMessage(ClusterNode node, CacheAffinityChangeMessage msg)Affinity change message callback, processed from the same thread asGridDhtPartitionsExchangeFuture.onNodeLeft(org.apache.ignite.cluster.ClusterNode).Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type CacheAffinityChangeMessage Constructor Description GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx, ReadWriteLock busyLock, GridDhtPartitionExchangeId exchId, ExchangeActions exchActions, CacheAffinityChangeMessage affChangeMsg)
-