Uses of Class
org.apache.ignite.internal.processors.cache.transactions.IgniteTxKey

Packages that use IgniteTxKey

Package	Description
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.near
org.apache.ignite.internal.processors.cache.transactions

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

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

Modifier and Type	Method and Description
IgniteTxKey<K>	GridCacheMapEntry.txKey()
IgniteTxKey<K>	GridCacheEntryEx.txKey()
IgniteTxKey<K>	GridCacheContext.txKey(K key)

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

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

Modifier and Type	Field and Description
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	GridDistributedTxRemoteAdapter.readMap Read set.
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	GridDistributedTxRemoteAdapter.writeMap Write map.

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

Modifier and Type	Method and Description
IgniteTxKey	GridDistributedLockRequest.groupLockKey()
IgniteTxKey	GridDistributedTxFinishRequest.groupLockKey()
IgniteTxKey	GridDistributedTxPrepareRequest.groupLockKey()

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

Modifier and Type	Method and Description
Map<IgniteTxKey<K>,GridCacheVersion>	GridDistributedTxPrepareRequest.dhtVersions()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	GridDistributedTxRemoteAdapter.readMap()
Set<IgniteTxKey<K>>	GridDistributedTxRemoteAdapter.readSet()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	GridDistributedTxRemoteAdapter.writeMap()
Set<IgniteTxKey<K>>	GridDistributedTxRemoteAdapter.writeSet()

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

Modifier and Type	Method and Description
void	GridDistributedTxPrepareRequest.addDhtVersion(IgniteTxKey<K> key, GridCacheVersion dhtVer) Adds version to be verified on remote node.
void	GridDistributedTxRemoteAdapter.clearEntry(IgniteTxKey<K> key) Clears entry from transaction as it never happened.
IgniteTxEntry<K,V>	GridDistributedTxRemoteAdapter.entry(IgniteTxKey<K> key)
void	GridDistributedTxRemoteAdapter.groupLockKey(IgniteTxKey key) Adds group lock key to remote transaction.
boolean	GridDistributedTxRemoteAdapter.hasWriteKey(IgniteTxKey<K> key)
boolean	GridDistributedTxRemoteAdapter.removed(IgniteTxKey<K> key) Checks whether given key has been removed within transaction.

Method parameters in org.apache.ignite.internal.processors.cache.distributed with type arguments of type IgniteTxKey

Modifier and Type	Method and Description
void	GridDistributedTxMapping.evictReaders(Collection<IgniteTxKey<K>> keys)

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

Constructor and Description
GridDistributedLockRequest(int cacheId, UUID nodeId, GridCacheVersion nearXidVer, long threadId, IgniteUuid futId, GridCacheVersion lockVer, boolean isInTx, boolean isRead, TransactionIsolation isolation, boolean isInvalidate, long timeout, int keyCnt, int txSize, IgniteTxKey grpLockKey, boolean partLock)
GridDistributedTxFinishRequest(GridCacheVersion xidVer, IgniteUuid futId, GridCacheVersion commitVer, long threadId, boolean commit, boolean invalidate, boolean sys, boolean syncCommit, boolean syncRollback, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, IgniteTxKey grpLockKey)
GridDistributedTxPrepareRequest(IgniteInternalTx<K,V> tx, Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, boolean onePhaseCommit)
GridDistributedTxRemoteAdapter(GridCacheSharedContext<K,V> ctx, UUID nodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash)

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

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

Modifier and Type	Method and Description
Collection<IgniteTxKey<K>>	GridDhtTxPrepareResponse.nearEvicted()
Collection<IgniteTxKey<K>>	GridDhtLockResponse.nearEvicted()
Map<IgniteTxKey<K>,GridCacheVersion>	GridDhtTxPrepareRequest.owned()

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

Modifier and Type	Method and Description
void	GridDhtTxRemote.addWrite(GridCacheContext<K,V> cacheCtx, GridCacheOperation op, IgniteTxKey<K> key, byte[] keyBytes, V val, byte[] valBytes, Collection<T2<javax.cache.processor.EntryProcessor<K,V,?>,Object[]>> entryProcessors, long ttl)
void	GridDhtTxPrepareRequest.owned(IgniteTxKey<K> key, GridCacheVersion ownerMapped) Sets owner and its mapped version.

Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type IgniteTxKey

Modifier and Type	Method and Description
protected void	GridDhtTxLocalAdapter.addGroupTxMapping(Collection<IgniteTxKey<K>> keys) Adds key mapping to transaction.
void	GridDhtTxPrepareResponse.nearEvicted(Collection<IgniteTxKey<K>> nearEvicted)
void	GridDhtLockResponse.nearEvicted(Collection<IgniteTxKey<K>> nearEvicted)
IgniteInternalFuture<IgniteInternalTx<K,V>>	GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry<K,V>> reads, Iterable<IgniteTxEntry<K,V>> writes, Map<IgniteTxKey<K>,GridCacheVersion> verMap, long msgId, IgniteUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) Prepares next batch of entries in dht transaction.

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

