Uses of Class
org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion

Packages that use AffinityTopologyVersion

Package	Description
org.apache.ignite.cache.affinity	Contains cache node affinity implementations.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.client.thin
org.apache.ignite.internal.direct
org.apache.ignite.internal.direct.stream
org.apache.ignite.internal.events
org.apache.ignite.internal.jdbc.thin
org.apache.ignite.internal.management.cache
org.apache.ignite.internal.management.tx
org.apache.ignite.internal.managers.discovery	TODO.
org.apache.ignite.internal.managers.failover	TODO.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.authentication
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.binary	Implementation of binary processor.
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.atomic
org.apache.ignite.internal.processors.cache.distributed.dht.colocated
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch
org.apache.ignite.internal.processors.cache.distributed.dht.topology
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.distributed.near.consistency
org.apache.ignite.internal.processors.cache.dr
org.apache.ignite.internal.processors.cache.persistence	This package contain cache with persistence implementation.
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.query.continuous
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.closure	TODO.
org.apache.ignite.internal.processors.cluster
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.job	TODO.
org.apache.ignite.internal.processors.marshaller
org.apache.ignite.internal.processors.odbc.jdbc
org.apache.ignite.internal.processors.platform
org.apache.ignite.internal.processors.platform.callback
org.apache.ignite.internal.processors.platform.client
org.apache.ignite.internal.processors.query
org.apache.ignite.internal.processors.query.aware
org.apache.ignite.internal.processors.query.h2.twostep.messages
org.apache.ignite.internal.processors.query.schema.message
org.apache.ignite.internal.processors.query.stat
org.apache.ignite.internal.processors.query.stat.messages
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.sql.optimizer.affinity
org.apache.ignite.internal.util.distributed
org.apache.ignite.plugin.extensions.communication	Contains extendable components for communication.
org.apache.ignite.spi.communication.tcp.internal	Contains connection health-checkers for TCP/IP-based implementation of communication SPI.
org.apache.ignite.spi.indexing	Contains APIs for indexing SPI.

Uses of AffinityTopologyVersion in org.apache.ignite.cache.affinity

Methods in org.apache.ignite.cache.affinity that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	AffinityFunctionContext.currentTopologyVersion()	Gets current topology version number.

Uses of AffinityTopologyVersion in org.apache.ignite.internal

Methods in org.apache.ignite.internal that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridJobExecuteResponse.getRetryTopologyVersion()
AffinityTopologyVersion	GridJobExecuteRequest.getTopVer()

Methods in org.apache.ignite.internal with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	IgniteDiagnosticPrepareContext.exchangeInfo(UUID nodeId, AffinityTopologyVersion topVer, String msg)
void	GridMessageListenHandler.updateCounters(AffinityTopologyVersion topVer, Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode, Map<Integer,T2<Long,Long>> cntrs)

Constructors in org.apache.ignite.internal with parameters of type AffinityTopologyVersion

Constructor	Description
GridJobExecuteRequest(IgniteUuid sesId, IgniteUuid jobId, String taskName, String userVer, String taskClsName, byte[] jobBytes, ComputeJob job, long startTaskTime, long timeout, @Nullable Collection<UUID> top, @Nullable IgnitePredicate<ClusterNode> topPred, byte[] topPredBytes, byte[] siblingsBytes, Collection<ComputeJobSibling> siblings, byte[] sesAttrsBytes, Map<Object,Object> sesAttrs, byte[] jobAttrsBytes, Map<? extends Serializable,? extends Serializable> jobAttrs, String cpSpi, IgniteUuid clsLdrId, DeploymentMode depMode, boolean dynamicSiblings, Map<UUID,IgniteUuid> ldrParticipants, boolean forceLocDep, boolean sesFullSup, boolean internal, @org.jetbrains.annotations.Nullable int[] cacheIds, int part, @Nullable AffinityTopologyVersion topVer, @Nullable String execName)
GridJobExecuteResponse(UUID nodeId, IgniteUuid sesId, IgniteUuid jobId, byte[] gridExBytes, IgniteException gridEx, byte[] resBytes, Object res, byte[] jobAttrsBytes, Map<Object,Object> jobAttrs, boolean isCancelled, AffinityTopologyVersion retry)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.client.thin

Methods in org.apache.ignite.internal.client.thin that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	ClientCacheAffinityMapping.topologyVersion()	Gets topology version.

Methods in org.apache.ignite.internal.client.thin with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
boolean	ClientCacheAffinityContext.updateLastTopologyVersion(AffinityTopologyVersion topVer, UUID nodeId)	Update topology version if it's greater than current version and store nodes for last topology.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.direct

Methods in org.apache.ignite.internal.direct that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	DirectMessageReader.readAffinityTopologyVersion(String name)	Reads AffinityTopologyVersion.

Methods in org.apache.ignite.internal.direct with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
boolean	DirectMessageWriter.writeAffinityTopologyVersion(String name, AffinityTopologyVersion val)	Writes AffinityTopologyVersion.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.direct.stream

Methods in org.apache.ignite.internal.direct.stream that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	DirectByteBufferStream.readAffinityTopologyVersion()

Methods in org.apache.ignite.internal.direct.stream with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	DirectByteBufferStream.writeAffinityTopologyVersion(AffinityTopologyVersion val)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.events

Methods in org.apache.ignite.internal.events that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	DiscoveryCustomEvent.affinityTopologyVersion()

Methods in org.apache.ignite.internal.events with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	DiscoveryCustomEvent.affinityTopologyVersion(AffinityTopologyVersion affTopVer)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.jdbc.thin

Methods in org.apache.ignite.internal.jdbc.thin that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	AffinityCache.version()

Constructors in org.apache.ignite.internal.jdbc.thin with parameters of type AffinityTopologyVersion

Constructor	Description
AffinityCache(AffinityTopologyVersion ver, int partitionAwarenessPartDistributionsCacheSize, int partitionAwarenessSQLCacheSize)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.management.cache

Fields in org.apache.ignite.internal.management.cache declared as AffinityTopologyVersion

Modifier and Type	Field	Description
AffinityTopologyVersion	CacheInfo.topVer	Topology version.

Methods in org.apache.ignite.internal.management.cache that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	CacheInfo.getTopologyVersion()

Methods in org.apache.ignite.internal.management.cache with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	CacheInfo.setTopologyVersion(AffinityTopologyVersion topologyVersion)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.management.tx

Methods in org.apache.ignite.internal.management.tx that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	TxInfo.getTopologyVersion()

Constructors in org.apache.ignite.internal.management.tx with parameters of type AffinityTopologyVersion

Constructor	Description
TxInfo(IgniteUuid xid, long startTime, long duration, TransactionIsolation isolation, TransactionConcurrency concurrency, long timeout, String lb, Collection<UUID> primaryNodes, TransactionState state, int size, IgniteUuid nearXid, Collection<UUID> masterNodeIds, AffinityTopologyVersion topVer, TxVerboseInfo info)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.managers.discovery

Methods in org.apache.ignite.internal.managers.discovery that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	DiscoveryLocalJoinData.joinTopologyVersion()
AffinityTopologyVersion	GridDiscoveryManager.topologyVersionEx()
AffinityTopologyVersion	DiscoCache.version()

Methods in org.apache.ignite.internal.managers.discovery with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable List<? extends BaselineNode>	GridDiscoveryManager.baselineNodes(AffinityTopologyVersion topVer)
Collection<ClusterNode>	GridDiscoveryManager.cacheGroupAffinityNodes(int grpId, AffinityTopologyVersion topVer)	Gets cache nodes for cache with given ID that participate in affinity calculation.
List<ClusterNode>	GridDiscoveryManager.cacheNodes(@Nullable String cacheName, AffinityTopologyVersion topVer)	Gets cache nodes for cache with given name.
Map<UUID,Short>	GridDiscoveryManager.consistentId(AffinityTopologyVersion topVer)	Gets consistentId from history for given topology version.
DiscoCache	DiscoCache.copy(AffinityTopologyVersion ver, @Nullable DiscoveryDataClusterState state)
DiscoCache	DiscoveryCustomMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	GridDiscoveryManager.createDiscoCacheOnCacheChange(AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates discovery cache after DynamicCacheChangeBatch received.
DiscoCache	GridDiscoveryManager.discoCache(AffinityTopologyVersion topVer)	Gets discovery collection cache from SPI safely guarding against "floating" collections.
short	ConsistentIdMapper.mapToCompactId(AffinityTopologyVersion topVer, UUID nodeId)	Maps UUID to compact ID for given baseline topology.
Map<Short,Collection<Short>>	ConsistentIdMapper.mapToCompactIds(AffinityTopologyVersion topVer, @Nullable Map<UUID,Collection<UUID>> txNodes, BaselineTopology baselineTop)	Map primary -> backup node compact ID accordingly to baseline topology..
UUID	ConsistentIdMapper.mapToUuid(AffinityTopologyVersion topVer, short nodeConstId)	Maps UUID to compact ID for given baseline topology.
ClusterNode	GridDiscoveryManager.node(AffinityTopologyVersion topVer, UUID id)	Gets node from history for given topology version.
Map<Short,UUID>	GridDiscoveryManager.nodeIdMap(AffinityTopologyVersion topVer)	Gets consistentId from history for given topology version.
Collection<ClusterNode>	GridDiscoveryManager.nodes(AffinityTopologyVersion topVer)	Gets all nodes for given topology version.
@Nullable ClusterNode	GridDiscoveryManager.oldestAliveServerNode(AffinityTopologyVersion topVer)
void	CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer, ClusterNode snd, T msg)
Collection<ClusterNode>	GridDiscoveryManager.remoteAliveNodesWithCaches(AffinityTopologyVersion topVer)	Gets cache remote nodes for cache with given name.
List<ClusterNode>	GridDiscoveryManager.serverNodes(AffinityTopologyVersion topVer)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.managers.failover

Methods in org.apache.ignite.internal.managers.failover that return AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable AffinityTopologyVersion	GridFailoverContextImpl.affinityTopologyVersion()

