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.events
org.apache.ignite.internal.managers.discovery	TODO.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.cache
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.near
org.apache.ignite.internal.processors.cache.dr
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cache.version
org.apache.ignite.internal.processors.datastreamer	Data streamer processor.
org.apache.ignite.internal.processors.query
org.apache.ignite.internal.processors.query.h2.twostep.messages

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

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

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

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

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

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

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

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

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 and Description
AffinityTopologyVersion	GridDiscoveryManager.topologyVersionEx()

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

Modifier and Type	Method and Description
Collection<ClusterNode>	GridDiscoveryManager.aliveCacheNodes(String cacheName, AffinityTopologyVersion topVer) Gets cache nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.aliveNodesWithCaches(AffinityTopologyVersion topVer) Gets alive nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.aliveRemoteCacheNodes(String cacheName, AffinityTopologyVersion topVer) Gets cache remote nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.aliveRemoteServerNodesWithCaches(AffinityTopologyVersion topVer) Gets alive remote server nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.aliveServerNodesWithCaches(AffinityTopologyVersion topVer) Gets alive server nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.cacheAffinityNodes(String cacheName, AffinityTopologyVersion topVer) Gets cache nodes for cache with given name that participate in affinity calculation.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(AffinityTopologyVersion topVer) Gets all nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(String cacheName, AffinityTopologyVersion topVer) Gets cache nodes for cache with given name.
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.DiscoCache	GridDiscoveryManager.discoCache(AffinityTopologyVersion topVer) Gets discovery collection cache from SPI safely guarding against "floating" collections.
boolean	GridDiscoveryManager.hasNearCache(String cacheName, AffinityTopologyVersion topVer) Checks if cache with given name has at least one node with near cache enabled.
Collection<ClusterNode>	GridDiscoveryManager.remoteCacheNodes(AffinityTopologyVersion topVer) Gets cache remote nodes for cache with given name.
Collection<ClusterNode>	GridDiscoveryManager.remoteCacheNodes(String cacheName, AffinityTopologyVersion topVer) Gets cache remote nodes for cache with given name.

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 and Description
static AffinityTopologyVersion	AffinityTopologyVersion.NONE
static AffinityTopologyVersion	AffinityTopologyVersion.ZERO

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

Modifier and Type	Method and Description
AffinityTopologyVersion	GridAffinityFunctionContextImpl.currentTopologyVersion() Gets current topology version number.
AffinityTopologyVersion	GridAffinityAssignmentCache.lastVersion()

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

Modifier and Type	Method and Description
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 and Description
List<List<ClusterNode>>	GridAffinityAssignmentCache.assignments(AffinityTopologyVersion topVer)
Set<Integer>	GridAffinityAssignmentCache.backupPartitions(UUID nodeId, AffinityTopologyVersion topVer) Get backup partitions for specified node ID.
List<List<ClusterNode>>	GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer, DiscoveryEvent discoEvt) Calculates affinity cache for given topology version.
void	GridAffinityAssignmentCache.cleanUpCache(AffinityTopologyVersion topVer) Clean up outdated cache items.
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)
void	GridAffinityAssignmentCache.initialize(AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment) Initializes affinity with given topology version and assignment.
<K> 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.
List<ClusterNode>	GridAffinityAssignmentCache.nodes(int part, AffinityTopologyVersion topVer) Gets affinity nodes for specified partition.
Set<Integer>	GridAffinityAssignmentCache.primaryPartitions(UUID nodeId, AffinityTopologyVersion topVer) Get primary partitions for specified node ID.
IgniteInternalFuture<AffinityTopologyVersion>	GridAffinityAssignmentCache.readyFuture(AffinityTopologyVersion topVer) Gets future that will be completed after topology with version topVer is calculated.

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

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

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 and Description
protected AffinityTopologyVersion	GridCacheAdapter.TopologyVersionAwareJob.topVer Affinity topology version.

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

