org.apache.ignite.internal.processors.affinity

Class GridAffinityAssignmentCache

java.lang.Object

org.apache.ignite.internal.processors.affinity.GridAffinityAssignmentCache

public class GridAffinityAssignmentCache
extends Object

Affinity cached function.

Constructor Summary

Constructors

Constructor and Description
GridAffinityAssignmentCache(GridKernalContext ctx, String cacheName, AffinityFunction aff, IgnitePredicate<ClusterNode> nodeFilter, int backups, boolean locCache) Constructs affinity cached calculations.

Method Summary

Methods

Modifier and Type	Method and Description
List<List<ClusterNode>>	assignments(AffinityTopologyVersion topVer)
Set<Integer>	backupPartitions(UUID nodeId, AffinityTopologyVersion topVer) Get backup partitions for specified node ID.
GridAffinityAssignment	cachedAffinity(AffinityTopologyVersion topVer) Get cached affinity for specified topology version.
Integer	cacheId()
String	cacheName()
List<List<ClusterNode>>	calculate(AffinityTopologyVersion topVer, DiscoveryEvent discoEvt) Calculates affinity cache for given topology version.
void	cancelFutures(IgniteCheckedException err) Kernal stop callback.
boolean	centralizedAffinityFunction()
void	clientEventTopologyChange(DiscoveryEvent evt, AffinityTopologyVersion topVer) Copies previous affinity assignment when discovery event does not cause affinity assignment changes (e.g. client node joins on leaves).
void	dumpDebugInfo() Dumps debug information.
List<List<ClusterNode>>	idealAssignment()
void	idealAssignment(List<List<ClusterNode>> assignment)
void	init(GridAffinityAssignmentCache aff)
void	initialize(AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment) Initializes affinity with given topology version and assignment.
AffinityTopologyVersion	lastVersion()
List<ClusterNode>	nodes(int part, AffinityTopologyVersion topVer) Gets affinity nodes for specified partition.
void	onReconnected()
int	partitions()
boolean	primaryChanged(int part, AffinityTopologyVersion startVer, AffinityTopologyVersion endVer)
Set<Integer>	primaryPartitions(UUID nodeId, AffinityTopologyVersion topVer) Get primary partitions for specified node ID.
IgniteInternalFuture<AffinityTopologyVersion>	readyFuture(AffinityTopologyVersion topVer) Gets future that will be completed after topology with version topVer is calculated.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridAffinityAssignmentCache

public GridAffinityAssignmentCache(GridKernalContext ctx,
                           String cacheName,
                           AffinityFunction aff,
                           IgnitePredicate<ClusterNode> nodeFilter,
                           int backups,
                           boolean locCache)

Constructs affinity cached calculations.

Parameters:

ctx - Kernal context.

cacheName - Cache name.

aff - Affinity function.

nodeFilter - Node filter.

backups - Number of backups.

locCache - Local cache flag.

Method Detail

cacheName

public String cacheName()

Returns:

Cache name.

cacheId

public Integer cacheId()

Returns:

Cache ID.

initialize

public void initialize(AffinityTopologyVersion topVer,
              List<List<ClusterNode>> affAssignment)

Initializes affinity with given topology version and assignment.

Parameters:

topVer - Topology version.

affAssignment - Affinity assignment for topology version.

idealAssignment

public void idealAssignment(List<List<ClusterNode>> assignment)

Parameters:

assignment - Assignment.

idealAssignment

@Nullable
public List<List<ClusterNode>> idealAssignment()

Returns:

Assignment.

centralizedAffinityFunction

public boolean centralizedAffinityFunction()

Returns:

True if affinity function has AffinityCentralizedFunction annotation.

cancelFutures

public void cancelFutures(IgniteCheckedException err)

Kernal stop callback.

Parameters:

err - Error.

onReconnected

public void onReconnected()

calculate

public List<List<ClusterNode>> calculate(AffinityTopologyVersion topVer,
                                DiscoveryEvent discoEvt)

Calculates affinity cache for given topology version.

Parameters:

topVer - Topology version to calculate affinity cache for.

discoEvt - Discovery event that caused this topology version change.

Returns:

Affinity assignments.

clientEventTopologyChange

public void clientEventTopologyChange(DiscoveryEvent evt,
                             AffinityTopologyVersion topVer)

Copies previous affinity assignment when discovery event does not cause affinity assignment changes (e.g. client node joins on leaves).

Parameters:

evt - Event.

topVer - Topology version.

lastVersion

public AffinityTopologyVersion lastVersion()

Returns:

Last calculated affinity version.

assignments

public List<List<ClusterNode>> assignments(AffinityTopologyVersion topVer)

Parameters:

topVer - Topology version.

Returns:

Affinity assignment.

readyFuture

@Nullable
public IgniteInternalFuture<AffinityTopologyVersion> readyFuture(AffinityTopologyVersion topVer)

Gets future that will be completed after topology with version topVer is calculated.

Parameters:

topVer - Topology version to await for.

Returns:

Future that will be completed after affinity for topology version topVer is calculated.

partitions

public int partitions()

Returns:

Partition count.

nodes

public List<ClusterNode> nodes(int part,
                      AffinityTopologyVersion topVer)

Gets affinity nodes for specified partition.

Parameters:

part - Partition.

topVer - Topology version.

Returns:

Affinity nodes.

primaryPartitions

public Set<Integer> primaryPartitions(UUID nodeId,
                             AffinityTopologyVersion topVer)

Get primary partitions for specified node ID.

Parameters:

nodeId - Node ID to get primary partitions for.

topVer - Topology version.

Returns:

Primary partitions for specified node ID.

backupPartitions

public Set<Integer> backupPartitions(UUID nodeId,
                            AffinityTopologyVersion topVer)

Get backup partitions for specified node ID.

Parameters:

nodeId - Node ID to get backup partitions for.

topVer - Topology version.

Returns:

Backup partitions for specified node ID.

dumpDebugInfo

public void dumpDebugInfo()

Dumps debug information.

cachedAffinity

public GridAffinityAssignment cachedAffinity(AffinityTopologyVersion topVer)

Get cached affinity for specified topology version.

Parameters:

topVer - Topology version.

Returns:

Cached affinity.

primaryChanged

public boolean primaryChanged(int part,
                     AffinityTopologyVersion startVer,
                     AffinityTopologyVersion endVer)

Parameters:

part - Partition.

startVer - Start version.

endVer - End version.

Returns:

True if primary changed or required affinity version not found in history.

init

public void init(GridAffinityAssignmentCache aff)

Parameters:

aff - Affinity cache.