Methods in org.apache.ignite.internal.managers.failover with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
ClusterNode	GridFailoverManager.failover(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, List<ClusterNode> top, int affPartId, @Nullable String affCacheName, @Nullable AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.managers.failover with parameters of type AffinityTopologyVersion

Constructor	Description
GridFailoverContextImpl(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, GridLoadBalancerManager loadMgr, int partId, @Nullable String affCacheName, @Nullable AffinityTopologyVersion topVer)	Initializes failover context.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.affinity

Fields in org.apache.ignite.internal.processors.affinity declared as AffinityTopologyVersion

Modifier and Type	Field	Description
static AffinityTopologyVersion	AffinityTopologyVersion.NONE
static AffinityTopologyVersion	AffinityTopologyVersion.ZERO

Methods in org.apache.ignite.internal.processors.affinity that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridAffinityFunctionContextImpl.currentTopologyVersion()	Gets current topology version number.
AffinityTopologyVersion	GridAffinityAssignmentCache.lastVersion()
AffinityTopologyVersion	AffinityTopologyVersion.nextMinorVersion()
AffinityTopologyVersion	AffinityAssignment.topologyVersion()
AffinityTopologyVersion	GridAffinityAssignment.topologyVersion()	Deprecated.
AffinityTopologyVersion	GridAffinityAssignmentV2.topologyVersion()
AffinityTopologyVersion	HistoryAffinityAssignmentImpl.topologyVersion()
AffinityTopologyVersion	HistoryAffinityAssignmentShallowCopy.topologyVersion()
AffinityTopologyVersion	IdealAffinityAssignment.topologyVersion()

Methods in org.apache.ignite.internal.processors.affinity that return types with arguments of type AffinityTopologyVersion

Modifier and Type	Method	Description
NavigableSet<AffinityTopologyVersion>	GridAffinityAssignmentCache.cachedVersions()
@Nullable IgniteInternalFuture<AffinityTopologyVersion>	GridAffinityAssignmentCache.readyFuture(AffinityTopologyVersion topVer)	Gets future that will be completed after topology with version topVer is calculated.

Methods in org.apache.ignite.internal.processors.affinity with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
IgniteInternalFuture<org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.AffinityInfo>	GridAffinityProcessor.affinityCacheFuture(String cacheName, @Nullable AffinityTopologyVersion topVer)
boolean	AffinityTopologyVersion.after(AffinityTopologyVersion topVer)
List<List<ClusterNode>>	GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer)
Set<Integer>	GridAffinityAssignmentCache.backupPartitions(UUID nodeId, AffinityTopologyVersion topVer)	Get backup partitions for specified node ID.
boolean	AffinityTopologyVersion.before(AffinityTopologyVersion topVer)
AffinityAssignment	GridAffinityAssignmentCache.cachedAffinity(AffinityTopologyVersion topVer)	Get cached affinity for specified topology version.
AffinityAssignment	GridAffinityAssignmentCache.cachedAffinity(AffinityTopologyVersion topVer, AffinityTopologyVersion lastAffChangeTopVer)	Get cached affinity for specified topology version.
IdealAffinityAssignment	GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer, @Nullable ExchangeDiscoveryEvents events, @Nullable DiscoCache discoCache)	Calculates ideal assignment for given topology version and events happened since last calculation.
void	GridAffinityAssignmentCache.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).
int	AffinityTopologyVersion.compareTo(AffinityTopologyVersion o)
static IdealAffinityAssignment	IdealAffinityAssignment.create(AffinityTopologyVersion topVer, @Nullable List<ClusterNode> nodes, List<List<ClusterNode>> assignment)
static IdealAffinityAssignment	IdealAffinityAssignment.create(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment)
static IdealAffinityAssignment	IdealAffinityAssignment.createWithPreservedPrimaries(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment, IdealAffinityAssignment previousAssignment)
void	GridAffinityAssignmentCache.idealAssignment(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment)
void	GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment)	Initializes affinity with given topology version and assignment.
boolean	AffinityTopologyVersion.isBetween(AffinityTopologyVersion lower, AffinityTopologyVersion upper)
<K> @Nullable ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key, AffinityTopologyVersion topVer)	Maps single key to a node.
<K> List<ClusterNode>	GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName, K key, AffinityTopologyVersion topVer)	Map single key to primary and backup nodes.
@Nullable ClusterNode	GridAffinityProcessor.mapPartitionToNode(String cacheName, int partId, AffinityTopologyVersion topVer)	Maps partition to a node.
List<ClusterNode>	GridAffinityAssignmentCache.nodes(int part, AffinityTopologyVersion topVer)	Gets affinity nodes for specified partition.
Set<Integer>	GridAffinityAssignmentCache.partitionPrimariesDifferentToIdeal(AffinityTopologyVersion topVer)
boolean	GridAffinityAssignmentCache.primaryChanged(int part, AffinityTopologyVersion startVer, AffinityTopologyVersion endVer)
Set<Integer>	GridAffinityAssignmentCache.primaryPartitions(UUID nodeId, AffinityTopologyVersion topVer)	Get primary partitions for specified node ID.
AffinityAssignment	GridAffinityAssignmentCache.readyAffinity(AffinityTopologyVersion topVer)
List<List<ClusterNode>>	GridAffinityAssignmentCache.readyAssignments(AffinityTopologyVersion topVer)
@Nullable IgniteInternalFuture<AffinityTopologyVersion>	GridAffinityAssignmentCache.readyFuture(AffinityTopologyVersion topVer)	Gets future that will be completed after topology with version topVer is calculated.
void	GridAffinityProcessor.removeCachedAffinity(AffinityTopologyVersion topVer)	Removes cached affinity instances with affinity topology versions less than topVer.

Constructors in org.apache.ignite.internal.processors.affinity with parameters of type AffinityTopologyVersion

Constructor	Description
GridAffinityAssignmentV2(AffinityTopologyVersion topVer, List<List<ClusterNode>> assignment, List<List<ClusterNode>> idealAssignment)
GridAffinityFunctionContextImpl(List<ClusterNode> topSnapshot, List<List<ClusterNode>> prevAssignment, DiscoveryEvent discoEvt, @NotNull AffinityTopologyVersion topVer, int backups)
HistoryAffinityAssignmentShallowCopy(HistoryAffinityAssignment histAssignment, AffinityTopologyVersion topVer)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.authentication

Methods in org.apache.ignite.internal.processors.authentication with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable DiscoCache	UserAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	UserProposedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache

Fields in org.apache.ignite.internal.processors.cache declared as AffinityTopologyVersion

Modifier and Type	Field	Description
protected AffinityTopologyVersion	GridCacheAdapter.TopologyVersionAwareJob.topVer	Affinity topology version.

Methods in org.apache.ignite.internal.processors.cache that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridCacheAffinityManager.affinityTopologyVersion()
AffinityTopologyVersion	StartCacheInfo.getExchangeTopVer()
AffinityTopologyVersion	GridCacheMessage.lastAffinityChangedTopologyVersion()	Returns the earliest affinity topology version for which this message is valid.
AffinityTopologyVersion	GridCachePartitionExchangeManager.lastAffinityChangedTopologyVersion(AffinityTopologyVersion topVer)
@Nullable AffinityTopologyVersion	GridCacheMvccManager.lastExplicitLockTopologyVersion(long threadId)
AffinityTopologyVersion	CacheGroupContext.localStartVersion()
@Nullable AffinityTopologyVersion	GridCacheSharedContext.lockedTopologyVersion(IgniteInternalTx ignore)
AffinityTopologyVersion	GridCachePartitionExchangeManager.mergeExchangesTestWaitVersion()	For testing only.
AffinityTopologyVersion	GridCachePartitionExchangeManager.onKernalStart(boolean active, boolean reconnect)
AffinityTopologyVersion	GridCachePartitionExchangeManager.readyAffinityVersion()
@Nullable AffinityTopologyVersion	CacheGroupData.startTopologyVersion()
@Nullable AffinityTopologyVersion	CacheGroupDescriptor.startTopologyVersion()
@Nullable AffinityTopologyVersion	DynamicCacheDescriptor.startTopologyVersion()
AffinityTopologyVersion	GridCacheContext.startTopologyVersion()
AffinityTopologyVersion	CacheAffinityChangeMessage.topologyVersion()
AffinityTopologyVersion	CachePartialUpdateCheckedException.topologyVersion()
AffinityTopologyVersion	ExchangeDiscoveryEvents.topologyVersion()
@Nullable AffinityTopologyVersion	GridCacheExplicitLockSpan.topologyVersion()	Gets actual topology snapshot for thread lock span.
AffinityTopologyVersion	GridCacheMessage.topologyVersion()	Gets topology version or -1 in case of topology version is not required for this message.
AffinityTopologyVersion	GridCacheMvccCandidate.topologyVersion()
AffinityTopologyVersion	ReaderArguments.topologyVersion()
AffinityTopologyVersion	StateChangeRequest.topologyVersion()

Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type AffinityTopologyVersion

Modifier and Type	Method	Description
IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuture(long topVer)	Gets affinity ready future, a future that will be completed after affinity with given topology version is calculated.
IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuture(AffinityTopologyVersion topVer)	Gets affinity ready future, a future that will be completed after affinity with given topology version is calculated.
@NotNull IgniteInternalFuture<AffinityTopologyVersion>	GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion ver)
@Nullable IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuturex(AffinityTopologyVersion topVer)	Gets affinity ready future that will be completed after affinity with given topology version is calculated.