Modifier and Type	Method and Description
AffinityTopologyVersion	GridCacheAffinityManager.affinityTopologyVersion()
AffinityTopologyVersion	GridCacheMvccManager.lastExplicitLockTopologyVersion(long threadId)
AffinityTopologyVersion	GridCachePartitionExchangeManager.readyAffinityVersion()
AffinityTopologyVersion	GridCacheContext.startTopologyVersion()
AffinityTopologyVersion	GridCacheMessage.topologyVersion() Gets topology version or -1 in case of topology version is not required for this message.
AffinityTopologyVersion	GridCacheEvictionRequest.topologyVersion()
AffinityTopologyVersion	GridCacheMvccCandidate.topologyVersion()
AffinityTopologyVersion	CachePartialUpdateCheckedException.topologyVersion()
AffinityTopologyVersion	GridCachePartitionExchangeManager.topologyVersion() Gets topology version of last partition exchange, it is possible that last partition exchange is not completed yet.
AffinityTopologyVersion	GridCacheExplicitLockSpan.topologyVersion() Gets actual topology snapshot for thread lock span.

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

Modifier and Type	Method and Description
IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuture(AffinityTopologyVersion topVer) Gets affinity ready future, a future that will be completed after affinity with given topology version is calculated.
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.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 and Description
void	CachePartialUpdateCheckedException.add(Collection<?> failedKeys, Throwable err, AffinityTopologyVersion topVer)
boolean	GridCacheExplicitLockSpan.addCandidate(AffinityTopologyVersion topVer, GridCacheMvccCandidate cand) Adds candidate to a lock span.
void	GridCacheMvccManager.addExplicitLock(long threadId, GridCacheMvccCandidate cand, AffinityTopologyVersion topVer) Adds candidate to the list of near local candidates.
static Collection<ClusterNode>	GridCacheUtils.affinityNodes(GridCacheContext ctx, AffinityTopologyVersion topOrder) Gets DHT affinity nodes.
IgniteInternalFuture<?>	GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion ver)
IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuture(AffinityTopologyVersion topVer) Gets affinity ready future, a future that will be completed after affinity with given topology version is calculated.
IgniteInternalFuture<AffinityTopologyVersion>	GridCacheAffinityManager.affinityReadyFuturex(AffinityTopologyVersion topVer) Gets affinity ready future that will be completed after affinity with given topology version is calculated.
static Collection<ClusterNode>	GridCacheUtils.aliveRemoteServerNodesWithCaches(GridCacheSharedContext ctx, AffinityTopologyVersion topOrder) Gets alive remote nodes with at least one cache configured.
static Collection<ClusterNode>	GridCacheUtils.allNodes(GridCacheContext ctx, AffinityTopologyVersion topOrder) Gets all nodes on which cache with the same name is started.
static Collection<ClusterNode>	GridCacheUtils.allNodes(GridCacheSharedContext ctx, AffinityTopologyVersion topOrder) Gets all nodes with at least one cache configured.
List<List<ClusterNode>>	GridCacheAffinityManager.assignments(AffinityTopologyVersion topVer)
Set<Integer>	GridCacheAffinityManager.backupPartitions(UUID nodeId, AffinityTopologyVersion topVer)
Collection<ClusterNode>	GridCacheAffinityManager.backups(int part, AffinityTopologyVersion topVer)
Collection<ClusterNode>	GridCacheAffinityManager.backups(Object key, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.belongs(ClusterNode node, int part, AffinityTopologyVersion topVer)
List<List<ClusterNode>>	GridCacheAffinityManager.calculateAffinity(AffinityTopologyVersion topVer, DiscoveryEvent discoEvt) Calculates affinity cache for given topology version.
void	GridCacheAffinityManager.cleanUpCache(AffinityTopologyVersion topVer) Clean up outdated cache items.
void	GridCacheAffinityManager.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).
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.
GridCacheMapEntry	GridCacheMapEntryFactory.create(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)
boolean	GridCacheContext.dhtMap(UUID nearNodeId, AffinityTopologyVersion topVer, GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
GridCacheEntryEx	GridCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
protected GridCacheEntryEx	GridCacheAdapter.entryExSafe(KeyCacheObject key, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishAtomicUpdates(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, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishLocks(AffinityTopologyVersion topVer)
void	GridCacheAffinityManager.initializeAffinity(AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment) Initializes affinity for joined node.
boolean	GridCacheEntryEx.initialValue(CacheObject val, GridCacheVersion ver, long ttl, long expireTime, boolean preload, AffinityTopologyVersion topVer, GridDrType drType) 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) Sets new value if current version is 0
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateAtomicResult	GridCacheEntryEx.innerUpdate(GridCacheVersion ver, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object val, Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean checkVer, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long conflictTtl, long conflictExpireTime, GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, UUID subjId, String taskName)
GridCacheUpdateAtomicResult	GridCacheMapEntry.innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean verCheck, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long explicitTtl, long explicitExpireTime, GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, UUID subjId, String taskName)
boolean	GridCacheAffinityManager.localNode(int part, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.localNode(Object key, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheSharedContext.nextAffinityReadyFuture(AffinityTopologyVersion curVer) Gets ready future for the next affinity topology version (used in cases when a node leaves grid).
List<ClusterNode>	GridCacheAffinityManager.nodes(int part, AffinityTopologyVersion topVer)
List<ClusterNode>	GridCacheAffinityManager.nodes(Object key, AffinityTopologyVersion topVer)
int	GridCacheSwapManager.offheapEntriesCount(boolean primary, boolean backup, AffinityTopologyVersion topVer)
<K,V> Iterator<javax.cache.Cache.Entry<K,V>>	GridCacheSwapManager.offheapIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
Iterator<KeyCacheObject>	GridCacheSwapManager.offHeapKeyIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
static ClusterNode	GridCacheUtils.oldestAliveCacheServerNode(GridCacheSharedContext ctx, AffinityTopologyVersion topVer) Gets oldest alive server node with at least one cache configured for specified topology version.
void	GridCacheProcessor.onExchangeDone(AffinityTopologyVersion topVer, Collection<DynamicCacheChangeRequest> reqs, Throwable err) Callback invoked when first exchange future for dynamic cache is completed.
IgniteInternalFuture<?>	GridCacheSharedContext.partitionReleaseFuture(AffinityTopologyVersion topVer) Waits for partition locks and transactions release.
CacheObject	GridCacheEntryEx.peek(boolean heap, boolean offheap, boolean swap, AffinityTopologyVersion topVer, IgniteCacheExpiryPolicy plc) Peeks into entry without loading value or updating statistics.
CacheObject	GridCacheMapEntry.peek(boolean heap, boolean offheap, boolean swap, AffinityTopologyVersion topVer, IgniteCacheExpiryPolicy expiryPlc) Peeks into entry without loading value or updating statistics.
IgniteInternalFuture<Object>	GridCacheSharedContext.preloadersStartFuture(AffinityTopologyVersion topVer)
void	GridCacheProcessor.prepareCachesStart(Collection<DynamicCacheChangeRequest> reqs, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primary(ClusterNode n, int part, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primary(ClusterNode n, Object key, AffinityTopologyVersion topVer)
ClusterNode	GridCacheAffinityManager.primary(int part, AffinityTopologyVersion topVer)
ClusterNode	GridCacheAffinityManager.primary(Object key, AffinityTopologyVersion topVer)
Set<Integer>	GridCacheAffinityManager.primaryPartitions(UUID nodeId, AffinityTopologyVersion topVer)
GridCacheMapEntry	GridCacheConcurrentMap.putEntry(AffinityTopologyVersion topVer, KeyCacheObject key, CacheObject val)
GridTriple<GridCacheMapEntry>	GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer, KeyCacheObject key, CacheObject val, boolean create)
protected void	GridCacheMapEntry.recordNodeId(UUID nodeId, AffinityTopologyVersion topVer)
static Collection<ClusterNode>	GridCacheUtils.remoteNodes(GridCacheSharedContext ctx, AffinityTopologyVersion topVer) Gets remote nodes with at least one cache configured.
Collection<ClusterNode>	GridCacheAffinityManager.remoteNodes(Iterable keys, AffinityTopologyVersion topVer)
void	GridCacheMvccManager.removeExplicitNodeLocks(UUID leftNodeId, AffinityTopologyVersion topVer)
IgniteInternalFuture<Object>	GridCachePreloaderAdapter.request(Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer) Requests that preloader sends the request for the key.
IgniteInternalFuture<Object>	GridCachePreloader.request(Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer) Requests that preloader sends the request for the key.
void	GridCacheContext.startTopologyVersion(AffinityTopologyVersion startTopVer)
int	GridCacheSwapManager.swapEntriesCount(boolean primary, boolean backup, AffinityTopologyVersion topVer)
<K,V> Iterator<javax.cache.Cache.Entry<K,V>>	GridCacheSwapManager.swapIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
Iterator<KeyCacheObject>	GridCacheSwapManager.swapKeyIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer)
void	GridCacheMvccCandidate.topologyVersion(AffinityTopologyVersion topVer)
void	GridCacheEvictionManager.touch(GridCacheEntryEx e, AffinityTopologyVersion topVer)
Map<IgniteTxKey,Collection<GridCacheMvccCandidate>>	GridCacheMvccManager.unfinishedLocks(AffinityTopologyVersion topVer)
boolean	GridCacheEntryEx.valid(AffinityTopologyVersion topVer)
boolean	GridCacheMapEntry.valid(AffinityTopologyVersion topVer)

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

Constructor and Description
GridCacheAdapter.TopologyVersionAwareJob(String cacheName, AffinityTopologyVersion topVer)
GridCacheExplicitLockSpan(AffinityTopologyVersion topVer, GridCacheMvccCandidate cand)

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 and Description
AffinityTopologyVersion	GridCacheTtlUpdateRequest.topologyVersion()

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

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

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

Constructor and Description
GridCacheTtlUpdateRequest(int cacheId, AffinityTopologyVersion topVer, long ttl)
GridFutureRemapTimeoutObject(GridFutureAdapter<?> fut, long timeout, AffinityTopologyVersion topVer, IgniteCheckedException e)

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

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

Modifier and Type	Method and Description
AffinityTopologyVersion	GridDhtCacheAdapter.beginMultiUpdate() Starts multi-update lock.
AffinityTopologyVersion	GridDhtLockRequest.topologyVersion()
AffinityTopologyVersion	GridDhtTopologyFuture.topologyVersion() Gets topology version of this future.
AffinityTopologyVersion	GridDhtAffinityAssignmentRequest.topologyVersion()
AffinityTopologyVersion	GridClientPartitionTopology.topologyVersion() Topology version.
AffinityTopologyVersion	GridDhtUnreservedPartitionException.topologyVersion()
AffinityTopologyVersion	GridDhtAffinityAssignmentResponse.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionTopology.topologyVersion() Topology version.
AffinityTopologyVersion	GridDhtTxPrepareRequest.topologyVersion()
AffinityTopologyVersion	GridDhtTxFinishRequest.topologyVersion()

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

Modifier and Type	Method and Description
GridCacheMvccCandidate	GridDhtCacheEntry.addDhtLocal(UUID nearNodeId, GridCacheVersion nearVer, AffinityTopologyVersion topVer, long threadId, GridCacheVersion ver, long timeout, boolean reenter, boolean tx, boolean implicitSingle) Add local candidate.
protected abstract IgniteInternalFuture<Boolean>	GridDhtTxLocalAdapter.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer) Adds reader to cached entry.
protected IgniteInternalFuture<Boolean>	GridDhtTxLocal.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer) Adds reader to cached entry.
IgniteInternalFuture<Boolean>	GridDhtCacheEntry.addReader(UUID nodeId, long msgId, AffinityTopologyVersion topVer)
GridCacheEntryEx	GridDhtCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
GridDhtCacheEntry	GridDhtCacheAdapter.entryExx(KeyCacheObject key, AffinityTopologyVersion topVer)
GridCacheEntryEx	GridDhtCacheAdapter.entryExx(KeyCacheObject key, AffinityTopologyVersion topVer, boolean allowDetached, boolean touch) Gets or creates entry for given key.
GridDhtFuture<Collection<GridCacheEntryInfo>>	GridDhtCacheAdapter.getDhtAsync(UUID reader, long msgId, LinkedHashMap<KeyCacheObject,Boolean> keys, boolean readThrough, boolean reload, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiry, boolean skipVals)
GridDhtLocalPartition	GridClientPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
GridDhtLocalPartition	GridDhtPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
IgniteInternalFuture<?>	GridDhtCacheAdapter.multiUpdateFinishFuture(AffinityTopologyVersion topVer) Creates multi update finish future.
protected boolean	GridDhtCacheAdapter.needRemap(AffinityTopologyVersion expVer, AffinityTopologyVersion curVer)
Collection<ClusterNode>	GridClientPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
Collection<ClusterNode>	GridDhtPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
GridDhtLocalPartition	GridClientPartitionTopology.onAdded(AffinityTopologyVersion topVer, GridDhtCacheEntry e)
GridDhtLocalPartition	GridDhtPartitionTopology.onAdded(AffinityTopologyVersion topVer, GridDhtCacheEntry e)
List<ClusterNode>	GridClientPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
boolean	GridDhtLocalPartition.primary(AffinityTopologyVersion topVer)
GridCacheMapEntry	GridNoStorageCacheMap.putEntry(AffinityTopologyVersion topVer, KeyCacheObject key, CacheObject val)
GridTriple<GridCacheMapEntry>	GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer, KeyCacheObject key, CacheObject val, boolean create)
protected boolean	GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer) Checks whether near cache should be updated.
protected boolean	GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer) Checks whether near cache should be updated.
IgniteBiTuple<GridCacheVersion,CacheObject>	GridDhtCacheEntry.versionedValue(AffinityTopologyVersion topVer)

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

