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.events
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.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.persistence
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.cache.version
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.query
org.apache.ignite.internal.processors.query.h2.twostep.messages
org.apache.ignite.internal.visor.node

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

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

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

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

Modifier and Type	Method and 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 and Description
GridJobExecuteRequest(IgniteUuid sesId, IgniteUuid jobId, String taskName, String userVer, String taskClsName, byte[] jobBytes, ComputeJob job, long startTaskTime, long timeout, Collection<UUID> top, 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, UUID subjId, int[] cacheIds, int part, AffinityTopologyVersion topVer, 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.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	DiscoveryLocalJoinData.joinTopologyVersion()
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.cacheGroupAffinityNodes(int grpId, AffinityTopologyVersion topVer) Gets cache nodes for cache with given ID that participate in affinity calculation.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(AffinityTopologyVersion topVer) Gets all nodes with at least one cache configured.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(int cacheId, AffinityTopologyVersion topVer) Gets cache nodes for cache with given ID.
Collection<ClusterNode>	GridDiscoveryManager.cacheNodes(String cacheName, AffinityTopologyVersion topVer) Gets cache nodes for cache with given name.
DiscoCache	GridDiscoveryManager.discoCache(AffinityTopologyVersion topVer) Gets discovery collection cache from SPI safely guarding against "floating" collections.
ClusterNode	GridDiscoveryManager.node(AffinityTopologyVersion topVer, UUID id) Gets node from history for given topology version.
Collection<ClusterNode>	GridDiscoveryManager.nodes(AffinityTopologyVersion topVer) Gets all nodes for given topology version.
ClusterNode	GridDiscoveryManager.oldestAliveCacheServerNode(AffinityTopologyVersion topVer)
void	CustomEventListener.onCustomEvent(AffinityTopologyVersion topVer, ClusterNode snd, T msg)
Collection<ClusterNode>	GridDiscoveryManager.remoteCacheNodes(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 and Description
AffinityTopologyVersion	GridFailoverContextImpl.affinityTopologyVersion()

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

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

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

Constructor and Description
GridFailoverContextImpl(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, GridLoadBalancerManager loadMgr, int partId, String affCacheName, 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 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()
AffinityTopologyVersion	AffinityTopologyVersion.nextMinorVersion()
AffinityTopologyVersion	HistoryAffinityAssignment.topologyVersion()
AffinityTopologyVersion	GridAffinityAssignment.topologyVersion()
AffinityTopologyVersion	AffinityAssignment.topologyVersion()

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.
AffinityAssignment	GridAffinityAssignmentCache.cachedAffinity(AffinityTopologyVersion topVer) Get cached affinity for specified topology version.
List<List<ClusterNode>>	GridAffinityAssignmentCache.calculate(AffinityTopologyVersion topVer, DiscoveryEvent discoEvt, DiscoCache discoCache) Calculates affinity cache for given topology version.
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.
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.
boolean	GridAffinityAssignmentCache.primaryChanged(int part, AffinityTopologyVersion startVer, AffinityTopologyVersion endVer)
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	CacheGroupContext.localStartVersion()
AffinityTopologyVersion	GridCacheSharedContext.lockedTopologyVersion(IgniteInternalTx ignore)
AffinityTopologyVersion	GridCachePartitionExchangeManager.readyAffinityVersion()
AffinityTopologyVersion	DynamicCacheDescriptor.startTopologyVersion()
AffinityTopologyVersion	GridCacheContext.startTopologyVersion()
AffinityTopologyVersion	CacheGroupData.startTopologyVersion()
AffinityTopologyVersion	CacheGroupDescriptor.startTopologyVersion()
AffinityTopologyVersion	CacheAffinityChangeMessage.topologyVersion()
AffinityTopologyVersion	ReaderArguments.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	GridCacheMvccCandidate.topologyVersion()
AffinityTopologyVersion	GridCacheMessage.topologyVersion() Gets topology version or -1 in case of topology version is not required for this message.
AffinityTopologyVersion	GridCacheExplicitLockSpan.topologyVersion() Gets actual topology snapshot for thread lock span.
AffinityTopologyVersion	StateChangeRequest.topologyVersion()

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.
GridFutureAdapter	GridCacheMvccManager.addDataStreamerFuture(AffinityTopologyVersion topVer)
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.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.
boolean	GridCacheContext.allowFastLocalRead(int part, List<ClusterNode> affNodes, AffinityTopologyVersion topVer)
AffinityAssignment	GridCacheAffinityManager.assignment(AffinityTopologyVersion topVer) 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)
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>>	IgniteCacheOffheapManagerImpl.cacheEntriesIterator(GridCacheContext cctx, boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary)
GridIterator<CacheDataRow>	IgniteCacheOffheapManager.cacheIterator(int cacheId, boolean primary, boolean backup, AffinityTopologyVersion topVer)
GridIterator<CacheDataRow>	IgniteCacheOffheapManagerImpl.cacheIterator(int cacheId, boolean primary, boolean backups, AffinityTopologyVersion topVer)
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)
void	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)
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, int cacheId, AffinityTopologyVersion topVer)
IgniteInternalFuture<?>	GridCacheMvccManager.finishLocks(AffinityTopologyVersion topVer)
boolean	GridCacheEntryEx.initialValue(CacheObject val, GridCacheVersion ver, long ttl, long expireTime, boolean preload, AffinityTopologyVersion topVer, GridDrType drType, boolean fromStore) 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) Sets new value if current version is 0
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateAtomicResult	GridCacheEntryEx.innerUpdate(GridCacheVersion ver, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object val, Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, 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, CacheObject prevVal, Long updateCntr, GridDhtAtomicAbstractUpdateFuture fut)
GridCacheUpdateAtomicResult	GridCacheMapEntry.innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, 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, CacheObject prevVal, Long updateCntr, GridDhtAtomicAbstractUpdateFuture fut)
<T> T	IgniteCacheProxy.invoke(AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> javax.cache.processor.EntryProcessorResult<T>	IgniteInternalCache.invoke(AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> javax.cache.processor.EntryProcessorResult<T>	GridCacheProxyImpl.invoke(AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> javax.cache.processor.EntryProcessorResult<T>	GridCacheAdapter.invoke(AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
boolean	GridCacheAffinityManager.keyLocalNode(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).
protected long	GridCacheMapEntry.nextPartitionCounter(AffinityTopologyVersion topVer, boolean primary, Long primaryCntr)
List<ClusterNode>	GridCacheAffinityManager.nodesByKey(Object key, AffinityTopologyVersion topVer)
List<ClusterNode>	GridCacheAffinityManager.nodesByPartition(int part, AffinityTopologyVersion topVer)
boolean	GridCacheProcessor.onCustomEvent(DiscoveryCustomMessage msg, AffinityTopologyVersion topVer, ClusterNode node) Callback invoked from discovery thread when discovery custom message is received.
void	GridCacheProcessor.onDiscoveryEvent(int type, DiscoveryCustomMessage customMsg, ClusterNode node, AffinityTopologyVersion topVer, DiscoveryDataClusterState state)
void	GridCacheProcessor.onExchangeDone(AffinityTopologyVersion topVer, ExchangeActions exchActions, Throwable err) Callback invoked when first exchange future for dynamic cache is completed.
void	CacheGroupContext.onPartitionCounterUpdate(int cacheId, int part, long cntr, AffinityTopologyVersion topVer, boolean primary)
ExchangeActions	GridCacheProcessor.onStateChangeRequest(ChangeGlobalStateMessage msg, AffinityTopologyVersion topVer)
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.partitionReleaseFuture(AffinityTopologyVersion topVer) Captures all ongoing operations that we need to wait before we can proceed to the next topology version.
CacheObject	GridCacheEntryEx.peek(boolean heap, boolean offheap, AffinityTopologyVersion topVer, IgniteCacheExpiryPolicy plc) Peeks into entry without loading value or updating statistics.
CacheObject	GridCacheMapEntry.peek(boolean heap, boolean offheap, AffinityTopologyVersion topVer, IgniteCacheExpiryPolicy expiryPlc) Peeks into entry without loading value or updating statistics.
boolean	GridCacheAffinityManager.primaryByKey(ClusterNode n, Object key, AffinityTopologyVersion topVer)
ClusterNode	GridCacheAffinityManager.primaryByKey(Object key, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primaryByPartition(ClusterNode n, int part, AffinityTopologyVersion topVer)
ClusterNode	GridCacheAffinityManager.primaryByPartition(int part, AffinityTopologyVersion topVer)
boolean	GridCacheAffinityManager.primaryChanged(int part, AffinityTopologyVersion startVer, AffinityTopologyVersion endVer)
Set<Integer>	GridCacheAffinityManager.primaryPartitions(UUID nodeId, AffinityTopologyVersion topVer)
protected GridCacheMapEntry	GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheConcurrentMap.CacheMapHolder hld, GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean touch)
GridCacheMapEntry	GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean touch)
GridCacheMapEntry	GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean touch)
GridCacheMapEntry	GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean touch)
IgniteRebalanceIterator	IgniteCacheOffheapManager.rebalanceIterator(int part, AffinityTopologyVersion topVer, Long partCntr)
IgniteRebalanceIterator	IgniteCacheOffheapManagerImpl.rebalanceIterator(int part, AffinityTopologyVersion topVer, Long partCntr)
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.
void	GridCacheMvccManager.removeExplicitNodeLocks(UUID leftNodeId, AffinityTopologyVersion topVer)
GridDhtFuture<Object>	GridCachePreloaderAdapter.request(GridCacheContext ctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer) Requests that preloader sends the request for the key.
GridDhtFuture<Object>	GridCachePreloader.request(GridCacheContext cctx, 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.
GridDhtFuture<Object>	GridCachePreloader.request(GridCacheContext cctx, GridNearAtomicAbstractUpdateRequest req, AffinityTopologyVersion topVer) Requests that preloader sends the request for the key.
void	GridCacheProcessor.startCachesOnLocalJoin(List<T2<DynamicCacheDescriptor,NearCacheConfiguration>> caches, AffinityTopologyVersion exchTopVer)
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)
void	CacheEvictionManager.touch(GridCacheEntryEx e, AffinityTopologyVersion topVer)
void	GridCacheEvictionManager.touch(GridCacheEntryEx e, AffinityTopologyVersion topVer)
void	CacheOffheapEvictionManager.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
CacheAffinityChangeMessage(AffinityTopologyVersion topVer, Map<Integer,Map<Integer,List<UUID>>> assignmentChange, Map<Integer,IgniteUuid> cacheDeploymentIds) Constructor used when message is created after cache rebalance finished.
GridCacheAdapter.TopologyVersionAwareJob(String cacheName, AffinityTopologyVersion topVer)
GridCacheContext(GridKernalContext ctx, GridCacheSharedContext sharedCtx, CacheConfiguration cacheCfg, CacheGroupContext grp, CacheType cacheType, AffinityTopologyVersion locStartTopVer, boolean affNode, boolean updatesAllowed, 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)
GridCacheExplicitLockSpan(AffinityTopologyVersion topVer, GridCacheMvccCandidate cand)
ReaderArguments(UUID reader, long msgId, AffinityTopologyVersion topVer)
StateChangeRequest(ChangeGlobalStateMessage msg, AffinityTopologyVersion topVer)

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()
AffinityTopologyVersion	GridDistributedTxFinishRequest.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, boolean read) 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)
GridDistributedTxFinishRequest(GridCacheVersion xidVer, IgniteUuid futId, AffinityTopologyVersion topVer, GridCacheVersion commitVer, long threadId, boolean commit, boolean invalidate, boolean sys, byte plc, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, UUID subjId, int taskNameHash, int txSize, boolean addDepInfo)

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	GridDhtPartitionTopologyImpl.topologyVersion() Topology version.
AffinityTopologyVersion	GridDhtAffinityAssignmentResponse.topologyVersion()
AffinityTopologyVersion	GridClientPartitionTopology.topologyVersion() Topology version.
AffinityTopologyVersion	GridDhtTxPrepareRequest.topologyVersion()
AffinityTopologyVersion	ClientCacheDhtTopologyFuture.topologyVersion() Gets topology version of this future.
AffinityTopologyVersion	GridDhtUnreservedPartitionException.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionTopology.topologyVersion() Topology version.
AffinityTopologyVersion	GridDhtLockRequest.topologyVersion()
AffinityTopologyVersion	GridDhtAffinityAssignmentRequest.topologyVersion()
AffinityTopologyVersion	GridDhtTopologyFuture.topologyVersion() Gets topology version of this future.

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

