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

Class RebalanceReassignExchangeTask

java.lang.Object

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

All Implemented Interfaces:

CachePartitionExchangeWorkerTask

public class RebalanceReassignExchangeTask
extends Object
implements CachePartitionExchangeWorkerTask

Constructor Summary

Constructors

Constructor and Description
RebalanceReassignExchangeTask(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RebalanceReassignExchangeTask

public RebalanceReassignExchangeTask(GridDhtPartitionExchangeId exchId,
                                     GridDhtPartitionsExchangeFuture exchFut)

Parameters:

exchId - Exchange ID.

exchFut - Exchange future.

Method Detail

skipForExchangeMerge

public boolean skipForExchangeMerge()

Specified by:

skipForExchangeMerge in interface CachePartitionExchangeWorkerTask

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.