org.apache.ignite.internal.processors.affinity

Interface AffinityAssignment

All Known Implementing Classes:

GridAffinityAssignment, HistoryAffinityAssignment

public interface AffinityAssignment

Cached affinity calculations.

Method Summary

Modifier and Type	Method and Description
List<List<ClusterNode>>	assignment()
Set<Integer>	backupPartitions(UUID nodeId) Get backup partitions for specified node ID.
List<ClusterNode>	get(int part) Get affinity nodes for partition.
HashSet<UUID>	getIds(int part) Get affinity node IDs for partition.
List<List<ClusterNode>>	idealAssignment()
MvccCoordinator	mvccCoordinator()
Set<ClusterNode>	nodes()
Set<ClusterNode>	primaryPartitionNodes()
Set<Integer>	primaryPartitions(UUID nodeId) Get primary partitions for specified node ID.
AffinityTopologyVersion	topologyVersion()

Method Detail

idealAssignment

List<List<ClusterNode>> idealAssignment()

Returns:

Affinity assignment computed by affinity function.

assignment

List<List<ClusterNode>> assignment()

Returns:

Affinity assignment.

topologyVersion

AffinityTopologyVersion topologyVersion()

Returns:

Topology version.

get

List<ClusterNode> get(int part)

Get affinity nodes for partition.

Parameters:

part - Partition.

Returns:

Affinity nodes.

getIds

HashSet<UUID> getIds(int part)

Get affinity node IDs for partition.

Parameters:

part - Partition.

Returns:

Affinity nodes IDs.

nodes

Set<ClusterNode> nodes()

Returns:

Nodes having parimary and backup assignments.

primaryPartitionNodes

Set<ClusterNode> primaryPartitionNodes()

Returns:

Nodes having primary partitions assignments.

primaryPartitions

Set<Integer> primaryPartitions(UUID nodeId)

Get primary partitions for specified node ID.

Parameters:

nodeId - Node ID to get primary partitions for.

Returns:

Primary partitions for specified node ID.

backupPartitions

Set<Integer> backupPartitions(UUID nodeId)

Get backup partitions for specified node ID.

Parameters:

nodeId - Node ID to get backup partitions for.

Returns:

Backup partitions for specified node ID.

mvccCoordinator

MvccCoordinator mvccCoordinator()

Returns:

Mvcc coordinator.