Package org.apache.ignite.internal.processors.cache.distributed.dht.preloader

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

Modifier and Type	Method	Description
GridDhtPartitionExchangeId	exchangeId()
GridDhtPartitionsExchangeFuture	future()
boolean	skipForExchangeMerge()

Methods inherited from class org.apache.ignite.internal.processors.cache.AbstractCachePartitionExchangeWorkerTask

securityContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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:

False if 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.