Constructor and Description
GridDhtLockRequest(int cacheId, UUID nodeId, GridCacheVersion nearXidVer, long threadId, IgniteUuid futId, IgniteUuid miniId, GridCacheVersion lockVer, long topVer, boolean isInTx, boolean isRead, TransactionIsolation isolation, boolean isInvalidate, long timeout, int dhtCnt, int nearCnt, int txSize, IgniteTxKey grpLockKey, boolean partLock, UUID subjId, int taskNameHash, long accessTtl)
GridDhtTxFinishRequest(UUID nearNodeId, IgniteUuid futId, IgniteUuid miniId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, TransactionIsolation isolation, boolean commit, boolean invalidate, boolean sys, boolean sysInvalidate, boolean syncCommit, boolean syncRollback, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash)
GridDhtTxLocal(GridCacheSharedContext<K,V> cctx, UUID nearNodeId, GridCacheVersion nearXidVer, IgniteUuid nearFutId, IgniteUuid nearMiniId, long nearThreadId, boolean implicit, boolean implicitSingle, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, UUID subjId, int taskNameHash)
GridDhtTxLocalAdapter(GridCacheSharedContext<K,V> cctx, GridCacheVersion xidVer, boolean implicit, boolean implicitSingle, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, boolean partLock, UUID subjId, int taskNameHash)
GridDhtTxPrepareRequest(IgniteUuid futId, IgniteUuid miniId, long topVer, GridDhtTxLocalAdapter<K,V> tx, Collection<IgniteTxEntry<K,V>> dhtWrites, Collection<IgniteTxEntry<K,V>> nearWrites, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, boolean onePhaseCommit, UUID subjId, int taskNameHash)
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, GridCacheVersion nearXidVer, long rmtThreadId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for pessimistic transactions.
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, long rmtThreadId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, GridCacheVersion nearXidVer, Map<UUID,Collection<UUID>> txNodes, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.

Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type IgniteTxKey

Constructor and Description
GridDhtTxPrepareFuture(GridCacheSharedContext<K,V> cctx, GridDhtTxLocalAdapter<K,V> tx, IgniteUuid nearMiniId, Map<IgniteTxKey<K>,GridCacheVersion> dhtVerMap, boolean last, boolean retVal, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb)

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

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

Modifier and Type	Method and Description
Collection<IgniteTxKey<K>>	GridNearTxRemote.evicted()
Collection<IgniteTxKey<K>>	GridNearTxPrepareResponse.filterFailedKeys()
Map<IgniteTxKey<K>,GridTuple3<GridCacheVersion,V,byte[]>>	GridNearTxPrepareResponse.ownedValues()

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

Modifier and Type	Method and Description
protected IgniteCacheExpiryPolicy	GridNearTxLocal.accessPolicy(GridCacheContext ctx, IgniteTxKey<K> key, javax.cache.expiry.ExpiryPolicy expiryPlc)
boolean	GridNearTxRemote.addEntry(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key, byte[] keyBytes, GridCacheOperation op, V val, byte[] valBytes, GridCacheVersion drVer)
void	GridNearTxRemote.addEvicted(IgniteTxKey<K> key) Adds evicted key bytes to evicted collection.
void	GridNearTxLocal.addKeyMapping(IgniteTxKey<K> key, ClusterNode node) Adds key mapping to dht mapping.
void	GridNearTxPrepareResponse.addOwnedValue(IgniteTxKey<K> key, GridCacheVersion ver, V val, byte[] valBytes) Adds owned value.
protected GridCacheEntryEx<K,V>	GridNearTxLocal.entryEx(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key) Gets cache entry for given key.
protected GridCacheEntryEx<K,V>	GridNearTxLocal.entryEx(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key, long topVer) Gets cache entry for given key and topology version.
boolean	GridNearTxPrepareResponse.hasOwnedValue(IgniteTxKey<K> key)
GridCacheVersion	GridNearTxRemote.ownedVersion(IgniteTxKey<K> key) Gets owned version for near remote transaction.

Method parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type IgniteTxKey

Modifier and Type	Method and Description
protected void	GridNearTxLocal.addGroupTxMapping(Collection<IgniteTxKey<K>> keys) Adds key mapping to transaction.
void	GridNearTxPrepareResponse.filterFailedKeys(Collection<IgniteTxKey<K>> filterFailedKeys)
void	GridNearTxRemote.ownedVersions(Map<IgniteTxKey<K>,GridCacheVersion> vers) Adds owned versions to map.

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