Constructor and Description
GridDhtAffinityAssignmentRequest(int cacheId, AffinityTopologyVersion topVer)
GridDhtAffinityAssignmentResponse(int cacheId, AffinityTopologyVersion topVer, List<List<ClusterNode>> affAssignment)
GridDhtAssignmentFetchFuture(GridCacheContext ctx, AffinityTopologyVersion topVer, Collection<ClusterNode> availableNodes)
GridDhtCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)
GridDhtGetFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, LinkedHashMap<KeyCacheObject,Boolean> keys, boolean readThrough, boolean reload, IgniteTxLocalEx tx, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals)
GridDhtLockFuture(GridCacheContext<?,?> cctx, UUID nearNodeId, GridCacheVersion nearLockVer, AffinityTopologyVersion topVer, int cnt, boolean read, boolean needReturnVal, long timeout, GridDhtTxLocalAdapter tx, long threadId, long accessTtl, CacheEntryPredicate[] filter, boolean skipStore)
GridDhtLockRequest(int cacheId, UUID nodeId, GridCacheVersion nearXidVer, long threadId, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion lockVer, AffinityTopologyVersion topVer, boolean isInTx, boolean isRead, TransactionIsolation isolation, boolean isInvalidate, long timeout, int dhtCnt, int nearCnt, int txSize, UUID subjId, int taskNameHash, long accessTtl, boolean skipStore)
GridDhtOffHeapCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)
GridDhtPartitionsReservation(AffinityTopologyVersion topVer, GridCacheContext<?,?> cctx, Object appKey)
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, IgniteUuid miniId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, TransactionIsolation isolation, boolean commit, boolean invalidate, boolean sys, byte plc, boolean sysInvalidate, boolean syncCommit, boolean syncRollback, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, UUID subjId, int taskNameHash)
GridDhtTxPrepareRequest(IgniteUuid futId, IgniteUuid miniId, AffinityTopologyVersion topVer, GridDhtTxLocalAdapter tx, Collection<IgniteTxEntry> dhtWrites, Collection<IgniteTxEntry> nearWrites, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, boolean onePhaseCommit, UUID subjId, int taskNameHash)
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, GridCacheVersion nearXidVer, long rmtThreadId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, UUID subjId, int taskNameHash) This constructor is meant for pessimistic transactions.
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, long rmtThreadId, 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, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.
GridDhtUnreservedPartitionException(int part, AffinityTopologyVersion topVer, String msg)
GridPartitionedGetFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer, boolean readThrough, boolean reload, boolean forcePrimary, UUID subjId, String taskName, boolean deserializePortable, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap)

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

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

