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

Class GridDhtPartitionDemander

java.lang.Object

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

public class GridDhtPartitionDemander
extends Object

Thread pool for requesting partitions from other nodes and populating local cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GridDhtPartitionDemander.RebalanceFuture

Constructor Summary

Constructors

Constructor and Description
GridDhtPartitionDemander(CacheGroupContext grp)

Method Summary

Modifier and Type	Method and Description
void	handleSupplyMessage(int topicId, UUID nodeId, GridDhtPartitionSupplyMessage supplyMsg) Handles supply message from nodeId with specified topicId.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDhtPartitionDemander

public GridDhtPartitionDemander(CacheGroupContext grp)

Parameters:

grp - Ccahe group.

Method Detail

handleSupplyMessage

public void handleSupplyMessage(int topicId,
                                UUID nodeId,
                                GridDhtPartitionSupplyMessage supplyMsg)

Handles supply message from nodeId with specified topicId. Supply message contains entries to populate rebalancing partitions. There is a cyclic process: Populate rebalancing partitions with entries from Supply message. If not all partitions specified in rebalanceFut were rebalanced or marked as missed send new Demand message to request next batch of entries.

Parameters:

topicId - Topic id.

nodeId - Node id.

supplyMsg - Supply message.

toString

public String toString()

Overrides:

toString in class Object