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

Class GridDhtPartitionMap

java.lang.Object

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

All Implemented Interfaces:

Externalizable, Serializable, Comparable<GridDhtPartitionMap>

public class GridDhtPartitionMap
extends Object
implements Comparable<GridDhtPartitionMap>, Externalizable

Partition map from single node.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected GridPartitionStateMap	map
protected UUID	nodeId	Node ID.
protected AffinityTopologyVersion	top	Topology version.
protected long	updateSeq	Update sequence number.

Constructor Summary

Constructors

Constructor	Description
GridDhtPartitionMap()	Empty constructor required for Externalizable.
GridDhtPartitionMap(UUID nodeId, long updateSeq, AffinityTopologyVersion top, GridPartitionStateMap m, boolean onlyActive)

Method Summary

Modifier and Type	Method	Description
int	compareTo(GridDhtPartitionMap o)
boolean	containsKey(Integer part)
GridDhtPartitionMap	emptyCopy()
Set<Map.Entry<Integer,GridDhtPartitionState>>	entrySet()
boolean	equals(Object o)
GridDhtPartitionState	get(int part)
int	hashCode()
boolean	hasMovingPartitions()
Set<Integer>	keySet()
GridPartitionStateMap	map()
UUID	nodeId()
void	put(Integer part, GridDhtPartitionState state)
void	readExternal(ObjectInput in)
int	size()
String	toFullString()
AffinityTopologyVersion	topologyVersion()
String	toString()
long	updateSequence()
long	updateSequence(long updateSeq, AffinityTopologyVersion topVer)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

nodeId

protected UUID nodeId

Node ID.

updateSeq

protected long updateSeq

Update sequence number.

top

protected AffinityTopologyVersion top

Topology version.

map

protected GridPartitionStateMap map

Constructor Detail

GridDhtPartitionMap

public GridDhtPartitionMap()

Empty constructor required for Externalizable.

GridDhtPartitionMap

public GridDhtPartitionMap(UUID nodeId,
                           long updateSeq,
                           AffinityTopologyVersion top,
                           GridPartitionStateMap m,
                           boolean onlyActive)

Parameters:

nodeId - Node ID.

updateSeq - Update sequence number.

top - Topology version.

m - Map to copy.

onlyActive - If true, then only active states will be included.

Method Detail

emptyCopy

public GridDhtPartitionMap emptyCopy()

Returns:

Copy with empty partition state map.

put

public void put(Integer part,
                GridDhtPartitionState state)

Parameters:

part - Partition.

state - Partition state.

hasMovingPartitions

public boolean hasMovingPartitions()

Returns:

true If partition map contains moving partitions.

get

public GridDhtPartitionState get(int part)

Parameters:

part - Partition.

Returns:

Partition state.

containsKey

public boolean containsKey(Integer part)

Parameters:

part - Partition.

Returns:

True if contains given partition.

entrySet

public Set<Map.Entry<Integer,GridDhtPartitionState>> entrySet()

Returns:

Entries.

size

public int size()

Returns:

Map size.

keySet

public Set<Integer> keySet()

Returns:

Partitions.

map

public GridPartitionStateMap map()

Returns:

Underlying map.

nodeId

public UUID nodeId()

Returns:

Node ID.

updateSequence

public long updateSequence()

Returns:

Update sequence.

updateSequence

public long updateSequence(long updateSeq,
                           AffinityTopologyVersion topVer)

Parameters:

updateSeq - New update sequence value.

topVer - Current topology version.

Returns:

Old update sequence value.

topologyVersion

public AffinityTopologyVersion topologyVersion()

Returns:

Topology version.

compareTo

public int compareTo(GridDhtPartitionMap o)

Specified by:

compareTo in interface Comparable<GridDhtPartitionMap>

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toFullString

public String toFullString()

Returns:

Full string representation.

toString

public String toString()

Overrides:

toString in class Object