Modifier and Type	Method and Description
AffinityTopologyVersion	GridDhtAtomicUpdateRequest.topologyVersion()
AffinityTopologyVersion	GridNearAtomicUpdateRequest.topologyVersion()

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

Modifier and Type	Method and Description
IgniteInternalFuture<Void>	GridDhtAtomicUpdateFuture.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>	GridNearAtomicUpdateFuture.completeFuture(AffinityTopologyVersion topVer) Gets future that will be completed when it is safe when update is finished on the given version of topology.

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

Constructor and Description
GridDhtAtomicCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)
GridDhtAtomicOffHeapCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)
GridDhtAtomicUpdateRequest(int cacheId, UUID nodeId, GridCacheVersion futVer, GridCacheVersion writeVer, CacheWriteSynchronizationMode syncMode, AffinityTopologyVersion topVer, boolean forceTransformBackups, UUID subjId, int taskNameHash, Object[] invokeArgs) Constructor.
GridNearAtomicUpdateRequest(int cacheId, UUID nodeId, GridCacheVersion futVer, boolean fastMap, GridCacheVersion updateVer, AffinityTopologyVersion topVer, boolean topLocked, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, boolean retval, javax.cache.expiry.ExpiryPolicy expiryPlc, Object[] invokeArgs, CacheEntryPredicate[] filter, UUID subjId, int taskNameHash, boolean skipStore, boolean clientReq) 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 and Description
protected GridCacheEntryEx	GridDhtColocatedCache.entryExSafe(KeyCacheObject key, AffinityTopologyVersion topVer)
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(Collection<KeyCacheObject> keys, boolean readThrough, boolean reload, boolean forcePrimary, AffinityTopologyVersion topVer, UUID subjId, String taskName, boolean deserializePortable, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap)

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

