Class RebalanceReassignExchangeTask
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.AbstractCachePartitionExchangeWorkerTask
-
- org.apache.ignite.internal.processors.cache.distributed.dht.preloader.RebalanceReassignExchangeTask
-
- All Implemented Interfaces:
CachePartitionExchangeWorkerTask
public class RebalanceReassignExchangeTask extends AbstractCachePartitionExchangeWorkerTask
-
-
Constructor Summary
Constructors Constructor Description RebalanceReassignExchangeTask(SecurityContext secCtx, GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description GridDhtPartitionExchangeIdexchangeId()GridDhtPartitionsExchangeFuturefuture()booleanskipForExchangeMerge()-
Methods inherited from class org.apache.ignite.internal.processors.cache.AbstractCachePartitionExchangeWorkerTask
securityContext
-
-
-
-
Constructor Detail
-
RebalanceReassignExchangeTask
public RebalanceReassignExchangeTask(SecurityContext secCtx, GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
- Parameters:
secCtx- Security context in which current task must be executed.exchId- Exchange ID.exchFut- Exchange future.
-
-
Method Detail
-
skipForExchangeMerge
public boolean skipForExchangeMerge()
- Returns:
Falseif exchange merge should stop if this task is found in exchange worker queue.
-
exchangeId
public GridDhtPartitionExchangeId exchangeId()
- Returns:
- Exchange ID.
-
future
public GridDhtPartitionsExchangeFuture future()
- Returns:
- Exchange future.
-
-