Methods in org.apache.ignite.internal.processors.cache with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	CachePartialUpdateCheckedException.add(Collection<?> failedKeys, Throwable err, AffinityTopologyVersion topVer)
<Msg extends GridCacheMessage> void	GridCacheIoManager.addCacheHandler(int hndId, AffinityTopologyVersion startTopVer, Class<Msg> type, IgniteBiInClosure<UUID,? super Msg> c)
boolean	GridCacheExplicitLockSpan.addCandidate(AffinityTopologyVersion topVer, GridCacheMvccCandidate cand)	Adds candidate to a lock span.
GridFutureAdapter	GridCacheMvccManager.addDataStreamerFuture(AffinityTopologyVersion topVer)
void	GridCacheMvccManager.addExplicitLock(long threadId, GridCacheMvccCandidate cand, AffinityTopologyVersion topVer)	Adds candidate to the list of near local candidates.
void	CacheAffinitySharedManager.addToWaitGroup(int grpId, int part, AffinityTopologyVersion topVer, List<ClusterNode> assignment)	Adds group partition to wait list.
boolean	GridCachePartitionExchangeManager.affinityChanged(AffinityTopologyVersion from, AffinityTopologyVersion to)
static Collection<ClusterNode>	GridCacheUtils.affinityNodes(GridCacheContext ctx, AffinityTopologyVersion topVer)	Gets DHT affinity nodes.
IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuture(AffinityTopologyVersion topVer)	Gets affinity ready future, a future that will be completed after affinity with given topology version is calculated.
@NotNull IgniteInternalFuture<AffinityTopologyVersion>	GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion ver)
@Nullable IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuturex(AffinityTopologyVersion topVer)	Gets affinity ready future that will be completed after affinity with given topology version is calculated.
AffinityAssignment	GridCacheAffinityManager.assignment(AffinityTopologyVersion topVer)	Get affinity assignment for the given topology version.
AffinityAssignment	GridCacheAffinityManager.assignment(AffinityTopologyVersion topVer, AffinityTopologyVersion lastAffChangedTopVer)	Get affinity assignment for the given topology version.
List<List<ClusterNode>>	GridCacheAffinityManager.assignments(AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.backupByPartition(ClusterNode n, int part, AffinityTopologyVersion topVer)
Set<Integer>	GridCacheAffinityManager.backupPartitions(UUID nodeId, AffinityTopologyVersion topVer)
Collection<ClusterNode>	GridCacheAffinityManager.backupsByKey(Object key, AffinityTopologyVersion topVer)
long	IgniteCacheOffheapManager.cacheEntriesCount(int cacheId, boolean primary, boolean backup, AffinityTopologyVersion topVer)
long	IgniteCacheOffheapManagerImpl.cacheEntriesCount(int cacheId, boolean primary, boolean backup, AffinityTopologyVersion topVer)
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>>	IgniteCacheOffheapManager.cacheEntriesIterator(GridCacheContext cctx, boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary, Boolean dataPageScanEnabled)
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>>	IgniteCacheOffheapManagerImpl.cacheEntriesIterator(GridCacheContext cctx, boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary, Boolean dataPageScanEnabled)
GridIterator<CacheDataRow>	IgniteCacheOffheapManager.cacheIterator(int cacheId, boolean primary, boolean backup, AffinityTopologyVersion topVer, Boolean dataPageScanEnabled)
GridIterator<CacheDataRow>	IgniteCacheOffheapManagerImpl.cacheIterator(int cacheId, boolean primary, boolean backups, AffinityTopologyVersion topVer, Boolean dataPageScanEnabled)
void	ClusterCachesInfo.cleanupRemovedCacheGroups(AffinityTopologyVersion topVer)	Cleanups cache group descriptors that belong to the topVer and earlier.
void	ClusterCachesInfo.cleanupRemovedCaches(AffinityTopologyVersion topVer)	Cleanups cache descriptors that belong to the topVer and earlier.
IgniteInternalFuture<Void>	GridCacheAtomicFuture.completeFuture(AffinityTopologyVersion topVer)	Gets future that will be completed when it is safe when update is finished on the given version of topology.
void	GridCacheProcessor.completeProxyRestart(Map<String,DynamicCacheChangeRequest> reqs, AffinityTopologyVersion initVer, AffinityTopologyVersion doneVer)
GridCacheMapEntry	GridCacheMapEntryFactory.create(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key)
static @Nullable GridCacheUtils.BackupPostProcessingClosure	GridCacheUtils.createBackupPostProcessingClosure(AffinityTopologyVersion topVer, IgniteLogger log, GridCacheContext cctx, @Nullable KeyCacheObject key, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean readThrough, boolean skipVals)	Creates closure that saves initial value to backup partition.
@Nullable DiscoCache	CacheAffinityChangeMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	CacheStatisticsClearMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	CacheStatisticsModeChangeMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	ClientCacheChangeDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	ClientCacheChangeDummyDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	DynamicCacheChangeBatch.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	DynamicCacheChangeFailureMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	TxTimeoutOnPartitionMapExchangeChangeMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	WalStateAbstractMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
void	GridCacheContext.dhtMap(UUID nearNodeId, AffinityTopologyVersion topVer, GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, @Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
GridCacheEntryEx	GridCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishAtomicUpdates(AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishDataStreamerUpdates(AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishExplicitLocks(AffinityTopologyVersion topVer)	Creates a future that will wait for all explicit locks acquired on given topology version to be released.
IgniteInternalFuture<?>	GridCacheMvccManager.finishKeys(Collection<KeyCacheObject> keys, int cacheId, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishLocks(AffinityTopologyVersion topVer)
void	GridCachePartitionExchangeManager.finishPreloading(AffinityTopologyVersion topVer, int grpId, long rebalanceId)
void	GridCachePreloader.finishPreloading(AffinityTopologyVersion topVer, long rebalanceId)	Finish preloading for given topology version.
void	GridCachePreloaderAdapter.finishPreloading(AffinityTopologyVersion topVer, long rebalanceId)	Finish preloading for given topology version.
void	CacheGroupContext.finishRecovery(AffinityTopologyVersion startVer, UUID originalReceivedFrom, boolean affinityNode)	Finishes recovery for current cache group.
void	GridCacheContext.finishRecovery(AffinityTopologyVersion topVer, DynamicCacheDescriptor clusterWideDesc)	Called when cache was restored during recovery and node has joined to topology.
IgniteInternalFuture<?>	GridCacheMvccManager.finishRemoteTxs(AffinityTopologyVersion topVer)	Creates a future that will wait for finishing all remote transactions (primary -> backup) with topology version less or equal to topVer.
default boolean	GridCacheEntryEx.initialValue(CacheObject val, GridCacheVersion ver, long ttl, long expireTime, boolean preload, AffinityTopologyVersion topVer, GridDrType drType, boolean fromStore, boolean primary)	Sets new value if current version is 0
boolean	GridCacheEntryEx.initialValue(CacheObject val, GridCacheVersion ver, long ttl, long expireTime, boolean preload, AffinityTopologyVersion topVer, GridDrType drType, boolean fromStore, boolean primary, @Nullable CacheDataRow row)	Sets new value if current version is 0
boolean	GridCacheMapEntry.initialValue(CacheObject val, GridCacheVersion ver, long ttl, long expireTime, boolean preload, AffinityTopologyVersion topVer, GridDrType drType, boolean fromStore, boolean primary, CacheDataRow row)	Sets new value if current version is 0
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, @Nullable CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateAtomicResult	GridCacheEntryEx.innerUpdate(GridCacheVersion ver, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, @Nullable Object val, @Nullable Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean checkVer, boolean readRepairRecovery, AffinityTopologyVersion topVer, @Nullable CacheEntryPredicate[] filter, GridDrType drType, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, String taskName, @Nullable CacheObject prevVal, @Nullable Long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, boolean transformOp)
GridCacheUpdateAtomicResult	GridCacheMapEntry.innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, @Nullable Object writeObj, @Nullable Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean verCheck, boolean readRepairRecovery, AffinityTopologyVersion topVer, @Nullable CacheEntryPredicate[] filter, GridDrType drType, long explicitTtl, long explicitExpireTime, @Nullable GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, String taskName, @Nullable CacheObject prevVal, @Nullable Long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, boolean transformOp)
<T> @Nullable javax.cache.processor.EntryProcessorResult<T>	GridCacheAdapter.invoke(@Nullable AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> @Nullable javax.cache.processor.EntryProcessorResult<T>	GridCacheProxyImpl.invoke(AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> T	IgniteCacheProxyImpl.invoke(@Nullable AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> @Nullable javax.cache.processor.EntryProcessorResult<T>	IgniteInternalCache.invoke(@Nullable AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
boolean	GridCacheAffinityManager.isCompatibleWithCurrentTopologyVersion(AffinityTopologyVersion rmtVer)
boolean	GridCacheAffinityManager.keyLocalNode(Object key, AffinityTopologyVersion topVer)
void	GridCacheMessage.lastAffinityChangedTopologyVersion(AffinityTopologyVersion topVer)	Sets the earliest affinity topology version for which this message is valid.
AffinityTopologyVersion	GridCachePartitionExchangeManager.lastAffinityChangedTopologyVersion(AffinityTopologyVersion topVer)
boolean	GridCachePartitionExchangeManager.lastAffinityChangedTopologyVersion(AffinityTopologyVersion topVer, AffinityTopologyVersion lastAffTopVer)
boolean	GridCachePartitionExchangeManager.mergeExchangesOnCoordinator(GridDhtPartitionsExchangeFuture curFut, @Nullable AffinityTopologyVersion threshold)
void	GridCachePartitionExchangeManager.mergeExchangesTestWaitVersion(AffinityTopologyVersion exchMergeTestWaitVer, @Nullable List mergedEvtsForTest)	For testing only.
IgniteInternalFuture<?>	GridCacheSharedContext.nextAffinityReadyFuture(AffinityTopologyVersion curVer)	Gets ready future for the next affinity topology version (used in cases when a node leaves grid).
protected long	GridCacheMapEntry.nextPartitionCounter(AffinityTopologyVersion topVer, boolean primary, boolean initial, @Nullable Long primaryCntr)
List<ClusterNode>	GridCacheAffinityManager.nodesByKey(Object key, AffinityTopologyVersion topVer)
List<ClusterNode>	GridCacheAffinityManager.nodesByPartition(int part, AffinityTopologyVersion topVer)
boolean	ClusterCachesInfo.onCacheChangeRequested(DynamicCacheChangeBatch batch, AffinityTopologyVersion topVer)
void	ClusterCachesInfo.onCacheChangeRequested(DynamicCacheChangeFailureMessage failMsg, AffinityTopologyVersion topVer)	Creates exchanges actions.
boolean	GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg, AffinityTopologyVersion topVer, ClusterNode node)	Callback invoked from discovery thread when discovery custom message is received.
void	ClusterCachesInfo.onDiscoveryEvent(int type, ClusterNode node, AffinityTopologyVersion topVer)	Discovery event callback, executed from discovery thread.
void	GridCacheProcessor.onDiscoveryEvent(int type, @Nullable DiscoveryCustomMessage customMsg, ClusterNode node, AffinityTopologyVersion topVer, DiscoveryDataClusterState state)
void	GridCachePartitionExchangeManager.onExchangeDone(AffinityTopologyVersion topVer, AffinityTopologyVersion initTopVer, @Nullable Throwable err)
void	GridCacheProcessor.onExchangeDone(AffinityTopologyVersion cacheStartVer, @Nullable ExchangeActions exchActions, @Nullable Throwable err)	Callback invoked when first exchange future for dynamic cache is completed.
Set<Integer>	CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut, Map<Integer,CacheGroupAffinityMessage> receivedAff, AffinityTopologyVersion resTopVer)
void	CacheGroupContext.onPartitionCounterUpdate(int cacheId, int part, long cntr, AffinityTopologyVersion topVer, boolean primary)
ExchangeActions	ClusterCachesInfo.onStateChangeRequest(ChangeGlobalStateMessage msg, AffinityTopologyVersion topVer, DiscoveryDataClusterState curState)
ExchangeActions	GridCacheProcessor.onStateChangeRequest(ChangeGlobalStateMessage msg, AffinityTopologyVersion topVer, DiscoveryDataClusterState curState)
abstract IgniteInternalFuture<T>	GridCacheAdapter.AsyncOp.op(GridNearTxLocal tx, AffinityTopologyVersion readyTopVer)
boolean	GridCacheAffinityManager.partitionBelongs(ClusterNode node, int part, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.partitionLocalNode(int part, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheSharedContext.partitionRecoveryFuture(AffinityTopologyVersion topVer, ClusterNode node)	Captures all prepared operations that we need to wait before we able to perform PME-free switch.
IgniteInternalFuture<?>	GridCacheSharedContext.partitionReleaseFuture(AffinityTopologyVersion topVer)	Captures all ongoing operations that we need to wait before we can proceed to the next topology version.
@Nullable CacheObject	GridCacheEntryEx.peek(boolean heap, boolean offheap, AffinityTopologyVersion topVer, @Nullable IgniteCacheExpiryPolicy plc)	Peeks into entry without loading value or updating statistics.
@Nullable CacheObject	GridCacheMapEntry.peek(boolean heap, boolean offheap, AffinityTopologyVersion topVer, @Nullable IgniteCacheExpiryPolicy expiryPlc)	Peeks into entry without loading value or updating statistics.
void	GridCacheProcessor.prepareCacheStart(DynamicCacheDescriptor desc, @Nullable NearCacheConfiguration reqNearCfg, AffinityTopologyVersion exchTopVer, boolean disabledAfterStart, boolean clientCache)
@Nullable ClusterNode	GridCacheAffinityManager.primaryByKey(Object key, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primaryByKey(ClusterNode n, Object key, AffinityTopologyVersion topVer)
@Nullable ClusterNode	GridCacheAffinityManager.primaryByPartition(int part, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primaryByPartition(ClusterNode n, int part, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primaryChanged(int part, AffinityTopologyVersion startVer, AffinityTopologyVersion endVer)
Set<Integer>	GridCacheAffinityManager.primaryPartitions(UUID nodeId, AffinityTopologyVersion topVer)
GridCacheMapEntry	GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)
protected GridCacheMapEntry	GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(@Nullable GridCacheConcurrentMap.CacheMapHolder hld, GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)
GridCacheMapEntry	GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)
GridCacheMapEntry	GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)
static String	WalStateManager.reason(long grpId, AffinityTopologyVersion topVer)	Checkpoint reason for enabling group durability.
IgniteRebalanceIterator	IgniteCacheOffheapManager.rebalanceIterator(IgniteDhtDemandedPartitionsMap parts, AffinityTopologyVersion topVer)
IgniteRebalanceIterator	IgniteCacheOffheapManagerImpl.rebalanceIterator(IgniteDhtDemandedPartitionsMap parts, AffinityTopologyVersion topVer)
protected void	GridCacheMapEntry.recordNodeId(UUID nodeId, AffinityTopologyVersion topVer)
void	GridCacheContext.releaseForFastLocalGet(int part, AffinityTopologyVersion topVer)	Releases the partition that was reserved by a call to GridCacheContext.reserveForFastLocalGet(int, AffinityTopologyVersion).
GridDhtFuture<Object>	GridCachePreloader.request(GridCacheContext cctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer)	Requests that preloader sends the request for the key.
GridDhtFuture<Object>	GridCachePreloader.request(GridCacheContext cctx, GridNearAtomicAbstractUpdateRequest req, AffinityTopologyVersion topVer)	Requests that preloader sends the request for the key.
GridDhtFuture<Object>	GridCachePreloaderAdapter.request(GridCacheContext ctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer)	Requests that preloader sends the request for the key.
GridDhtFuture<Object>	GridCachePreloaderAdapter.request(GridCacheContext ctx, GridNearAtomicAbstractUpdateRequest req, AffinityTopologyVersion topVer)	Requests that preloader sends the request for the key.
GridCloseableIterator<CacheDataRow>	IgniteCacheOffheapManager.reservedIterator(int part, AffinityTopologyVersion topVer)
GridCloseableIterator<CacheDataRow>	IgniteCacheOffheapManagerImpl.reservedIterator(int part, AffinityTopologyVersion topVer)
boolean	GridCacheContext.reserveForFastLocalGet(int part, AffinityTopologyVersion topVer)	Checks if local reads are allowed for the given partition and reserves the partition when needed.
IgniteInternalFuture<?>	GridCacheProcessor.startCachesOnLocalJoin(AffinityTopologyVersion exchTopVer, LocalJoinCachesContext locJoinCtx)
Collection<DynamicCacheDescriptor>	GridCacheProcessor.startReceivedCaches(UUID nodeId, AffinityTopologyVersion exchTopVer)	Starts statically configured caches received from remote nodes during exchange.
void	DynamicCacheDescriptor.startTopologyVersion(AffinityTopologyVersion startTopVer)
void	GridCacheMvccCandidate.topologyVersion(AffinityTopologyVersion topVer)
Map<IgniteTxKey,Collection<GridCacheMvccCandidate>>	GridCacheMvccManager.unfinishedLocks(AffinityTopologyVersion topVer)
protected void	GridCacheMapEntry.updatePlatformCache(@Nullable CacheObject val, @Nullable AffinityTopologyVersion ver)	Invokes platform cache update callback, if applicable.
boolean	GridCacheEntryEx.valid(AffinityTopologyVersion topVer)
boolean	GridCacheMapEntry.valid(AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache with parameters of type AffinityTopologyVersion

Constructor	Description
CacheAffinityChangeMessage(AffinityTopologyVersion topVer, Map<Integer,IgniteUuid> cacheDeploymentIds)	Constructor used when message is created after cache rebalance finished.
CacheGroupContext(GridCacheSharedContext<?,?> ctx, int grpId, UUID rcvdFrom, CacheType cacheType, CacheConfiguration<?,?> ccfg, boolean affNode, DataRegion dataRegion, CacheObjectContext cacheObjCtx, FreeList<?> freeList, ReuseList reuseList, AffinityTopologyVersion locStartVer, boolean persistenceEnabled, boolean walEnabled, boolean recoveryMode, CompressionHandler compressHnd)
CacheObjectsReleaseFuture(String type, AffinityTopologyVersion topVer)
CacheObjectsReleaseFuture(String type, AffinityTopologyVersion topVer, @Nullable IgniteReducer<T,R> rdc)
GridCacheContext(GridKernalContext ctx, GridCacheSharedContext sharedCtx, CacheConfiguration cacheCfg, CacheGroupContext grp, CacheType cacheType, AffinityTopologyVersion locStartTopVer, IgniteUuid deploymentId, boolean affNode, boolean updatesAllowed, boolean statisticsEnabled, boolean recoveryMode, GridCacheEventManager evtMgr, CacheStoreManager storeMgr, CacheEvictionManager evictMgr, GridCacheQueryManager<K,V> qryMgr, CacheContinuousQueryManager contQryMgr, CacheDataStructuresManager dataStructuresMgr, GridCacheTtlManager ttlMgr, GridCacheDrManager drMgr, CacheConflictResolutionManager<K,V> rslvrMgr, CachePluginManager pluginMgr, GridCacheAffinityManager affMgr, PlatformCacheManager platformMgr)
GridCacheExplicitLockSpan(AffinityTopologyVersion topVer, GridCacheMvccCandidate cand)
ReaderArguments(UUID reader, long msgId, AffinityTopologyVersion topVer)
StartCacheInfo(CacheConfiguration conf, DynamicCacheDescriptor desc, NearCacheConfiguration reqNearCfg, AffinityTopologyVersion exchTopVer, boolean disabledAfterStart)
StartCacheInfo(CacheConfiguration conf, DynamicCacheDescriptor desc, NearCacheConfiguration reqNearCfg, AffinityTopologyVersion exchTopVer, boolean disabledAfterStart, boolean clientCache)
StartCacheInfo(DynamicCacheDescriptor desc, NearCacheConfiguration reqNearCfg, AffinityTopologyVersion exchTopVer, boolean disabledAfterStart)
StateChangeRequest(ChangeGlobalStateMessage msg, BaselineTopologyHistoryItem bltHistItem, ClusterState prevState, AffinityTopologyVersion topVer)
TopologyVersionAwareJob(String cacheName, AffinityTopologyVersion topVer)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.binary

Methods in org.apache.ignite.internal.processors.cache.binary with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable DiscoCache	MetadataRemoveAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	MetadataRemoveProposedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	MetadataUpdateAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	MetadataUpdateProposedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed

Methods in org.apache.ignite.internal.processors.cache.distributed that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridCacheTtlUpdateRequest.topologyVersion()
AffinityTopologyVersion	GridDistributedTxFinishRequest.topologyVersion()

Methods in org.apache.ignite.internal.processors.cache.distributed with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable GridCacheMvccCandidate	GridDistributedCacheEntry.addLocal(long threadId, GridCacheVersion ver, AffinityTopologyVersion topVer, long timeout, boolean reenter, boolean tx, boolean implicitSingle, boolean read)	Add local candidate.

Constructors in org.apache.ignite.internal.processors.cache.distributed with parameters of type AffinityTopologyVersion

Constructor	Description
GridCacheTtlUpdateRequest(int cacheId, AffinityTopologyVersion topVer, long ttl)
GridDistributedTxFinishRequest(GridCacheVersion xidVer, IgniteUuid futId, @NotNull AffinityTopologyVersion topVer, @Nullable GridCacheVersion commitVer, long threadId, boolean commit, boolean invalidate, boolean sys, byte plc, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int taskNameHash, int txSize, boolean addDepInfo)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.dht

Fields in org.apache.ignite.internal.processors.cache.distributed.dht declared as AffinityTopologyVersion

Modifier and Type	Field	Description
protected AffinityTopologyVersion	CacheDistributedGetFutureAdapter.AbstractMiniFuture.topVer	Topology version on which this future was mapped.

Fields in org.apache.ignite.internal.processors.cache.distributed.dht with type parameters of type AffinityTopologyVersion

Modifier and Type	Field	Description
protected Map<AffinityTopologyVersion,Map<Integer,Set<ClusterNode>>>	CacheDistributedGetFutureAdapter.invalidNodes

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridDhtTopologyFuture.initialVersion()	Returns topology version when exchange started.
AffinityTopologyVersion	GridDhtAffinityAssignmentRequest.topologyVersion()
AffinityTopologyVersion	GridDhtAffinityAssignmentResponse.topologyVersion()
AffinityTopologyVersion	GridDhtLockRequest.topologyVersion()
AffinityTopologyVersion	GridDhtTopologyFuture.topologyVersion()	Gets result topology version of this future.
AffinityTopologyVersion	GridDhtTxPrepareRequest.topologyVersion()
AffinityTopologyVersion	GridDhtUnreservedPartitionException.topologyVersion()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
protected void	CacheDistributedGetFutureAdapter.addNodeAsInvalid(ClusterNode node, int part, AffinityTopologyVersion topVer)
@Nullable IgniteInternalFuture<Boolean>	GridDhtCacheEntry.addReader(UUID nodeId, long msgId, AffinityTopologyVersion topVer)
protected @Nullable IgniteInternalFuture<Boolean>	GridDhtTxLocal.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer)	Adds reader to cached entry.
protected abstract @Nullable IgniteInternalFuture<Boolean>	GridDhtTxLocalAdapter.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer)	Adds reader to cached entry.
GridCacheEntryEx	GridDhtCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
GridDhtCacheEntry	GridDhtCacheAdapter.entryExx(KeyCacheObject key, AffinityTopologyVersion topVer)
GridDhtFuture<Collection<GridCacheEntryInfo>>	GridDhtCacheAdapter.getDhtAsync(UUID reader, long msgId, Map<KeyCacheObject,Boolean> keys, boolean addReaders, boolean readThrough, AffinityTopologyVersion topVer, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean recovery, @Nullable String txLbl)
protected Set<ClusterNode>	CacheDistributedGetFutureAdapter.getInvalidNodes(int part, AffinityTopologyVersion topVer)
void	GridPartitionedGetFuture.init(AffinityTopologyVersion topVer)	Initializes future.
protected abstract void	CacheDistributedGetFutureAdapter.map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)
protected void	GridPartitionedGetFuture.map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)
protected boolean	GridDhtCacheAdapter.needRemap(AffinityTopologyVersion rmtVer)
protected long	GridDhtCacheEntry.nextPartitionCounter(AffinityTopologyVersion topVer, boolean primary, boolean init, @Nullable Long primaryCntr)
GridCacheMapEntry	GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)
protected ClusterTopologyServerNotFoundException	CacheDistributedGetFutureAdapter.serverNotFoundError(int part, AffinityTopologyVersion topVer)
protected boolean	GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer)	Checks whether near cache should be updated.
protected boolean	GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer)	Checks whether near cache should be updated.
@Nullable IgniteBiTuple<GridCacheVersion,CacheObject>	GridDhtCacheEntry.versionedValue(AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type AffinityTopologyVersion

Constructor	Description
AbstractMiniFuture(ClusterNode node, LinkedHashMap<KeyCacheObject,Boolean> keys, AffinityTopologyVersion topVer)
GridDhtAffinityAssignmentRequest(long futId, int grpId, AffinityTopologyVersion topVer, boolean sndPartMap)
GridDhtAffinityAssignmentResponse(long futId, int grpId, @NotNull AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment)
GridDhtAssignmentFetchFuture(GridCacheSharedContext ctx, int grpId, AffinityTopologyVersion topVer, DiscoCache discoCache)
GridDhtCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key)
GridDhtGetFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, Map<KeyCacheObject,Boolean> keys, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, boolean addReaders, @Nullable String txLbl)
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, KeyCacheObject key, boolean addRdr, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, @Nullable String txLbl)
GridDhtLockFuture(GridCacheContext<?,?> cctx, UUID nearNodeId, GridCacheVersion nearLockVer, @NotNull AffinityTopologyVersion topVer, int cnt, boolean read, boolean needReturnVal, long timeout, GridDhtTxLocalAdapter tx, long threadId, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary)
GridDhtLockRequest(int cacheId, UUID nodeId, GridCacheVersion nearXidVer, long threadId, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion lockVer, @NotNull AffinityTopologyVersion topVer, boolean isInTx, boolean isRead, TransactionIsolation isolation, boolean isInvalidate, long timeout, int dhtCnt, int txSize, int taskNameHash, long accessTtl, boolean skipStore, boolean storeUsed, boolean keepBinary, boolean addDepInfo, String txLbl)
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, int miniId, @NotNull AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, boolean commit, boolean invalidate, boolean sys, byte plc, boolean sysInvalidate, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, int taskNameHash, boolean addDepInfo, boolean retVal, boolean waitRemoteTxs, Collection<PartitionUpdateCountersMessage> updCntrs)
GridDhtTxLocal(GridCacheSharedContext cctx, AffinityTopologyVersion topVer, UUID nearNodeId, GridCacheVersion nearXidVer, IgniteUuid nearFutId, int nearMiniId, long nearThreadId, boolean implicit, boolean implicitSingle, boolean sys, boolean explicitLock, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, boolean onePhaseCommit, int txSize, Map<UUID,Collection<UUID>> txNodes, UUID subjId, int taskNameHash, @Nullable String lb, GridNearTxLocal parentTx)
GridDhtTxPrepareRequest(IgniteUuid futId, int miniId, AffinityTopologyVersion topVer, GridDhtTxLocalAdapter tx, long timeout, Collection<IgniteTxEntry> dhtWrites, Collection<IgniteTxEntry> nearWrites, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, boolean onePhaseCommit, int taskNameHash, boolean addDepInfo, boolean storeWriteThrough, boolean retVal, Collection<PartitionUpdateCountersMessage> updCntrs)
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, UUID nodeId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, GridCacheVersion nearXidVer, Map<UUID,Collection<UUID>> txNodes, @Nullable UUID subjId, int taskNameHash, boolean single, boolean storeWriteThrough, @Nullable String txLbl)	This constructor is meant for optimistic transactions.
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, UUID nodeId, GridCacheVersion nearXidVer, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, @Nullable UUID subjId, int taskNameHash, boolean storeWriteThrough, @Nullable String txLbl)	This constructor is meant for pessimistic transactions.
GridDhtUnreservedPartitionException(int part, AffinityTopologyVersion topVer, String msg)
GridPartitionedSingleGetFuture(GridCacheContext cctx, KeyCacheObject key, AffinityTopologyVersion topVer, boolean readThrough, boolean forcePrimary, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, boolean recovery, String txLbl)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Fields in org.apache.ignite.internal.processors.cache.distributed.dht.atomic declared as AffinityTopologyVersion