Constructor and Description
GridDhtColocatedCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)
GridDhtColocatedOffHeapCacheEntry(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)

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

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

Modifier and Type	Method and Description
AffinityTopologyVersion	GridDhtPartitionsExchangeFuture.topologyVersion() Gets topology version of this future.
AffinityTopologyVersion	GridDhtForceKeysRequest.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionDemandMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionsFullMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionExchangeId.topologyVersion()

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

Modifier and Type	Method and Description
void	GridDhtPreloader.addDhtAssignmentFetchFuture(AffinityTopologyVersion topVer, GridDhtAssignmentFetchFuture fut)
boolean	GridDhtPartitionsExchangeFuture.isCacheAdded(int cacheId, AffinityTopologyVersion topVer)
boolean	GridDhtPartitionsExchangeFuture.onDone(AffinityTopologyVersion res, Throwable err) Callback to notify that future is finished.
void	GridDhtPreloader.removeDhtAssignmentFetchFuture(AffinityTopologyVersion topVer, GridDhtAssignmentFetchFuture fut)
GridDhtFuture<Object>	GridDhtPreloader.request(Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer)
void	GridDhtPartitionsFullMessage.topologyVersion(AffinityTopologyVersion topVer)

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

Constructor and Description
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx, AffinityTopologyVersion topVer, Collection<KeyCacheObject> keys, GridDhtPreloader preloader)
GridDhtPartitionExchangeId(UUID nodeId, int evt, AffinityTopologyVersion topVer)
GridDhtPartitionsFullMessage(GridDhtPartitionExchangeId id, GridCacheVersion lastVer, AffinityTopologyVersion topVer)
GridDhtPreloaderAssignments(GridDhtPartitionsExchangeFuture exchFut, AffinityTopologyVersion topVer)

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 and Description
AffinityTopologyVersion	GridNearLockResponse.clientRemapVersion()
AffinityTopologyVersion	GridNearTxPrepareResponse.clientRemapVersion()
AffinityTopologyVersion	GridNearLockRequest.topologyVersion()
AffinityTopologyVersion	GridNearTxPrepareRequest.topologyVersion()
AffinityTopologyVersion	GridNearTxFinishRequest.topologyVersion()
AffinityTopologyVersion	GridNearGetResponse.topologyVersion()
AffinityTopologyVersion	GridNearGetRequest.topologyVersion()

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