Modifier and Type	Method and Description
protected IgniteInternalFuture<Boolean>	GridDhtTxLocal.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer) Adds reader to cached entry.
protected abstract IgniteInternalFuture<Boolean>	GridDhtTxLocalAdapter.addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer) Adds reader to cached entry.
IgniteInternalFuture<Boolean>	GridDhtCacheEntry.addReader(UUID nodeId, long msgId, AffinityTopologyVersion topVer)
boolean	GridDhtLocalPartition.backup(AffinityTopologyVersion topVer)
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, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean recovery)
GridDhtGetSingleFuture	GridDhtCacheAdapter.getDhtSingleAsync(UUID nodeId, long msgId, KeyCacheObject key, boolean addRdr, boolean readThrough, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean recovery)
GridDhtLocalPartition	GridDhtPartitionTopologyImpl.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
GridDhtLocalPartition	GridClientPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
GridDhtLocalPartition	GridDhtPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create)
GridDhtLocalPartition	GridDhtPartitionTopologyImpl.localPartition(int p, AffinityTopologyVersion topVer, boolean create, boolean showRenting)
GridDhtLocalPartition	GridClientPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create, boolean showRenting)
GridDhtLocalPartition	GridDhtPartitionTopology.localPartition(int p, AffinityTopologyVersion topVer, boolean create, boolean showRenting)
IgniteInternalFuture<?>	GridDhtCacheAdapter.multiUpdateFinishFuture(AffinityTopologyVersion topVer) Creates multi update finish future.
protected boolean	GridDhtCacheAdapter.needRemap(AffinityTopologyVersion expVer, AffinityTopologyVersion curVer)
protected long	GridDhtCacheEntry.nextPartitionCounter(AffinityTopologyVersion topVer, boolean primary, Long primaryCntr)
List<ClusterNode>	GridDhtPartitionTopologyImpl.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridClientPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopology.nodes(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopologyImpl.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridClientPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
List<ClusterNode>	GridDhtPartitionTopology.owners(int p, AffinityTopologyVersion topVer)
boolean	GridDhtLocalPartition.primary(AffinityTopologyVersion topVer)
GridCacheMapEntry	GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean touch)
boolean	GridDhtPartitionTopologyImpl.rebalanceFinished(AffinityTopologyVersion topVer)
boolean	GridClientPartitionTopology.rebalanceFinished(AffinityTopologyVersion topVer)
boolean	GridDhtPartitionTopology.rebalanceFinished(AffinityTopologyVersion topVer)
protected ClusterTopologyServerNotFoundException	CacheDistributedGetFutureAdapter.serverNotFoundError(AffinityTopologyVersion topVer)
boolean	GridDhtPartitionTopologyImpl.update(AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, Map<Integer,T2<Long,Long>> cntrMap, Set<Integer> partsToReload)
boolean	GridClientPartitionTopology.update(AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, Map<Integer,T2<Long,Long>> cntrMap, Set<Integer> partsToReload)
boolean	GridDhtPartitionTopology.update(AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, Map<Integer,T2<Long,Long>> cntrMap, Set<Integer> partsToReload)
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
ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer)
ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer, IgniteCheckedException e)
GridDhtAffinityAssignmentRequest(long futId, int grpId, AffinityTopologyVersion topVer, boolean sndPartMap)
GridDhtAffinityAssignmentResponse(long futId, int grpId, 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, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, boolean addReaders)
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, KeyCacheObject key, boolean addRdr, boolean readThrough, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery)
GridDhtLockFuture(GridCacheContext<?,?> cctx, UUID nearNodeId, GridCacheVersion nearLockVer, AffinityTopologyVersion topVer, int cnt, boolean read, boolean needReturnVal, long timeout, GridDhtTxLocalAdapter tx, long threadId, long createTtl, long accessTtl, CacheEntryPredicate[] filter, boolean skipStore, boolean keepBinary)
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, boolean storeUsed, boolean keepBinary, boolean addDepInfo)
GridDhtPartitionsReservation(AffinityTopologyVersion topVer, GridCacheContext<?,?> cctx, Object appKey)
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, int miniId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, TransactionIsolation isolation, boolean commit, boolean invalidate, boolean sys, byte plc, boolean sysInvalidate, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, UUID subjId, int taskNameHash, boolean addDepInfo, boolean retVal, boolean waitRemoteTxs)
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, int miniId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, TransactionIsolation isolation, boolean commit, boolean invalidate, boolean sys, byte plc, boolean sysInvalidate, CacheWriteSynchronizationMode syncMode, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, UUID subjId, int taskNameHash, boolean addDepInfo, Collection<Long> updateIdxs, boolean retVal, boolean waitRemoteTxs)
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)
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, UUID subjId, int taskNameHash, boolean addDepInfo, boolean storeWriteThrough, boolean retVal)
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, IgniteUuid rmtFutId, 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, UUID subjId, int taskNameHash, boolean single, boolean storeWriteThrough) This constructor is meant for optimistic transactions.
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, GridCacheVersion nearXidVer, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, UUID subjId, int taskNameHash, boolean storeWriteThrough) This constructor is meant for pessimistic transactions.
GridDhtUnreservedPartitionException(int part, AffinityTopologyVersion topVer, String msg)
GridPartitionedGetFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer, boolean readThrough, boolean forcePrimary, UUID subjId, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap, boolean needVer, boolean keepCacheObjects)
GridPartitionedSingleGetFuture(GridCacheContext cctx, KeyCacheObject key, AffinityTopologyVersion topVer, boolean readThrough, boolean forcePrimary, UUID subjId, String taskName, boolean deserializeBinary, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap, boolean needVer, boolean keepCacheObjects, boolean recovery)

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 and Description
protected AffinityTopologyVersion	GridNearAtomicAbstractUpdateFuture.remapTopVer
protected AffinityTopologyVersion	GridDhtAtomicAbstractUpdateRequest.topVer Topology version.
protected AffinityTopologyVersion	GridNearAtomicAbstractUpdateRequest.topVer Topology version.
protected AffinityTopologyVersion	GridNearAtomicAbstractUpdateFuture.topVer Current topology version.

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

