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

Class GridClientPartitionTopology<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.distributed.dht.GridClientPartitionTopology<K,V>

All Implemented Interfaces:

GridDhtPartitionTopology<K,V>

@GridToStringExclude
public class GridClientPartitionTopology<K,V>
extends Object
implements GridDhtPartitionTopology<K,V>

Partition topology for node which does not have any local partitions.

Constructor Summary

Constructors

Constructor and Description
GridClientPartitionTopology(GridCacheSharedContext<K,V> cctx, int cacheId, GridDhtPartitionExchangeId exchId)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	afterExchange(GridDhtPartitionExchangeId exchId) Post-initializes this topology.
void	beforeExchange(GridDhtPartitionExchangeId exchId) Pre-initializes this topology.
int	cacheId()
Collection<GridDhtLocalPartition<K,V>>	currentLocalPartitions()
GridDhtLocalPartition<K,V>	localPartition(int p, long topVer, boolean create)
GridDhtLocalPartition<K,V>	localPartition(K key, boolean create)
GridDhtPartitionMap	localPartitionMap()
List<GridDhtLocalPartition<K,V>>	localPartitions()
List<ClusterNode>	moving(int p)
Collection<ClusterNode>	nodes(int p, long topVer)
GridDhtLocalPartition<K,V>	onAdded(long topVer, GridDhtCacheEntry<K,V> e)
void	onEvicted(GridDhtLocalPartition<K,V> part, boolean updateSeq)
void	onRemoved(GridDhtCacheEntry<K,V> e)
boolean	own(GridDhtLocalPartition<K,V> part)
List<ClusterNode>	owners(int p)
List<ClusterNode>	owners(int p, long topVer)
GridDhtPartitionFullMap	partitionMap(boolean onlyActive)
GridDhtPartitionMap	partitions(UUID nodeId)
void	printMemoryStats(int threshold) Prints memory stats.
void	readLock() Locks the topology, usually during mapping on locks or transactions.
void	readUnlock() Unlocks topology locked by GridDhtPartitionTopology.readLock() method.
long	topologyVersion() Topology version.
GridDhtTopologyFuture	topologyVersionFuture() Gets a future that will be completed when partition exchange map for this particular topology version is done.
GridDhtPartitionMap	update(GridDhtPartitionExchangeId exchId, GridDhtPartitionFullMap partMap)
GridDhtPartitionMap	update(GridDhtPartitionExchangeId exchId, GridDhtPartitionMap parts)
long	updateSequence()
void	updateTopologyVersion(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture<K,V> exchFut) Updates topology version.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridClientPartitionTopology

public GridClientPartitionTopology(GridCacheSharedContext<K,V> cctx,
                           int cacheId,
                           GridDhtPartitionExchangeId exchId)

Parameters:

cctx - Context.

cacheId - Cache ID.

exchId - Exchange ID.

Method Detail

cacheId

public int cacheId()

Returns:

Cache ID.

readLock

public void readLock()

Locks the topology, usually during mapping on locks or transactions.

Specified by:

readLock in interface GridDhtPartitionTopology<K,V>

readUnlock

public void readUnlock()

Unlocks topology locked by GridDhtPartitionTopology.readLock() method.

Specified by:

readUnlock in interface GridDhtPartitionTopology<K,V>

updateTopologyVersion

public void updateTopologyVersion(GridDhtPartitionExchangeId exchId,
                         GridDhtPartitionsExchangeFuture<K,V> exchFut)

Updates topology version.

Specified by:

updateTopologyVersion in interface GridDhtPartitionTopology<K,V>

Parameters:

exchId - Exchange ID.

exchFut - Exchange future.

topologyVersion

public long topologyVersion()

Topology version.

Specified by:

topologyVersion in interface GridDhtPartitionTopology<K,V>

Returns:

Topology version.

topologyVersionFuture

public GridDhtTopologyFuture topologyVersionFuture()

Gets a future that will be completed when partition exchange map for this particular topology version is done.

Specified by:

topologyVersionFuture in interface GridDhtPartitionTopology<K,V>

Returns:

Topology version ready future.

beforeExchange

public void beforeExchange(GridDhtPartitionExchangeId exchId)

Pre-initializes this topology.

Specified by:

beforeExchange in interface GridDhtPartitionTopology<K,V>

Parameters:

exchId - Exchange ID for this pre-initialization.

afterExchange

public boolean afterExchange(GridDhtPartitionExchangeId exchId)
                      throws IgniteCheckedException

Post-initializes this topology.

Specified by:

afterExchange in interface GridDhtPartitionTopology<K,V>

Parameters:

exchId - Exchange ID for this post-initialization.

Returns:

True if mapping was changed.

Throws:

IgniteCheckedException - If failed.

localPartition

@Nullable
public GridDhtLocalPartition<K,V> localPartition(int p,
                                                 long topVer,
                                                 boolean create)
                                          throws GridDhtInvalidPartitionException