Modifier and Type	Field	Description
protected AffinityTopologyVersion	GridNearAtomicAbstractUpdateFuture.remapTopVer
protected AffinityTopologyVersion	GridDhtAtomicAbstractUpdateRequest.topVer	Topology version.
protected AffinityTopologyVersion	GridNearAtomicAbstractUpdateFuture.topVer	Current topology version.
protected AffinityTopologyVersion	GridNearAtomicAbstractUpdateRequest.topVer	Topology version.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridDhtAtomicAbstractUpdateRequest.topologyVersion()	Gets topology version or -1 in case of topology version is not required for this message.
AffinityTopologyVersion	GridNearAtomicAbstractUpdateRequest.topologyVersion()	Gets topology version or -1 in case of topology version is not required for this message.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
IgniteInternalFuture<Void>	GridDhtAtomicAbstractUpdateFuture.completeFuture(AffinityTopologyVersion topVer)	Gets future that will be completed when it is safe when update is finished on the given version of topology.
IgniteInternalFuture<Void>	GridNearAtomicAbstractUpdateFuture.completeFuture(AffinityTopologyVersion topVer)	Gets future that will be completed when it is safe when update is finished on the given version of topology.
protected abstract GridDhtAtomicAbstractUpdateRequest	GridDhtAtomicAbstractUpdateFuture.createRequest(UUID nodeId, long futId, GridCacheVersion writeVer, CacheWriteSynchronizationMode syncMode, @NotNull AffinityTopologyVersion topVer, long ttl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer, boolean readRepairRecovery)
protected abstract void	GridNearAtomicAbstractUpdateFuture.map(AffinityTopologyVersion topVer)
protected void	GridNearAtomicSingleUpdateFuture.map(AffinityTopologyVersion topVer)
protected void	GridNearAtomicUpdateFuture.map(AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with parameters of type AffinityTopologyVersion

Constructor	Description
GridDhtAtomicAbstractUpdateRequest(int cacheId, UUID nodeId, long futId, GridCacheVersion writeVer, CacheWriteSynchronizationMode syncMode, @NotNull AffinityTopologyVersion topVer, int taskNameHash, boolean addDepInfo, boolean keepBinary, boolean skipStore, boolean readRepairRecovery)	Constructor.
GridDhtAtomicUpdateRequest(int cacheId, UUID nodeId, long futId, GridCacheVersion writeVer, CacheWriteSynchronizationMode syncMode, @NotNull AffinityTopologyVersion topVer, int taskNameHash, Object[] invokeArgs, boolean addDepInfo, boolean keepBinary, boolean skipStore, boolean forceTransformBackups, boolean readRepairRecovery)	Constructor.
GridNearAtomicAbstractSingleUpdateRequest(int cacheId, UUID nodeId, long futId, @NotNull AffinityTopologyVersion topVer, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, int taskNameHash, byte flags, boolean addDepInfo)	Constructor.
GridNearAtomicAbstractUpdateRequest(int cacheId, UUID nodeId, long futId, @NotNull AffinityTopologyVersion topVer, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, int taskNameHash, byte flags, boolean addDepInfo)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.dht.colocated

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
GridDistributedCacheEntry	GridDhtColocatedCache.entryExx(KeyCacheObject key, AffinityTopologyVersion topVer, boolean allowDetached)	Gets or creates entry for given key and given topology version.
IgniteInternalFuture<Map<K,V>>	GridDhtColocatedCache.loadAsync(@Nullable Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, String taskName, boolean deserializeBinary, boolean recovery, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObj, @Nullable String txLbl)
IgniteInternalFuture<Object>	GridDhtColocatedCache.loadAsync(KeyCacheObject key, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObj, boolean recovery, @Nullable String txLbl)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Fields in org.apache.ignite.internal.processors.cache.distributed.dht.preloader declared as AffinityTopologyVersion

Modifier and Type	Field	Description
protected AffinityTopologyVersion	GridDhtPartitionMap.top	Topology version.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridDhtPartitionsExchangeFuture.initialVersion()	Gets the affinity topology version for which this exchange was created.
AffinityTopologyVersion	GridDhtPartitionsFullMessage.resultTopologyVersion()
AffinityTopologyVersion	FinishPreloadingTask.topologyVersion()
AffinityTopologyVersion	GridDhtForceKeysRequest.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionDemander.RebalanceFuture.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionDemandLegacyMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionDemandMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionExchangeId.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionMap.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionsExchangeFuture.topologyVersion()	Gets result topology version of this future.
AffinityTopologyVersion	GridDhtPartitionsFullMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionSupplyMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPreloaderAssignments.topologyVersion()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	GridDhtPartitionsExchangeFuture.finishMerged(AffinityTopologyVersion resVer, GridDhtPartitionsExchangeFuture exchFut)	Finish merged future to allow GridCachePartitionExchangeManager.ExchangeFutureSet cleanup.
void	GridDhtPreloader.finishPreloading(AffinityTopologyVersion topVer, long rebalanceId)	Finish preloading for given topology version.
boolean	GridDhtPartitionsExchangeFuture.onDone(@Nullable AffinityTopologyVersion res, @Nullable Throwable err)	Callback to notify that future is finished.
void	GridDhtPartitionDemander.RebalanceFuture.ownPartitionsAndFinishFuture(AffinityTopologyVersion topVer, long rebalanceId)
GridDhtFuture<Object>	GridDhtPreloader.request(GridCacheContext cctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer)
GridDhtFuture<Object>	GridDhtPreloader.request(GridCacheContext cctx, GridNearAtomicAbstractUpdateRequest req, AffinityTopologyVersion topVer)	Requests that preloader sends the request for the key.
void	GridDhtPartitionsFullMessage.resultTopologyVersion(AffinityTopologyVersion resTopVer)
void	GridDhtPartitionsFullMessage.topologyVersion(AffinityTopologyVersion topVer)
long	GridDhtPartitionMap.updateSequence(long updateSeq, AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type AffinityTopologyVersion

Constructor	Description
FinishPreloadingTask(SecurityContext secCtx, AffinityTopologyVersion topVer, int grpId, long rebalanceId)
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx, AffinityTopologyVersion topVer, Collection<KeyCacheObject> keys)
GridDhtPartitionExchangeId(UUID nodeId, int evt, AffinityTopologyVersion topVer)
GridDhtPartitionExchangeId(UUID nodeId, DiscoveryEvent discoEvt, AffinityTopologyVersion topVer)
GridDhtPartitionMap(UUID nodeId, long updateSeq, AffinityTopologyVersion top, GridPartitionStateMap m, boolean onlyActive)
GridDhtPartitionsFullMessage(@Nullable GridDhtPartitionExchangeId id, @Nullable GridCacheVersion lastVer, @NotNull AffinityTopologyVersion topVer, @Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers, @Nullable IgniteDhtPartitionsToReloadMap partsToReload)
GridDhtPartitionSupplyMessageV2(long rebalanceId, int grpId, AffinityTopologyVersion topVer, boolean addDepInfo, Throwable err)
GridDhtPreloaderAssignments(GridDhtPartitionExchangeId exchangeId, AffinityTopologyVersion topVer, boolean affinityReassign)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	LatchAckMessage.topVer()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
boolean	ExchangeLatchManager.canSkipJoiningNodes(AffinityTopologyVersion topVer)	Checks that latch manager can use V2 protocol and skip joining nodes from latch participants.
void	ExchangeLatchManager.dropClientLatches(AffinityTopologyVersion topVer)	Drops client latches created by ExchangeLatchManager.getOrCreate(String, AffinityTopologyVersion).
Latch	ExchangeLatchManager.getOrCreate(String id, AffinityTopologyVersion topVer)	Creates new latch with specified id and topVer or returns existing latch.

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch with parameters of type AffinityTopologyVersion

Constructor	Description
LatchAckMessage(String latchId, AffinityTopologyVersion topVer, boolean isFinal)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.dht.topology

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridClientPartitionTopology.lastTopologyChangeVersion()
AffinityTopologyVersion	GridDhtPartitionTopology.lastTopologyChangeVersion()
AffinityTopologyVersion	GridDhtPartitionTopologyImpl.lastTopologyChangeVersion()
AffinityTopologyVersion	GridClientPartitionTopology.readyTopologyVersion()
AffinityTopologyVersion	GridDhtPartitionTopology.readyTopologyVersion()
AffinityTopologyVersion	GridDhtPartitionTopologyImpl.readyTopologyVersion()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	GridClientPartitionTopology.afterStateRestored(AffinityTopologyVersion topVer)	Initializes local data structures after partitions are restored from persistence.
void	GridDhtPartitionTopology.afterStateRestored(AffinityTopologyVersion topVer)	Initializes local data structures after partitions are restored from persistence.
void	GridDhtPartitionTopologyImpl.afterStateRestored(AffinityTopologyVersion topVer)	Initializes local data structures after partitions are restored from persistence.
boolean	GridDhtLocalPartition.backup(AffinityTopologyVersion topVer)
boolean	GridClientPartitionTopology.detectLostPartitions(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture fut)	Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridDhtPartitionTopology.detectLostPartitions(AffinityTopologyVersion resTopVer, GridDhtPartitionsExchangeFuture fut)	Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridDhtPartitionTopologyImpl.detectLostPartitions(AffinityTopologyVersion resTopVer, GridDhtPartitionsExchangeFuture fut)	Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridClientPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
@Nullable GridDhtLocalPartition	GridClientPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
@Nullable GridDhtLocalPartition	GridClientPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create, boolean showRenting)
@Nullable GridDhtLocalPartition	GridDhtPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
@Nullable GridDhtLocalPartition	GridDhtPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create, boolean showRenting)
@Nullable GridDhtLocalPartition	GridDhtPartitionTopologyImpl.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
@Nullable GridDhtLocalPartition	GridDhtPartitionTopologyImpl.localPartition(int p, AffinityTopologyVersion topVer, boolean create, boolean showRenting)
long	GridDhtLocalPartition.nextUpdateCounter(int cacheId, AffinityTopologyVersion topVer, boolean primary, boolean init, @Nullable Long primaryCntr)	Returns new update counter for primary node or passed counter for backup node.
List<ClusterNode>	GridClientPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopologyImpl.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridClientPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopologyImpl.owners(int p, AffinityTopologyVersion topVer)
boolean	GridDhtLocalPartition.primary(AffinityTopologyVersion topVer)
boolean	GridClientPartitionTopology.rebalanceFinished(AffinityTopologyVersion topVer)
boolean	GridDhtPartitionTopology.rebalanceFinished(AffinityTopologyVersion topVer)
boolean	GridDhtPartitionTopologyImpl.rebalanceFinished(AffinityTopologyVersion topVer)
void	GridClientPartitionTopology.resetLostPartitions(AffinityTopologyVersion affVer)	Resets the state of all LOST partitions to OWNING.
void	GridDhtPartitionTopology.resetLostPartitions(AffinityTopologyVersion resTopVer)	Resets the state of all LOST partitions to OWNING.
void	GridDhtPartitionTopologyImpl.resetLostPartitions(AffinityTopologyVersion resTopVer)	Resets the state of all LOST partitions to OWNING.
boolean	GridClientPartitionTopology.update(@Nullable AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap cntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
boolean	GridDhtPartitionTopology.update(@Nullable AffinityTopologyVersion exchangeResVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap cntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
boolean	GridDhtPartitionTopologyImpl.update(@Nullable AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap incomeCntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.topology with parameters of type AffinityTopologyVersion

Constructor	Description
GridDhtPartitionsReservation(AffinityTopologyVersion topVer, GridCacheContext<?,?> cctx, Object appKey)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable AffinityTopologyVersion	GridNearLockResponse.clientRemapVersion()
AffinityTopologyVersion	GridNearGetRequest.topologyVersion()
AffinityTopologyVersion	GridNearGetResponse.topologyVersion()
AffinityTopologyVersion	GridNearLockRequest.topologyVersion()
AffinityTopologyVersion	GridNearSingleGetRequest.topologyVersion()
AffinityTopologyVersion	GridNearSingleGetResponse.topologyVersion()
AffinityTopologyVersion	GridNearTxPrepareRequest.topologyVersion()

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
GridCacheMvccCandidate	GridNearCacheEntry.addLocal(long threadId, GridCacheVersion ver, AffinityTopologyVersion topVer, long timeout, boolean reenter, boolean tx, boolean implicitSingle, boolean read)	Add local candidate.
protected IgniteInternalFuture<Boolean>	GridNearTxLocal.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer)	Adds reader to cached entry.
GridCacheMapEntry	GridNearCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
protected GridCacheEntryEx	GridNearTxLocal.entryEx(GridCacheContext cacheCtx, IgniteTxKey key, AffinityTopologyVersion topVer)	Gets cache entry for given key and topology version.
GridNearCacheEntry	GridNearCacheAdapter.entryExx(KeyCacheObject key, AffinityTopologyVersion topVer)
protected boolean	GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e, GridCacheVersion obsoleteVer, AffinityTopologyVersion topVer)
<K,V> IgniteInternalFuture<Map<K,V>>	GridNearTxLocal.getAllAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, Collection<KeyCacheObject> keys, boolean deserializeBinary, boolean skipVals, boolean keepCacheObjects, boolean skipStore, boolean recovery, ReadRepairStrategy readRepairStrategy, boolean needVer)
void	GridNearGetFuture.init(@Nullable AffinityTopologyVersion topVer)	Initializes future.
void	GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer)
void	GridNearGetResponse.invalidPartitions(Collection<Integer> invalidParts, @NotNull AffinityTopologyVersion topVer)
<K,V,T> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, @Nullable Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map, Object... invokeArgs)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, K key, javax.cache.processor.EntryProcessor<K,V,Object> entryProc, Object... invokeArgs)
protected boolean	GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx e, AffinityTopologyVersion topVer)
boolean	GridNearCacheEntry.loadedValue(@Nullable IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, long ttl, long expireTime, boolean evt, boolean keepBinary, AffinityTopologyVersion topVer)
protected void	GridNearGetFuture.map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)
void	GridNearTxLocal.onRemap(AffinityTopologyVersion topVer, boolean reset)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.putAllAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, Map<? extends K,? extends V> map, boolean retval)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.putAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, K key, V val, boolean retval, CacheEntryPredicate filter)
protected void	GridNearCacheEntry.recordNodeId(UUID primaryNodeId, AffinityTopologyVersion topVer)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.removeAllAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, Collection<? extends K> keys, boolean retval, CacheEntryPredicate filter, boolean singleRmv)
boolean	GridNearCacheEntry.resetFromPrimary(CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, UUID primaryNodeId, AffinityTopologyVersion topVer)	This method should be called only when lock is owned on this entry.
void	GridNearLockRequest.topologyVersion(AffinityTopologyVersion topVer)
void	GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer, @Nullable CacheObject val, long expireTime, long ttl, UUID primaryNodeId, AffinityTopologyVersion topVer)	This method should be called only when lock is owned on this entry.
boolean	GridNearCacheEntry.valid(AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type AffinityTopologyVersion

Constructor	Description
GridNearGetRequest(int cacheId, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion ver, Map<KeyCacheObject,Boolean> keys, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, long createTtl, long accessTtl, boolean addReader, boolean skipVals, boolean addDepInfo, boolean recovery, @Nullable String txLbl)
GridNearLockRequest(int cacheId, @NotNull AffinityTopologyVersion topVer, UUID nodeId, long threadId, IgniteUuid futId, GridCacheVersion lockVer, boolean isInTx, boolean isRead, boolean retVal, TransactionIsolation isolation, boolean isInvalidate, long timeout, int keyCnt, int txSize, boolean syncCommit, int taskNameHash, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary, boolean firstClientReq, boolean nearCache, boolean addDepInfo, @Nullable String txLbl)
GridNearLockResponse(int cacheId, GridCacheVersion lockVer, IgniteUuid futId, int miniId, boolean filterRes, int cnt, Throwable err, AffinityTopologyVersion clientRemapVer, boolean addDepInfo, boolean compatibleRemapVer)
GridNearSingleGetRequest(int cacheId, long futId, KeyCacheObject key, boolean readThrough, @NotNull AffinityTopologyVersion topVer, int taskNameHash, long createTtl, long accessTtl, boolean skipVals, boolean addReader, boolean needVer, boolean addDepInfo, boolean recovery, @Nullable String txLbl)
GridNearSingleGetResponse(int cacheId, long futId, AffinityTopologyVersion topVer, @Nullable Message res, boolean invalidPartitions, boolean addDepInfo)
GridNearTxFinishRequest(IgniteUuid futId, GridCacheVersion xidVer, long threadId, boolean commit, boolean invalidate, boolean sys, byte plc, CacheWriteSynchronizationMode syncMode, boolean explicitLock, boolean storeEnabled, @NotNull AffinityTopologyVersion topVer, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, int taskNameHash, boolean addDepInfo)
GridNearTxPrepareRequest(IgniteUuid futId, AffinityTopologyVersion topVer, GridNearTxLocal tx, long timeout, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, boolean explicitLock, int taskNameHash, boolean firstClientReq, boolean allowWaitTopFut, boolean addDepInfo, boolean recovery)
GridNearTxPrepareResponse(int part, GridCacheVersion xid, IgniteUuid futId, int miniId, GridCacheVersion dhtVer, GridCacheVersion writeVer, GridCacheReturn retVal, Throwable err, AffinityTopologyVersion clientRemapVer, boolean onePhaseCommit, boolean addDepInfo)
GridNearTxRemote(GridCacheSharedContext<?,?> ctx, AffinityTopologyVersion topVer, ClassLoader ldr, UUID nodeId, UUID nearNodeId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, Collection<IgniteTxEntry> writeEntries, int txSize, @Nullable UUID subjId, int taskNameHash, @Nullable String txLbl)	This constructor is meant for optimistic transactions.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.distributed.near.consistency

Methods in org.apache.ignite.internal.processors.cache.distributed.near.consistency with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
protected void	GridNearReadRepairAbstractFuture.remap(AffinityTopologyVersion topVer)
protected abstract GridNearReadRepairAbstractFuture	GridNearReadRepairAbstractFuture.remapFuture(AffinityTopologyVersion topVer)
protected GridNearReadRepairAbstractFuture	GridNearReadRepairCheckOnlyFuture.remapFuture(AffinityTopologyVersion topVer)
protected GridNearReadRepairAbstractFuture	GridNearReadRepairFuture.remapFuture(AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.processors.cache.distributed.near.consistency with parameters of type AffinityTopologyVersion

Constructor	Description
GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer, GridCacheContext<?,?> ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, IgniteInternalTx tx, GridNearReadRepairAbstractFuture remappedFut)	Creates a new instance of GridNearReadRepairAbstractFuture.
GridNearReadRepairCheckOnlyFuture(AffinityTopologyVersion topVer, GridCacheContext<?,?> ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, IgniteInternalTx tx)	Creates a new instance of GridNearReadRepairCheckOnlyFuture.
GridNearReadRepairFuture(AffinityTopologyVersion topVer, GridCacheContext ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, IgniteInternalTx tx)	Creates a new instance of GridNearReadRepairFuture.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.dr

Methods in org.apache.ignite.internal.processors.cache.dr with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	GridCacheDrManager.onExchange(AffinityTopologyVersion topVer, boolean left, boolean activate)	Process partitions exchange event.
void	GridOsCacheDrManager.onExchange(AffinityTopologyVersion topVer, boolean left, boolean activate)	Process partitions exchange event.
void	GridCacheDrManager.replicate(KeyCacheObject key, @Nullable CacheObject val, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType, AffinityTopologyVersion topVer)	Performs replication.
void	GridOsCacheDrManager.replicate(KeyCacheObject key, @Nullable CacheObject val, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType, AffinityTopologyVersion topVer)	Performs replication.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.persistence

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	GridCacheDatabaseSharedManager.onStateRestored(AffinityTopologyVersion topVer)	Called when all partitions have been fully restored and pre-created on node start.
void	IgniteCacheDatabaseSharedManager.onStateRestored(AffinityTopologyVersion topVer)	Called when all partitions have been fully restored and pre-created on node start.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.query

Methods in org.apache.ignite.internal.processors.cache.query that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridCacheQueryManager.queryTopologyVersion()
AffinityTopologyVersion	GridCacheQueryRequest.topologyVersion()	Gets topology version or -1 in case of topology version is not required for this message.
AffinityTopologyVersion	ScanQueryIterator.topVer()

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.query.continuous

Methods in org.apache.ignite.internal.processors.cache.query.continuous with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	CacheContinuousQueryManager.closeBackupUpdateCountersGaps(GridCacheContext cctx, int part, AffinityTopologyVersion topVer, GridLongList gaps)	For cache updates in shared cache group need notify others caches CQ listeners that generated counter should be skipped.
static CacheContinuousQueryEntry	CacheContinuousQueryEntry.createFilteredEntry(int cacheId, int partId, AffinityTopologyVersion topVer, long cntr, long filtered)
void	CacheContinuousQueryListener.flushOnExchangeDone(GridKernalContext ctx, AffinityTopologyVersion topVer)	Flushes backup queue.
void	CacheContinuousQueryManager.flushOnExchangeDone(AffinityTopologyVersion topVer)
void	CacheContinuousQueryManager.onEntryUpdated(Map<UUID,CacheContinuousQueryListener> lsnrCol, KeyCacheObject key, CacheObject newVal, CacheObject oldVal, boolean internal, int partId, boolean primary, boolean preload, long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, AffinityTopologyVersion topVer)
void	CacheContinuousQueryManager.onEntryUpdated(KeyCacheObject key, CacheObject newVal, CacheObject oldVal, boolean internal, int partId, boolean primary, boolean preload, long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, AffinityTopologyVersion topVer)
@Nullable CounterSkipContext	CacheContinuousQueryListener.skipUpdateCounter(GridCacheContext cctx, @Nullable CounterSkipContext skipCtx, int part, long cntr, AffinityTopologyVersion topVer, boolean primary)	For cache updates in shared cache group need notify others caches CQ listeners that generated counter should be skipped.
@Nullable CounterSkipContext	CacheContinuousQueryManager.skipUpdateCounter(@Nullable CounterSkipContext skipCtx, int part, long cntr, AffinityTopologyVersion topVer, boolean primary)
void	CacheContinuousQueryListener.skipUpdateEvent(org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEvent<K,V> evt, AffinityTopologyVersion topVer, boolean primary)
void	CacheContinuousQueryHandler.updateCounters(AffinityTopologyVersion topVer, Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode, Map<Integer,T2<Long,Long>> cntrs)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cache.transactions

Fields in org.apache.ignite.internal.processors.cache.transactions declared as AffinityTopologyVersion

Modifier and Type	Field	Description
protected AffinityTopologyVersion	IgniteTxAdapter.topVer	Topology version.

Methods in org.apache.ignite.internal.processors.cache.transactions that return AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable AffinityTopologyVersion	IgniteTxManager.lockedTopologyVersion(long threadId, IgniteInternalTx ignore)
AffinityTopologyVersion	IgniteInternalTx.topologyVersion()
AffinityTopologyVersion	IgniteInternalTx.topologyVersion(AffinityTopologyVersion topVer)	Attempts to set topology version and returns the current value.
AffinityTopologyVersion	IgniteTxAdapter.topologyVersion()
AffinityTopologyVersion	IgniteTxAdapter.topologyVersion(AffinityTopologyVersion topVer)	Attempts to set topology version and returns the current value.
AffinityTopologyVersion	IgniteInternalTx.topologyVersionSnapshot()
AffinityTopologyVersion	IgniteTxAdapter.topologyVersionSnapshot()

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
protected GridCacheEntryEx	IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx, IgniteTxKey key, AffinityTopologyVersion topVer)	Gets cache entry for given key and topology version.
IgniteInternalFuture<?>	IgniteTxManager.finishAllTxs(IgniteInternalFuture<?> finishLocTxsFut, AffinityTopologyVersion topVer)	Creates a future that will wait for finishing all tx updates on backups after all local transactions are finished.
IgniteInternalFuture<Boolean>	IgniteTxManager.finishLocalTxs(AffinityTopologyVersion topVer)	Creates a future that will wait for all ongoing transactions that maybe affected by topology update to be finished.
boolean	IgniteTxManager.needWaitTransaction(IgniteInternalTx tx, AffinityTopologyVersion topVer)
void	IgniteTxEntry.prepareUnmarshal(GridCacheSharedContext<?,?> ctx, AffinityTopologyVersion topVer, boolean near)	Prepares this entry to unmarshall.
IgniteInternalFuture<Boolean>	IgniteTxManager.recoverLocalTxs(AffinityTopologyVersion topVer, ClusterNode node)	Creates a future that will wait for all transactions with failed primary recovery.
void	IgniteTxManager.rollbackOnTopologyChange(AffinityTopologyVersion topVer)	Rollback transactions blocking partition map exchange.
boolean	IgniteTxManager.setTxTopologyHint(@Nullable AffinityTopologyVersion topVer)
AffinityTopologyVersion	IgniteInternalTx.topologyVersion(AffinityTopologyVersion topVer)	Attempts to set topology version and returns the current value.
AffinityTopologyVersion	IgniteTxAdapter.topologyVersion(AffinityTopologyVersion topVer)	Attempts to set topology version and returns the current value.
protected boolean	IgniteTxAdapter.updateNearCache(GridCacheContext<?,?> cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer)	Checks whether near cache should be updated.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.closure