Modifier and Type	Method and Description
GridCacheMvccCandidate	GridNearCacheEntry.addLocal(long threadId, GridCacheVersion ver, AffinityTopologyVersion topVer, long timeout, boolean reenter, boolean tx, boolean implicitSingle) Add local candidate.
GridCacheMvccCandidate	GridNearCacheEntry.addNearLocal(UUID dhtNodeId, long threadId, GridCacheVersion ver, AffinityTopologyVersion topVer, long timeout, boolean reenter, boolean tx, boolean implicitSingle) Add near local candidate.
protected IgniteInternalFuture<Boolean>	GridNearTxLocal.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer) Adds reader to cached entry.
protected GridCacheEntryEx	GridNearTxLocal.entryEx(GridCacheContext cacheCtx, IgniteTxKey key, AffinityTopologyVersion topVer) Gets cache entry for given key and topology version.
GridCacheEntryEx	GridNearCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
GridNearCacheEntry	GridNearCacheAdapter.entryExx(KeyCacheObject key, AffinityTopologyVersion topVer)
protected boolean	GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e, GridCacheVersion obsoleteVer, AffinityTopologyVersion topVer)
boolean	GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer)
void	GridNearGetResponse.invalidPartitions(Collection<Integer> invalidParts, AffinityTopologyVersion topVer)
protected boolean	GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx e, AffinityTopologyVersion topVer)
boolean	GridNearCacheEntry.loadedValue(IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, GridCacheVersion expVer, long ttl, long expireTime, boolean evt, AffinityTopologyVersion topVer, UUID subjId)
void	GridNearTxLocal.onRemap(AffinityTopologyVersion topVer)
protected void	GridNearCacheEntry.recordNodeId(UUID primaryNodeId, AffinityTopologyVersion topVer)
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	GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer, 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 and Description
GridNearGetRequest(int cacheId, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion ver, LinkedHashMap<KeyCacheObject,Boolean> keys, boolean readThrough, boolean reload, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, long accessTtl, boolean skipVals)
GridNearLockRequest(int cacheId, AffinityTopologyVersion topVer, UUID nodeId, long threadId, IgniteUuid futId, GridCacheVersion lockVer, boolean isInTx, boolean implicitTx, boolean implicitSingleTx, boolean isRead, boolean retVal, TransactionIsolation isolation, boolean isInvalidate, long timeout, int keyCnt, int txSize, boolean syncCommit, UUID subjId, int taskNameHash, long accessTtl, boolean skipStore, boolean firstClientReq)
GridNearLockResponse(int cacheId, GridCacheVersion lockVer, IgniteUuid futId, IgniteUuid miniId, boolean filterRes, int cnt, Throwable err, AffinityTopologyVersion clientRemapVer)
GridNearTxFinishRequest(IgniteUuid futId, GridCacheVersion xidVer, long threadId, boolean commit, boolean invalidate, boolean sys, byte plc, boolean syncCommit, boolean syncRollback, boolean explicitLock, boolean storeEnabled, AffinityTopologyVersion topVer, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, UUID subjId, int taskNameHash)
GridNearTxPrepareRequest(IgniteUuid futId, AffinityTopologyVersion topVer, IgniteInternalTx tx, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, boolean explicitLock, UUID subjId, int taskNameHash, boolean firstClientReq)
GridNearTxPrepareResponse(GridCacheVersion xid, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion dhtVer, GridCacheVersion writeVer, GridCacheReturn retVal, Throwable err, AffinityTopologyVersion clientRemapVer)

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 and Description
void	GridCacheDrManager.beforeExchange(AffinityTopologyVersion topVer, boolean left) Process partitions "before exchange" event.
void	GridOsCacheDrManager.beforeExchange(AffinityTopologyVersion topVer, boolean left) Process partitions "before exchange" event.

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 and Description
AffinityTopologyVersion	GridCacheQueryManager.queryTopologyVersion()
AffinityTopologyVersion	GridCacheQueryRequest.topologyVersion() Gets topology version or -1 in case of topology version is not required for this message.

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

