org.apache.ignite.internal.processors.affinity

Class GridCacheAffinityFunctionContextImpl

java.lang.Object

org.apache.ignite.internal.processors.affinity.GridCacheAffinityFunctionContextImpl

All Implemented Interfaces:

CacheAffinityFunctionContext

public class GridCacheAffinityFunctionContextImpl
extends Object
implements CacheAffinityFunctionContext

Cache affinity function context implementation. Simple bean that holds all required fields.

Constructor Summary

Constructors

Constructor and Description
GridCacheAffinityFunctionContextImpl(List<ClusterNode> topSnapshot, List<List<ClusterNode>> prevAssignment, DiscoveryEvent discoEvt, long topVer, int backups)

Method Summary

Methods

Modifier and Type	Method and Description
int	backups() Gets number of backups for new assignment.
List<ClusterNode>	currentTopologySnapshot() Gets current topology snapshot.
long	currentTopologyVersion() Gets current topology version number.
DiscoveryEvent	discoveryEvent() Gets discovery event caused topology change.
List<ClusterNode>	previousAssignment(int part) Gets affinity assignment for given partition on previous topology version.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheAffinityFunctionContextImpl

public GridCacheAffinityFunctionContextImpl(List<ClusterNode> topSnapshot,
                                    List<List<ClusterNode>> prevAssignment,
                                    DiscoveryEvent discoEvt,
                                    long topVer,
                                    int backups)

Parameters:

topSnapshot - Topology snapshot.

topVer - Topology version.

Method Detail

previousAssignment

@Nullable
public List<ClusterNode> previousAssignment(int part)

Gets affinity assignment for given partition on previous topology version. First node in returned list is a primary node, other nodes are backups.

Specified by:

previousAssignment in interface CacheAffinityFunctionContext

Parameters:

part - Partition to get previous assignment for.

Returns:

List of nodes assigned to given partition on previous topology version or null if this information is not available.

currentTopologySnapshot

public List<ClusterNode> currentTopologySnapshot()

Gets current topology snapshot. Snapshot will contain only nodes on which particular cache is configured. List of passed nodes is guaranteed to be sorted in a same order on all nodes on which partition assignment is performed.

Specified by:

currentTopologySnapshot in interface CacheAffinityFunctionContext

Returns:

Cache topology snapshot.

currentTopologyVersion

public long currentTopologyVersion()

Gets current topology version number.

Specified by:

currentTopologyVersion in interface CacheAffinityFunctionContext

Returns:

Current topology version number.

discoveryEvent

@Nullable
public DiscoveryEvent discoveryEvent()

Gets discovery event caused topology change.

Specified by:

discoveryEvent in interface CacheAffinityFunctionContext

Returns:

Discovery event caused latest topology change or null if this information is not available.

backups

public int backups()

Gets number of backups for new assignment.

Specified by:

backups in interface CacheAffinityFunctionContext

Returns:

Number of backups for new assignment.