Methods in org.apache.ignite.internal.processors.closure that return AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable AffinityTopologyVersion	AffinityTask.topologyVersion()

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.cluster

Methods in org.apache.ignite.internal.processors.cluster that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	DiscoveryDataClusterState.transitionTopologyVersion()

Methods in org.apache.ignite.internal.processors.cluster with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable DiscoCache	ChangeGlobalStateFinishMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	ChangeGlobalStateMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
boolean	GridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer, ChangeGlobalStateMessage msg, DiscoCache discoCache)
boolean	IGridClusterStateProcessor.onStateChangeMessage(AffinityTopologyVersion topVer, ChangeGlobalStateMessage msg, DiscoCache discoCache)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.continuous

Methods in org.apache.ignite.internal.processors.continuous with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable DiscoCache	AbstractContinuousMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
void	GridContinuousHandler.updateCounters(AffinityTopologyVersion topVer, Map<UUID,Map<Integer,T2<Long,Long>>> cntrsPerNode, Map<Integer,T2<Long,Long>> cntrs)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.datastreamer

Methods in org.apache.ignite.internal.processors.datastreamer that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	DataStreamerRequest.topologyVersion()

Constructors in org.apache.ignite.internal.processors.datastreamer with parameters of type AffinityTopologyVersion

Constructor