Constructor and Description
GridNearLockRequest(int cacheId, long topVer, UUID nodeId, long threadId, IgniteUuid futId, GridCacheVersion lockVer, boolean isInTx, boolean implicitTx, boolean implicitSingleTx, boolean isRead, TransactionIsolation isolation, boolean isInvalidate, long timeout, int keyCnt, int txSize, boolean syncCommit, IgniteTxKey grpLockKey, boolean partLock, UUID subjId, int taskNameHash, long accessTtl)
GridNearTxLocal(GridCacheSharedContext<K,V> ctx, boolean implicit, boolean implicitSingle, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, boolean partLock, UUID subjId, int taskNameHash)
GridNearTxPrepareRequest(IgniteUuid futId, long topVer, IgniteInternalTx<K,V> tx, Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, IgniteTxKey grpLockKey, boolean partLock, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, UUID subjId, int taskNameHash)
GridNearTxRemote(GridCacheSharedContext<K,V> ctx, ClassLoader ldr, UUID nodeId, UUID nearNodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, Collection<IgniteTxEntry<K,V>> writeEntries, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.
GridNearTxRemote(GridCacheSharedContext<K,V> ctx, UUID nodeId, UUID nearNodeId, GridCacheVersion nearXidVer, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for pessimistic transactions.

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

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

Modifier and Type	Field and Description
protected IgniteTxKey	IgniteTxAdapter.grpLockKey Group lock key, if any.

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

Modifier and Type	Field and Description
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.txMap Per-transaction read map.

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

Modifier and Type	Method and Description
IgniteTxKey	IgniteTxAdapter.groupLockKey()
IgniteTxKey	IgniteInternalTx.groupLockKey()
IgniteTxKey<K>	IgniteTxEntry.txKey()

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

Modifier and Type	Method and Description
Set<Map.Entry<IgniteTxKey<K>,IgniteTxEntry<K,V>>>	IgniteTxMap.entrySet()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteInternalTx.readMap()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.readMap()
Set<IgniteTxKey<K>>	IgniteInternalTx.readSet()
Set<IgniteTxKey<K>>	IgniteTxLocalAdapter.readSet()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteInternalTx.writeMap()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.writeMap()
Set<IgniteTxKey<K>>	IgniteInternalTx.writeSet()
Set<IgniteTxKey<K>>	IgniteTxLocalAdapter.writeSet()

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

Modifier and Type	Method and Description
protected IgniteCacheExpiryPolicy	IgniteTxLocalAdapter.accessPolicy(GridCacheContext ctx, IgniteTxKey<K> key, javax.cache.expiry.ExpiryPolicy expiryPlc)
protected boolean	IgniteTxAdapter.checkInternal(IgniteTxKey<K> key)
IgniteTxEntry<K,V>	IgniteInternalTx.entry(IgniteTxKey<K> key)
IgniteTxEntry<K,V>	IgniteTxLocalAdapter.entry(IgniteTxKey<K> key)
protected GridCacheEntryEx<K,V>	IgniteTxLocalAdapter.entryEx(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key) Gets cache entry for given key.
protected GridCacheEntryEx<K,V>	IgniteTxLocalAdapter.entryEx(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key, long topVer) Gets cache entry for given key and topology version.
long	IgniteTxLocalAdapter.entryExpireTime(IgniteTxKey<K> key)
long	IgniteTxLocalAdapter.entryTtl(IgniteTxKey<K> key)
boolean	IgniteTxLocalAdapter.entryTtl(IgniteTxKey<K> key, long ttl)
boolean	IgniteInternalTx.hasWriteKey(IgniteTxKey<K> key)
boolean	IgniteTxLocalAdapter.hasWriteKey(IgniteTxKey<K> key)
IgniteTxLocalAdapter<K,V>	IgniteTxManager.newTx(boolean implicit, boolean implicitSingle, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, boolean partLock)
GridCacheVersion	IgniteTxAdapter.ownedVersion(IgniteTxKey<K> key) Gets owned version for near remote transaction.
GridCacheVersion	IgniteInternalTx.ownedVersion(IgniteTxKey<K> key) Gets owned version for near remote transaction.
boolean	IgniteInternalTx.removed(IgniteTxKey<K> key) Checks whether given key has been removed within transaction.
boolean	IgniteTxLocalAdapter.removed(IgniteTxKey<K> key) Checks whether given key has been removed within transaction.

Method parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteTxKey

Modifier and Type	Method and Description
protected void	IgniteTxLocalAdapter.addGroupTxMapping(Collection<IgniteTxKey<K>> keys) Adds key mapping to transaction.

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

Constructor and Description
IgniteTxAdapter(GridCacheSharedContext<K,V> cctx, GridCacheVersion xidVer, boolean implicit, boolean implicitSingle, boolean loc, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash)
IgniteTxAdapter(GridCacheSharedContext<K,V> cctx, UUID nodeId, GridCacheVersion xidVer, GridCacheVersion startVer, long threadId, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash)
IgniteTxLocalAdapter(GridCacheSharedContext<K,V> cctx, GridCacheVersion xidVer, boolean implicit, boolean implicitSingle, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, boolean partLock, UUID subjId, int taskNameHash)

Constructor parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteTxKey

Constructor and Description
IgniteTxMap(Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> txMap, IgnitePredicate<IgniteTxEntry<K,V>> filter)