Constructor and Description
GridCacheQueryRequest(int cacheId, long id, boolean fields, AffinityTopologyVersion topVer) Creates cancel query request.
GridCacheQueryRequest(int cacheId, long id, String cacheName, GridCacheQueryType type, boolean fields, String clause, String clsName, IgniteBiPredicate<Object,Object> keyValFilter, Integer part, IgniteReducer<Object,Object> rdc, IgniteClosure<Object,Object> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta, boolean keepPortable, UUID subjId, int taskHash, AffinityTopologyVersion topVer)
GridCacheQueryRequest(int cacheId, long id, String cacheName, int pageSize, boolean incBackups, boolean fields, boolean all, boolean keepPortable, UUID subjId, int taskHash, AffinityTopologyVersion topVer) Request to load page.

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

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

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

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

Modifier and Type	Method and Description
AffinityTopologyVersion	IgniteTxAdapter.topologyVersion()
AffinityTopologyVersion	IgniteInternalTx.topologyVersion()
AffinityTopologyVersion	IgniteTxAdapter.topologyVersion(AffinityTopologyVersion topVer) Attempts to set topology version and returns the current value.
AffinityTopologyVersion	IgniteInternalTx.topologyVersion(AffinityTopologyVersion topVer) Attempts to set topology version and returns the current value.
AffinityTopologyVersion	IgniteTxAdapter.topologyVersionSnapshot()
AffinityTopologyVersion	IgniteInternalTx.topologyVersionSnapshot()

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