Description

DataStreamerRequest(long reqId, byte[] resTopicBytes, @Nullable String cacheName, byte[] updaterBytes, Collection<DataStreamerEntry> entries, boolean ignoreDepOwnership, boolean skipStore, boolean keepBinary, DeploymentMode depMode, String sampleClsName, String userVer, Map<UUID,IgniteUuid> ldrParticipants, IgniteUuid clsLdrId, boolean forceLocDep, @NotNull AffinityTopologyVersion topVer, int partId)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.job

Constructors in org.apache.ignite.internal.processors.job with parameters of type AffinityTopologyVersion

Constructor	Description
PartitionsReservation(int[] cacheIds, int partId, AffinityTopologyVersion topVer)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.marshaller

Methods in org.apache.ignite.internal.processors.marshaller with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable DiscoCache	MappingAcceptedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
@Nullable DiscoCache	MappingProposedMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.odbc.jdbc

Methods in org.apache.ignite.internal.processors.odbc.jdbc that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	JdbcResponse.affinityVersion()
AffinityTopologyVersion	JdbcConnectionContext.getAffinityTopologyVersionIfChanged()

Constructors in org.apache.ignite.internal.processors.odbc.jdbc with parameters of type AffinityTopologyVersion

Constructor	Description
JdbcResponse(JdbcResult res, @Nullable AffinityTopologyVersion affinityVer)	Constructs successful rest response.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.platform

