Uses of Interface
org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx

Packages that use IgniteInternalTx

Package	Description
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.colocated
org.apache.ignite.internal.processors.cache.distributed.dht.topology
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.distributed.near.consistency
org.apache.ignite.internal.processors.cache.local
org.apache.ignite.internal.processors.cache.mvcc
org.apache.ignite.internal.processors.cache.query.continuous
org.apache.ignite.internal.processors.cache.store
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.spi.systemview.view	Contains SystemView clases that exists in Ignite.

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

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

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridCacheSharedContext.commitTxAsync(GridNearTxLocal tx)
static IgniteClosure<IgniteInternalTx,GridCacheVersion>	GridCacheUtils.tx2xidVersion()

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

Modifier and Type	Method and Description
void	GridCacheEventManager.addEvent(int part, KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable GridCacheMvccCandidate owner, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, UUID subjId, String cloClsName, String taskName, boolean keepBinary)
void	GridCacheEventManager.addEvent(int part, KeyCacheObject key, UUID nodeId, @Nullable IgniteInternalTx tx, GridCacheMvccCandidate owner, int type, CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, UUID subjId, String cloClsName, String taskName, boolean keepBinary)
void	GridCacheEventManager.addEvent(int part, KeyCacheObject key, UUID evtNodeId, @Nullable IgniteInternalTx tx, @Nullable String txLbl, @Nullable Object lockId, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, UUID subjId, @Nullable String cloClsName, @Nullable String taskName, boolean keepBinary)
void	GridCacheMultiTxFuture.addTx(IgniteInternalTx tx)
boolean	GridCacheContext.hasContinuousQueryListeners(@Nullable IgniteInternalTx tx)
CacheObject	GridCacheMapEntry.innerGet(@Nullable GridCacheVersion ver, @Nullable IgniteInternalTx tx, boolean readThrough, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expirePlc, boolean keepBinary)
CacheObject	GridCacheEntryEx.innerGet(@Nullable GridCacheVersion ver, @Nullable IgniteInternalTx tx, boolean readThrough, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary)
EntryGetResult	GridCacheMapEntry.innerGetVersioned(@Nullable GridCacheVersion ver, IgniteInternalTx tx, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary, @Nullable ReaderArguments readerArgs)
EntryGetResult	GridCacheEntryEx.innerGetVersioned(@Nullable GridCacheVersion ver, IgniteInternalTx tx, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary, @Nullable ReaderArguments readerArgs)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, @Nullable CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
@Nullable AffinityTopologyVersion	GridCacheSharedContext.lockedTopologyVersion(IgniteInternalTx ignore)
protected WALPointer	GridCacheMapEntry.logMvccUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr, MvccSnapshot mvccVer)
protected WALPointer	GridCacheMapEntry.logTxUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccRemove(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, boolean needHistory, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccRemove(@Nullable IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, boolean needHist, boolean needOldValue, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccSet(IgniteInternalTx tx, UUID affNodeId, CacheObject val, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, long ttl0, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, GridCacheOperation op, boolean needHistory, boolean noCreate, boolean needOldVal, CacheEntryPredicate filter, boolean retVal, boolean keepBinary)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccSet(@Nullable IgniteInternalTx tx, UUID affNodeId, CacheObject val, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, long ttl0, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, GridCacheOperation op, boolean needHistory, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, List<GridCacheEntryInfo> entries, GridCacheOperation op, MvccSnapshot mvccVer, IgniteUuid futId, int batchNum)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, List<GridCacheEntryInfo> entries, GridCacheOperation op, MvccSnapshot mvccVer, IgniteUuid futId, int batchNum)
protected long	GridCacheMapEntry.nextPartitionCounter(IgniteInternalTx tx, @Nullable Long updateCntr)
void	GridCacheEventManager.readEvent(KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable String txLbl, @Nullable CacheObject val, @Nullable UUID subjId, @Nullable String taskName, boolean keepBinary)
protected @Nullable Object	GridCacheMapEntry.readThrough(@Nullable IgniteInternalTx tx, KeyCacheObject key, boolean reload, UUID subjId, String taskName)
static <K,V> UUID	GridCacheUtils.subjectId(IgniteInternalTx tx, GridCacheSharedContext<K,V> ctx) Gets subject ID by transaction.
boolean	GridCacheEntryEx.tmLock(IgniteInternalTx tx, long timeout, @Nullable GridCacheVersion serOrder, @Nullable GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.
static String	GridCacheUtils.txDump(@Nullable IgniteInternalTx tx) Alias for GridCacheUtils.txString(IgniteInternalTx).
static String	GridCacheUtils.txString(@Nullable IgniteInternalTx tx)
void	GridCacheMapEntry.txUnlock(IgniteInternalTx tx) Unlocks acquired lock.
void	GridCacheEntryEx.txUnlock(IgniteInternalTx tx) Unlocks acquired lock.
@Nullable String	GridCacheSharedContext.verifyTxCompatibility(IgniteInternalTx tx, GridIntList activeCacheIds, GridCacheContext<K,V> cacheCtx)

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

Modifier and Type	Method and Description
IgniteInternalFuture<?>	GridCacheSharedContext.partitionRecoveryFuture(AffinityTopologyVersion topVer, ClusterNode node, IgnitePredicate<IgniteInternalTx> filter) Captures all prepared operations that we need to wait before we able to perform PME-free switch.

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

Classes in org.apache.ignite.internal.processors.cache.distributed that implement IgniteInternalTx

Modifier and Type	Class and Description
class	GridDistributedTxRemoteAdapter Transaction created by system implicitly on remote nodes.

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

Modifier and Type	Method and Description
IgniteInternalTx	GridCacheTxRecoveryFuture.tx()

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

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridDistributedTxRemoteAdapter.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	GridDistributedTxRemoteAdapter.rollbackAsync() Asynchronously rollback this transaction.

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

Modifier and Type	Method and Description
boolean	GridDistributedCacheEntry.tmLock(IgniteInternalTx tx, long timeout, @Nullable GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.

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

Constructor and Description
GridCacheTxRecoveryFuture(GridCacheSharedContext<?,?> cctx, IgniteInternalTx tx, Set<UUID> failedNodeIds, Map<UUID,Collection<UUID>> txNodes)
GridCacheTxRecoveryRequest(IgniteInternalTx tx, int txNum, boolean nearTxCheck, IgniteUuid futId, IgniteUuid miniId, boolean addDepInfo)
GridDistributedTxPrepareRequest(IgniteInternalTx tx, long timeout, @Nullable Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, Map<UUID,Collection<UUID>> txNodes, boolean retVal, boolean last, boolean onePhaseCommit, boolean addDepInfo)

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

Classes in org.apache.ignite.internal.processors.cache.distributed.dht that implement IgniteInternalTx

Modifier and Type	Class and Description
class	GridDhtTxLocal Replicated user transaction.
class	GridDhtTxLocalAdapter Replicated user transaction.
class	GridDhtTxRemote Transaction created by system implicitly on remote nodes.

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

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.commitDhtLocalAsync()
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.rollbackAsync() Asynchronously rollback this transaction.
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.rollbackDhtLocalAsync()

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

Modifier and Type	Method and Description
protected long	GridDhtCacheEntry.nextPartitionCounter(IgniteInternalTx tx, @Nullable Long primaryCntr)
boolean	GridDhtTxFinishFuture.onDone(IgniteInternalTx tx, Throwable err) Callback to notify that future is finished.
boolean	GridDhtCacheEntry.tmLock(IgniteInternalTx tx, long timeout, @Nullable GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.

Uses of IgniteInternalTx 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 IgniteInternalTx

Modifier and Type	Method and Description
protected WALPointer	GridDhtDetachedCacheEntry.logTxUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr)

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

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

Modifier and Type	Method and Description
long	GridDhtLocalPartition.nextUpdateCounter(int cacheId, IgniteInternalTx tx, @Nullable Long primaryCntr) Used for transactions.

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

Classes in org.apache.ignite.internal.processors.cache.distributed.near that implement IgniteInternalTx

Modifier and Type	Class and Description
class	GridNearTxLocal Replicated user transaction.
class	GridNearTxRemote Transaction created by system implicitly on remote nodes.

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

Modifier and Type	Method and Description
IgniteInternalTx	GridNearTxPrepareFutureAdapter.tx()

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

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.commitAsyncLocal() Commits local part of colocated transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.commitNearTxLocalAsync()
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackAsync() Asynchronously rollback this transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackAsyncLocal() Rolls back local part of colocated transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackNearTxLocalAsync()
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackNearTxLocalAsync(boolean clearThreadMap, boolean onTimeout)

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

Modifier and Type	Method and Description
IgniteInternalFuture<Map<K,V>>	GridNearCacheAdapter.loadAsync(@Nullable IgniteInternalTx tx, @Nullable Collection<KeyCacheObject> keys, boolean forcePrimary, @Nullable UUID subjId, String taskName, boolean deserializeBinary, boolean recovery, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, boolean skipVal, boolean skipStore, boolean needVer)
boolean	GridNearCacheEntry.loadedValue(@Nullable IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, long ttl, long expireTime, boolean evt, boolean keepBinary, AffinityTopologyVersion topVer, UUID subjId)
protected WALPointer	GridNearCacheEntry.logTxUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr)
boolean	GridNearTxFinishFuture.onDone(IgniteInternalTx tx0, Throwable err) Callback to notify that future is finished.
boolean	GridNearPessimisticTxPrepareFuture.onDone(@Nullable IgniteInternalTx res, @Nullable Throwable err) Callback to notify that future is finished.
boolean	GridNearOptimisticTxPrepareFuture.onDone(IgniteInternalTx t, Throwable err) Callback to notify that future is finished.
boolean	GridNearOptimisticSerializableTxPrepareFuture.onDone(IgniteInternalTx t, Throwable err) Callback to notify that future is finished.
protected Object	GridNearCacheEntry.readThrough(IgniteInternalTx tx, KeyCacheObject key, boolean reload, UUID subjId, String taskName)

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

Fields in org.apache.ignite.internal.processors.cache.distributed.near.consistency declared as IgniteInternalTx

Modifier and Type	Field and Description
protected IgniteInternalTx	GridNearReadRepairAbstractFuture.tx Tx.

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

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

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.local

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

Modifier and Type	Method and Description
boolean	GridLocalCacheEntry.tmLock(IgniteInternalTx tx, long timeout, @Nullable GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.mvcc

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

Modifier and Type	Method and Description
void	MvccCachingManager.addEnlisted(KeyCacheObject key, @Nullable CacheObject val, long ttl, long expireTime, GridCacheVersion ver, CacheObject oldVal, boolean primary, AffinityTopologyVersion topVer, MvccVersion mvccVer, int cacheId, IgniteInternalTx tx, IgniteUuid futId, int batchNum) Adds enlisted tx entry to cache.
Map<UUID,CacheContinuousQueryListener>	MvccCachingManager.continuousQueryListeners(GridCacheContext ctx0, @Nullable IgniteInternalTx tx)
void	MvccCachingManager.onTxFinished(IgniteInternalTx tx, boolean commit)

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

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

Modifier and Type	Method and Description
boolean	CacheContinuousQueryManager.notifyContinuousQueries(@Nullable IgniteInternalTx tx)

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.store

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

Modifier and Type	Method and Description
@Nullable Object	CacheStoreManager.load(@Nullable IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
@Nullable Object	GridCacheStoreManagerAdapter.load(@Nullable IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
boolean	CacheStoreManager.loadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, IgniteBiInClosure<KeyCacheObject,Object> vis) Loads data from persistent store.
boolean	GridCacheStoreManagerAdapter.loadAll(@Nullable IgniteInternalTx tx, Collection keys, IgniteBiInClosure vis) Loads data from persistent store.
void	CacheStoreManager.localStoreLoadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis)
void	GridCacheStoreManagerAdapter.localStoreLoadAll(@Nullable IgniteInternalTx tx, Collection keys, GridInClosure3 vis)
boolean	CacheStoreManager.put(@Nullable IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	GridCacheStoreManagerAdapter.put(@Nullable IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	CacheStoreManager.putAll(@Nullable IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	GridCacheStoreManagerAdapter.putAll(@Nullable IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	CacheStoreManager.remove(@Nullable IgniteInternalTx tx, KeyCacheObject key)
boolean	GridCacheStoreManagerAdapter.remove(@Nullable IgniteInternalTx tx, KeyCacheObject key)
boolean	CacheStoreManager.removeAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)
boolean	GridCacheStoreManagerAdapter.removeAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)
void	CacheStoreManager.sessionEnd(IgniteInternalTx tx, boolean commit, boolean last, boolean storeSessionEnded)
void	GridCacheStoreManagerAdapter.sessionEnd(IgniteInternalTx tx, boolean commit, boolean last, boolean storeSessionEnded)

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

Subinterfaces of IgniteInternalTx in org.apache.ignite.internal.processors.cache.transactions

Modifier and Type	Interface and Description
interface	IgniteTxLocalEx Local transaction API.
interface	IgniteTxRemoteEx Local transaction API.

Classes in org.apache.ignite.internal.processors.cache.transactions that implement IgniteInternalTx

Modifier and Type	Class and Description
class	IgniteTxAdapter Managed transaction adapter.
class	IgniteTxLocalAdapter Transaction adapter for cache transactions.

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

Modifier and Type	Field and Description
IgniteInternalTx	IgniteTxEntry.tx Owning transaction.

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

Modifier and Type	Method and Description
<T extends IgniteInternalTx> T	IgniteTxManager.nearTx(GridCacheVersion txId)
<T extends IgniteInternalTx> T	IgniteTxManager.onCreated(@Nullable GridCacheContext cacheCtx, T tx)
<T extends IgniteInternalTx> T	IgniteTxManager.tx(GridCacheVersion txId)

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

Modifier and Type	Method and Description
IgniteInternalTx	IgniteTxManager.tx(IgniteInternalTx tx) Sets transaction for current thread.

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

Modifier and Type	Method and Description
Collection<IgniteInternalTx>	IgniteTxManager.activeTransactions()
IgniteInternalFuture<IgniteInternalTx>	IgniteInternalTx.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.finishColocatedLocal(boolean commit, GridNearTxLocal tx)
IgniteInternalFuture<IgniteInternalTx>	IgniteTxAdapter.finishFuture()
IgniteInternalFuture<IgniteInternalTx>	IgniteInternalTx.finishFuture()
IgniteInternalFuture<IgniteInternalTx>	IgniteInternalTx.rollbackAsync() Asynchronously rollback this transaction.

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

Modifier and Type	Method and Description
void	IgniteTxManager.addAlternateVersion(GridCacheVersion ver, IgniteInternalTx tx)
void	IgniteTxManager.addCommittedTx(IgniteInternalTx tx)
boolean	IgniteTxManager.addCommittedTx(IgniteInternalTx tx, GridCacheVersion xidVer, @Nullable GridCacheVersion nearXidVer)
void	IgniteTxManager.addCommittedTxReturn(IgniteInternalTx tx, GridCacheReturnCompletableWrapper ret)
boolean	IgniteTxManager.addRolledbackTx(IgniteInternalTx tx)
boolean	IgniteTxManager.addRolledbackTx(IgniteInternalTx tx, GridCacheVersion xidVer)
void	IgniteTxManager.clearThreadMap(IgniteInternalTx tx)
IgniteInternalFuture<Boolean>	IgniteTxManager.commitIfPrepared(IgniteInternalTx tx, Set<UUID> failedNodeIds) Commits transaction in case when node started transaction failed, but all related transactions were prepared (invalidates transaction if it is not fully prepared).
void	IgniteTxManager.commitTx(IgniteInternalTx tx) Commits a transaction.
IgniteInternalFuture<TxDeadlock>	IgniteTxManager.detectDeadlock(IgniteInternalTx tx, Set<IgniteTxKey> keys) Performs deadlock detection for given keys.
@Nullable List<PartitionUpdateCountersMessage>	IgniteTxHandler.filterUpdateCountersForBackupNode(IgniteInternalTx tx, ClusterNode node)
void	IgniteTxManager.finishTxOnRecovery(IgniteInternalTx tx, boolean commit) Commits or rolls back prepared transaction.
void	IgniteTxManager.forgetTx(IgniteInternalTx tx) Removes Tx from manager.
@Nullable AffinityTopologyVersion	IgniteTxManager.lockedTopologyVersion(long threadId, IgniteInternalTx ignore)
boolean	IgniteTxManager.needWaitTransaction(IgniteInternalTx tx, AffinityTopologyVersion topVer)
boolean	IgniteTxManager.onStarted(IgniteInternalTx tx) Transaction start callback (has to do with when any operation was performed on this transaction).
protected void	IgniteTxLocalStateAdapter.onTxEnd(GridCacheContext cacheCtx, IgniteInternalTx tx, boolean commit)
void	IgniteTxRemoteStateAdapter.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxState.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxStateImpl.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxImplicitSingleStateImpl.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxManager.prepareTx(IgniteInternalTx tx, @Nullable Collection<IgniteTxEntry> entries) Handles prepare stage.
void	IgniteTxManager.removeCommittedTx(IgniteInternalTx tx)
void	IgniteTxManager.rollbackTx(IgniteInternalTx tx, boolean clearThreadMap, boolean skipCompletedVers) Rolls back a transaction.
void	IgniteTxManager.salvageTx(IgniteInternalTx tx) Invalidates transaction.
void	IgniteTxManager.setMvccState(IgniteInternalTx tx, byte state) Sets MVCC state.
IgniteInternalTx	IgniteTxManager.tx(IgniteInternalTx tx) Sets transaction for current thread.
void	IgniteTxManager.txContext(IgniteInternalTx tx)

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

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	IgniteTxManager.recoverLocalTxs(AffinityTopologyVersion topVer, ClusterNode node, IgnitePredicate<IgniteInternalTx> filter) Creates a future that will wait for all transactions with failed primary recovery.

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

Constructor and Description
IgniteTxEntry(GridCacheContext<?,?> ctx, IgniteInternalTx tx, GridCacheOperation op, CacheObject val, javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor, Object[] invokeArgs, long ttl, GridCacheEntryEx entry, CacheEntryPredicate[] filters, GridCacheVersion conflictVer, boolean skipStore, boolean keepBinary, boolean addReader) This constructor is meant for local transactions.
IgniteTxEntry(GridCacheContext<?,?> ctx, IgniteInternalTx tx, GridCacheOperation op, CacheObject val, long ttl, long conflictExpireTime, GridCacheEntryEx entry, @Nullable GridCacheVersion conflictVer, boolean skipStore, boolean keepBinary) This constructor is meant for remote transactions.
PartitionCountersNeighborcastFuture(IgniteInternalTx tx, GridCacheSharedContext<?,?> cctx)

Uses of IgniteInternalTx in org.apache.ignite.spi.systemview.view

Constructors in org.apache.ignite.spi.systemview.view with parameters of type IgniteInternalTx

Constructor and Description
TransactionView(IgniteInternalTx tx)