Modifier and Type	Method and Description
protected GridCacheEntryEx	IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx, IgniteTxKey key, AffinityTopologyVersion topVer) Gets cache entry for given key and topology version.
IgniteInternalFuture<Boolean>	IgniteTxManager.finishTxs(AffinityTopologyVersion topVer) Creates a future that will wait for all ongoing transactions that maybe affected by topology update to be finished.
void	IgniteTxAdapter.onRemap(AffinityTopologyVersion topVer)
void	IgniteInternalTx.onRemap(AffinityTopologyVersion topVer)
AffinityTopologyVersion	IgniteTxAdapter.topologyVersion(AffinityTopologyVersion topVer) Attempts to set topology version and returns the current value.
AffinityTopologyVersion	IgniteInternalTx.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.cache.version

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

Modifier and Type	Method and Description
GridCacheVersion	GridCacheVersionManager.next(AffinityTopologyVersion topVer) Gets next version based on given topology version.
GridCacheVersion	GridCacheVersionManager.nextForLoad(AffinityTopologyVersion topVer) Gets next version for cache store load and reload operations.

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 and Description
AffinityTopologyVersion	DataStreamerRequest.topologyVersion()

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

Constructor and Description
DataStreamerRequest(long reqId, byte[] resTopicBytes, String cacheName, byte[] updaterBytes, Collection<DataStreamerEntry> entries, boolean ignoreDepOwnership, boolean skipStore, DeploymentMode depMode, String sampleClsName, String userVer, Map<UUID,IgniteUuid> ldrParticipants, IgniteUuid clsLdrId, boolean forceLocDep, AffinityTopologyVersion topVer)

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

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

Modifier and Type	Method and Description
IndexingQueryFilter	GridQueryIndexing.backupFilter(List<String> caches, AffinityTopologyVersion topVer, int[] parts) Returns backup filter.

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 and Description
AffinityTopologyVersion	GridQueryNextPageResponse.retry()
AffinityTopologyVersion	GridQueryRequest.topologyVersion()

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

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

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

Constructor and Description
GridQueryRequest(long reqId, int pageSize, String space, Collection<GridCacheSqlQuery> qrys, AffinityTopologyVersion topVer, List<String> extraSpaces, int[] parts)