Methods in org.apache.ignite.internal.processors.platform with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	PlatformContext.updatePlatformCache(int cacheId, byte[] keyBytes, byte[] valBytes, int part, AffinityTopologyVersion ver)	Updates the platform cache cache.
void	PlatformContextImpl.updatePlatformCache(int cacheId, byte[] keyBytes, byte[] valBytes, int part, AffinityTopologyVersion ver)	Updates the platform cache cache.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.platform.callback

Methods in org.apache.ignite.internal.processors.platform.callback with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	PlatformCallbackGateway.onAffinityTopologyVersionChanged(AffinityTopologyVersion version)	Notifies about topology version update.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.platform.client

Methods in org.apache.ignite.internal.processors.platform.client that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	ClientAffinityTopologyVersion.getVersion()

Constructors in org.apache.ignite.internal.processors.platform.client with parameters of type AffinityTopologyVersion

Constructor	Description
ClientAffinityTopologyVersion(AffinityTopologyVersion version, boolean changed)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query that return AffinityTopologyVersion

Modifier and Type	Method	Description
static AffinityTopologyVersion	GridQueryProcessor.getRequestAffinityTopologyVersion()

Methods in org.apache.ignite.internal.processors.query with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
IndexingQueryFilter	GridQueryIndexing.backupFilter(AffinityTopologyVersion topVer, int[] parts)	Returns backup filter.
static void	GridQueryProcessor.setRequestAffinityTopologyVersion(AffinityTopologyVersion ver)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.query.aware