Modifier and Type	Method and 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 and 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, AffinityTopologyVersion topVer, long ttl, long conflictExpireTime, GridCacheVersion conflictVer)
protected void	GridNearAtomicSingleUpdateFuture.map(AffinityTopologyVersion topVer)
protected abstract void	GridNearAtomicAbstractUpdateFuture.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 and Description
GridDhtAtomicAbstractUpdateRequest(int cacheId, UUID nodeId, long futId, GridCacheVersion writeVer, CacheWriteSynchronizationMode syncMode, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, boolean addDepInfo, boolean keepBinary, boolean skipStore) Constructor.
GridDhtAtomicUpdateRequest(int cacheId, UUID nodeId, long futId, GridCacheVersion writeVer, CacheWriteSynchronizationMode syncMode, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, Object[] invokeArgs, boolean addDepInfo, boolean keepBinary, boolean skipStore, boolean forceTransformBackups) Constructor.
GridNearAtomicAbstractSingleUpdateRequest(int cacheId, UUID nodeId, long futId, AffinityTopologyVersion topVer, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, UUID subjId, int taskNameHash, byte flags, boolean addDepInfo) Constructor.
GridNearAtomicAbstractUpdateRequest(int cacheId, UUID nodeId, long futId, AffinityTopologyVersion topVer, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, UUID subjId, 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 and 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(Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, UUID subjId, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap, boolean needVer)
IgniteInternalFuture<Map<K,V>>	GridDhtColocatedCache.loadAsync(Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, UUID subjId, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap, boolean needVer, boolean keepCacheObj)
IgniteInternalFuture<Object>	GridDhtColocatedCache.loadAsync(KeyCacheObject key, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, UUID subjId, String taskName, boolean deserializeBinary, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean canRemap, boolean needVer, boolean keepCacheObj, boolean recovery)

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 and 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 and Description
AffinityTopologyVersion	GridDhtPartitionMap.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionSupplyMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionDemandMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionExchangeId.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionsFullMessage.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionsExchangeFuture.topologyVersion() Gets topology version of this future.
AffinityTopologyVersion	GridDhtForceKeysRequest.topologyVersion()
AffinityTopologyVersion	GridDhtPartitionDemander.RebalanceFuture.topologyVersion()

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

Modifier and Type	Method and Description
boolean	GridDhtPartitionsExchangeFuture.onDone(AffinityTopologyVersion res, Throwable err) Callback to notify that future is finished.
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.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 and Description
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx, AffinityTopologyVersion topVer, Collection<KeyCacheObject> keys)
GridDhtPartitionExchangeId(UUID nodeId, int evt, AffinityTopologyVersion topVer)
GridDhtPartitionMap(UUID nodeId, long updateSeq, AffinityTopologyVersion top, GridPartitionStateMap m, boolean onlyActive)
GridDhtPartitionsFullMessage(GridDhtPartitionExchangeId id, GridCacheVersion lastVer, AffinityTopologyVersion topVer, IgniteDhtPartitionHistorySuppliersMap partHistSuppliers, IgniteDhtPartitionsToReloadMap partsToReload)
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	GridNearLockRequest.topologyVersion()
AffinityTopologyVersion	GridNearTxPrepareRequest.topologyVersion()
AffinityTopologyVersion	GridNearSingleGetResponse.topologyVersion()
AffinityTopologyVersion	GridNearGetResponse.topologyVersion()
AffinityTopologyVersion	GridNearGetRequest.topologyVersion()
AffinityTopologyVersion	GridNearSingleGetRequest.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, boolean read) Add 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.
GridCacheMapEntry	GridNearCacheAdapter.entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
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, AffinityTopologyVersion entryTopVer, Collection<KeyCacheObject> keys, boolean deserializeBinary, boolean skipVals, boolean keepCacheObjects, boolean skipStore, boolean recovery, boolean needVer)
void	GridNearGetFuture.init(AffinityTopologyVersion topVer) Initializes future.
void	GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer)
void	GridNearGetResponse.invalidPartitions(Collection<Integer> invalidParts, AffinityTopologyVersion topVer)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx, AffinityTopologyVersion entryTopVer, K key, javax.cache.processor.EntryProcessor<K,V,Object> entryProcessor, Object... invokeArgs)
<K,V,T> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.invokeAsync(GridCacheContext cacheCtx, AffinityTopologyVersion entryTopVer, Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,Object>> map, Object... invokeArgs)
protected boolean	GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx e, AffinityTopologyVersion topVer)
boolean	GridNearCacheEntry.loadedValue(IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, long ttl, long expireTime, boolean evt, boolean keepBinary, AffinityTopologyVersion topVer, UUID subjId)
IgniteInternalFuture<Void>	GridNearTxLocal.loadMissing(GridCacheContext cacheCtx, AffinityTopologyVersion topVer, boolean readThrough, boolean async, Collection<KeyCacheObject> keys, boolean skipVals, boolean needVer, boolean keepBinary, boolean recovery, javax.cache.expiry.ExpiryPolicy expiryPlc, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c)
void	GridNearTxLocal.onRemap(AffinityTopologyVersion topVer)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.putAllAsync(GridCacheContext cacheCtx, AffinityTopologyVersion entryTopVer, Map<? extends K,? extends V> map, boolean retval)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.putAsync(GridCacheContext cacheCtx, 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, 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	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, Map<KeyCacheObject,Boolean> keys, boolean readThrough, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, long createTtl, long accessTtl, boolean addReader, boolean skipVals, boolean addDepInfo, boolean recovery)
GridNearLockRequest(int cacheId, 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, UUID subjId, int taskNameHash, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary, boolean firstClientReq, boolean nearCache, boolean addDepInfo)
GridNearLockResponse(int cacheId, GridCacheVersion lockVer, IgniteUuid futId, int miniId, boolean filterRes, int cnt, Throwable err, AffinityTopologyVersion clientRemapVer, boolean addDepInfo)
GridNearSingleGetRequest(int cacheId, long futId, KeyCacheObject key, boolean readThrough, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, long createTtl, long accessTtl, boolean skipVals, boolean addReader, boolean needVer, boolean addDepInfo, boolean recovery)
GridNearSingleGetResponse(int cacheId, long futId, AffinityTopologyVersion topVer, 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, AffinityTopologyVersion topVer, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, UUID subjId, 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, UUID subjId, int taskNameHash, boolean firstClientReq, boolean addDepInfo)
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, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.
GridNearTxRemote(GridCacheSharedContext ctx, AffinityTopologyVersion topVer, UUID nodeId, UUID nearNodeId, GridCacheVersion nearXidVer, 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.

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.onExchange(AffinityTopologyVersion topVer, boolean left) Process partitions exchange event.
void	GridOsCacheDrManager.onExchange(AffinityTopologyVersion topVer, boolean left) Process partitions exchange event.
void	GridCacheDrManager.replicate(KeyCacheObject key, CacheObject val, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType, AffinityTopologyVersion topVer) Performs replication.
void	GridOsCacheDrManager.replicate(KeyCacheObject key, 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 and Description
IgniteRebalanceIterator	GridCacheOffheapManager.rebalanceIterator(int part, AffinityTopologyVersion topVer, Long partCntrSince)

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, boolean addDepInfo) 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<?,?> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta, boolean keepBinary, UUID subjId, int taskHash, AffinityTopologyVersion topVer, boolean addDepInfo)
GridCacheQueryRequest(int cacheId, long id, String cacheName, int pageSize, boolean incBackups, boolean fields, boolean all, boolean keepBinary, UUID subjId, int taskHash, AffinityTopologyVersion topVer, boolean addDepInfo) Request to load page.

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 and Description
void	CacheContinuousQueryManager.flushBackupQueue(AffinityTopologyVersion topVer)
void	CacheContinuousQueryListener.flushBackupQueue(GridKernalContext ctx, AffinityTopologyVersion topVer) Flushes backup queue.
void	CacheContinuousQueryManager.onEntryUpdated(KeyCacheObject key, CacheObject newVal, CacheObject oldVal, boolean internal, int partId, boolean primary, boolean preload, long updateCntr, GridDhtAtomicAbstractUpdateFuture fut, 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, GridDhtAtomicAbstractUpdateFuture fut, AffinityTopologyVersion topVer)
CounterSkipContext	CacheContinuousQueryManager.skipUpdateCounter(CounterSkipContext skipCtx, int part, long cntr, AffinityTopologyVersion topVer, boolean primary)
CounterSkipContext	CacheContinuousQueryListener.skipUpdateCounter(GridCacheContext cctx, 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.
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 and Description
protected AffinityTopologyVersion	IgniteTxAdapter.topVer Topology version.

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

Modifier and Type	Method and Description
AffinityTopologyVersion	IgniteTxManager.lockedTopologyVersion(long threadId, IgniteInternalTx ignore)
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.
boolean	IgniteTxManager.needWaitTransaction(IgniteInternalTx tx, AffinityTopologyVersion topVer)
boolean	IgniteTxManager.setTxTopologyHint(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.closure

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

Modifier and Type	Method and Description
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 and Description
AffinityTopologyVersion	DiscoveryDataClusterState.transitionTopologyVersion()

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

Modifier and Type	Method and Description
boolean	GridClusterStateProcessor.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 and Description
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 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, boolean keepBinary, 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 that return AffinityTopologyVersion

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

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

Modifier and Type	Method and 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.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()

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)

Uses of AffinityTopologyVersion in org.apache.ignite.internal.visor.node

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

Constructor and Description
VisorAffinityTopologyVersion(AffinityTopologyVersion affTopVer) Create data transfer object for affinity topology version.