Specified by:

localPartition in interface GridDhtPartitionTopology<K,V>

Parameters:

p - Partition ID.

topVer - Topology version at the time of creation.

create - If true, then partition will be created if it's not there.

Returns:

Local partition.

Throws:

GridDhtInvalidPartitionException - If partition is evicted or absent and does not belong to this node.

localPartition

public GridDhtLocalPartition<K,V> localPartition(K key,
                                        boolean create)

Specified by:

localPartition in interface GridDhtPartitionTopology<K,V>

Parameters:

key - Cache key.

create - If true, then partition will be created if it's not there.

Returns:

Local partition.

localPartitions

public List<GridDhtLocalPartition<K,V>> localPartitions()

Specified by:

localPartitions in interface GridDhtPartitionTopology<K,V>

Returns:

All local partitions by copying them into another list.

currentLocalPartitions

public Collection<GridDhtLocalPartition<K,V>> currentLocalPartitions()

Specified by:

currentLocalPartitions in interface GridDhtPartitionTopology<K,V>

Returns:

All current local partitions.

onAdded

public GridDhtLocalPartition<K,V> onAdded(long topVer,
                                 GridDhtCacheEntry<K,V> e)

Specified by:

onAdded in interface GridDhtPartitionTopology<K,V>

Parameters:

topVer - Topology version.

e - Entry added to cache.

Returns:

Local partition.

onRemoved

public void onRemoved(GridDhtCacheEntry<K,V> e)

Specified by:

onRemoved in interface GridDhtPartitionTopology<K,V>

Parameters:

e - Entry removed from cache.

localPartitionMap

public GridDhtPartitionMap localPartitionMap()

Specified by:

localPartitionMap in interface GridDhtPartitionTopology<K,V>

Returns:

Local IDs.

nodes

public Collection<ClusterNode> nodes(int p,
                            long topVer)

Specified by:

nodes in interface GridDhtPartitionTopology<K,V>

Parameters:

p - Partition ID.

topVer - Topology version.

Returns:

Collection of all nodes responsible for this partition with primary node being first.

owners

public List<ClusterNode> owners(int p,
                       long topVer)

Specified by:

owners in interface GridDhtPartitionTopology<K,V>

Parameters:

p - Partition ID.

topVer - Topology version.

Returns:

Collection of all nodes who own this partition.

owners

public List<ClusterNode> owners(int p)

Specified by:

owners in interface GridDhtPartitionTopology<K,V>

Parameters:

p - Partition ID.

Returns:

Collection of all nodes who own this partition.

moving

public List<ClusterNode> moving(int p)

Specified by:

moving in interface GridDhtPartitionTopology<K,V>

Parameters:

p - Partition ID.

Returns:

Collection of all nodes who are preloading this partition.

updateSequence

public long updateSequence()

Specified by:

updateSequence in interface GridDhtPartitionTopology<K,V>

Returns:

Current update sequence.

partitionMap

public GridDhtPartitionFullMap partitionMap(boolean onlyActive)

Specified by:

partitionMap in interface GridDhtPartitionTopology<K,V>

Parameters:

onlyActive - If true, then only active partitions will be returned.

Returns:

Node IDs mapped to partitions.

update

@Nullable
public GridDhtPartitionMap update(@Nullable
                                  GridDhtPartitionExchangeId exchId,
                                  GridDhtPartitionFullMap partMap)

Specified by:

update in interface GridDhtPartitionTopology<K,V>

Parameters:

exchId - Exchange ID.

partMap - Update partition map.

Returns:

Local partition map if there were evictions or null otherwise.

update

@Nullable
public GridDhtPartitionMap update(@Nullable
                                  GridDhtPartitionExchangeId exchId,
                                  GridDhtPartitionMap parts)

Specified by:

update in interface GridDhtPartitionTopology<K,V>

Parameters:

exchId - Exchange ID.

parts - Partitions.

Returns:

Local partition map if there were evictions or null otherwise.

own

public boolean own(GridDhtLocalPartition<K,V> part)

Specified by:

own in interface GridDhtPartitionTopology<K,V>

Parameters:

part - Partition to own.

Returns:

True if owned.

onEvicted

public void onEvicted(GridDhtLocalPartition<K,V> part,
             boolean updateSeq)

Specified by:

onEvicted in interface GridDhtPartitionTopology<K,V>

Parameters:

part - Evicted partition.

partitions

@Nullable
public GridDhtPartitionMap partitions(UUID nodeId)

Specified by:

partitions in interface GridDhtPartitionTopology<K,V>

Parameters:

nodeId - Node to get partitions for.

Returns:

Partitions for node.

printMemoryStats

public void printMemoryStats(int threshold)

Prints memory stats.

Specified by:

printMemoryStats in interface GridDhtPartitionTopology<K,V>

Parameters:

threshold - Threshold for number of entries.