Methods in org.apache.ignite.internal.processors.query.aware with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	IndexRebuildFutureStorage.cancelRebuildIndexesOnExchange(Set<Integer> cacheIds, AffinityTopologyVersion topVer)	Canceling index rebuilding for caches on the exchange.
Set<Integer>	IndexRebuildFutureStorage.prepareRebuildIndexes(Set<Integer> cacheIds, @Nullable AffinityTopologyVersion topVer)	Preparing futures of rebuilding indexes for caches.
boolean	IndexRebuildFutureStorage.rebuildIndexesOnExchange(int cacheId, AffinityTopologyVersion topVer)	Checks that the indexes need to be rebuilt on the exchange.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.query.h2.twostep.messages

Methods in org.apache.ignite.internal.processors.query.h2.twostep.messages that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	GridQueryNextPageResponse.retry()

Methods in org.apache.ignite.internal.processors.query.h2.twostep.messages with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
void	GridQueryNextPageResponse.retry(AffinityTopologyVersion retry)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.query.schema.message

Methods in org.apache.ignite.internal.processors.query.schema.message with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
@Nullable DiscoCache	SchemaAbstractDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.query.stat

Methods in org.apache.ignite.internal.processors.query.stat that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	IgniteStatisticsRepository.VersionedStatistics.topologyVersion()
AffinityTopologyVersion	LocalStatisticsGatheringContext.topologyVersion()
AffinityTopologyVersion	ObjectStatisticsEvent.topologyVersion()	Get affinity topology version.

Methods in org.apache.ignite.internal.processors.query.stat with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
ObjectStatisticsImpl	IgniteStatisticsRepository.aggregatedLocalStatistics(Collection<ObjectPartitionStatisticsImpl> stats, StatisticsObjectConfiguration cfg, AffinityTopologyVersion topVer)	Scan local partitioned statistic and aggregate local statistic for specified statistic object.
ObjectStatisticsImpl	IgniteStatisticsManagerImpl.getLocalStatistics(StatisticsKey key, AffinityTopologyVersion topVer)	Get local statitsics with specified topology version if exists.
ObjectStatisticsImpl	IgniteStatisticsRepository.getLocalStatistics(StatisticsKey key, AffinityTopologyVersion topVer)	Get local statistics.
void	IgniteGlobalStatisticsManager.onLocalStatisticsAggregated(StatisticsKey key, ObjectStatisticsImpl statistics, AffinityTopologyVersion topVer)	After collecting local statistics - check if there are some pending request for it and send responces.
void	IgniteStatisticsRepository.saveLocalStatistics(StatisticsKey key, ObjectStatisticsImpl statistics, AffinityTopologyVersion topVer)	Save local object statistics.

Constructors in org.apache.ignite.internal.processors.query.stat with parameters of type AffinityTopologyVersion

Constructor	Description
LocalStatisticsGatheringContext(boolean forceRecollect, GridQueryTypeDescriptor tbl, GridCacheContextInfo<?,?> cctxInfo, StatisticsObjectConfiguration cfg, Set<Integer> remainingParts, AffinityTopologyVersion topVer)	Constructor.
ObjectStatisticsEvent(StatisticsKey key, ObjectStatisticsImpl statistics, AffinityTopologyVersion topVer)	Constructor.
VersionedStatistics(AffinityTopologyVersion topVer, ObjectStatisticsImpl statistics)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.query.stat.messages

Methods in org.apache.ignite.internal.processors.query.stat.messages that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	StatisticsRequest.topVer()

Constructors in org.apache.ignite.internal.processors.query.stat.messages with parameters of type AffinityTopologyVersion

Constructor	Description
StatisticsRequest(UUID reqId, StatisticsKeyMessage key, StatisticsType type, AffinityTopologyVersion topVer, Map<String,Long> versions)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.processors.service

Methods in org.apache.ignite.internal.processors.service that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	ServiceDeploymentManager.readyTopologyVersion()
AffinityTopologyVersion	ServiceDeploymentProcessId.topologyVersion()

Methods in org.apache.ignite.internal.processors.service with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
DiscoCache	ServiceChangeBatchRequest.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	ServiceClusterDeploymentResultBatch.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.sql.optimizer.affinity

Methods in org.apache.ignite.internal.sql.optimizer.affinity that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	PartitionResult.topologyVersion()

Constructors in org.apache.ignite.internal.sql.optimizer.affinity with parameters of type AffinityTopologyVersion

Constructor	Description
PartitionResult(PartitionNode tree, AffinityTopologyVersion topVer, String cacheName, int partsCnt)	Constructor.
PartitionResult(PartitionNode tree, PartitionTableAffinityDescriptor aff, AffinityTopologyVersion topVer)	Constructor.

Uses of AffinityTopologyVersion in org.apache.ignite.internal.util.distributed

Methods in org.apache.ignite.internal.util.distributed with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
DiscoCache	FullMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
DiscoCache	InitMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.plugin.extensions.communication

Methods in org.apache.ignite.plugin.extensions.communication that return AffinityTopologyVersion

Modifier and Type	Method	Description
AffinityTopologyVersion	MessageReader.readAffinityTopologyVersion(String name)	Reads AffinityTopologyVersion.

Methods in org.apache.ignite.plugin.extensions.communication with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
boolean	MessageWriter.writeAffinityTopologyVersion(String name, AffinityTopologyVersion val)	Writes AffinityTopologyVersion.

Uses of AffinityTopologyVersion in org.apache.ignite.spi.communication.tcp.internal

Methods in org.apache.ignite.spi.communication.tcp.internal with parameters of type AffinityTopologyVersion

Modifier and Type	Method	Description
DiscoCache	TcpConnectionRequestDiscoveryMessage.createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.

Uses of AffinityTopologyVersion in org.apache.ignite.spi.indexing

Constructors in org.apache.ignite.spi.indexing with parameters of type AffinityTopologyVersion

Constructor	Description
IndexingQueryCacheFilter(GridCacheAffinityManager aff, Set<Integer> parts, AffinityTopologyVersion topVer, ClusterNode locNode)	Constructor.
IndexingQueryFilterImpl(GridKernalContext ctx, @Nullable AffinityTopologyVersion topVer, @org.jetbrains.annotations.Nullable int[] partsArr)	Constructor.
IndexingQueryFilterImpl(GridKernalContext ctx, @Nullable AffinityTopologyVersion topVer, @org.jetbrains.annotations.Nullable int[] partsArr, boolean treatReplicatedAsPartitioned)	Constructor.