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.store org.apache.ignite.internal.processors.cache.transactions org.apache.ignite.internal.processors.odbc org.apache.ignite.spi.systemview.view ContainsSystemViewclases 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 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 Description voidGridCacheEventManager. addEvent(int part, KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable GridCacheMvccCandidate owner, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)voidGridCacheEventManager. 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, @Nullable String cloClsName, @Nullable String taskName, boolean keepBinary)voidGridCacheEventManager. addEvent(int part, KeyCacheObject key, UUID nodeId, @Nullable IgniteInternalTx tx, GridCacheMvccCandidate owner, int type, CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)voidGridCacheMultiTxFuture. addTx(IgniteInternalTx tx)CacheObjectGridCacheEntryEx. innerGet(@Nullable GridCacheVersion ver, @Nullable IgniteInternalTx tx, boolean readThrough, boolean updateMetrics, boolean evt, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary)CacheObjectGridCacheMapEntry. innerGet(@Nullable GridCacheVersion ver, @Nullable IgniteInternalTx tx, boolean readThrough, boolean updateMetrics, boolean evt, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expirePlc, boolean keepBinary)EntryGetResultGridCacheEntryEx. innerGetVersioned(@Nullable GridCacheVersion ver, IgniteInternalTx tx, boolean updateMetrics, boolean evt, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary, @Nullable ReaderArguments readerArgs)EntryGetResultGridCacheMapEntry. innerGetVersioned(@Nullable GridCacheVersion ver, IgniteInternalTx tx, boolean updateMetrics, boolean evt, Object transformClo, String taskName, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary, @Nullable ReaderArguments readerArgs)GridCacheUpdateTxResultGridCacheEntryEx. innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)GridCacheUpdateTxResultGridCacheMapEntry. innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)GridCacheUpdateTxResultGridCacheEntryEx. innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, @Nullable CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)GridCacheUpdateTxResultGridCacheMapEntry. innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)@Nullable AffinityTopologyVersionGridCacheSharedContext. lockedTopologyVersion(IgniteInternalTx ignore)protected WALPointerGridCacheMapEntry. logTxUpdate(IgniteInternalTx tx, CacheObject val, GridCacheVersion writeVer, long expireTime, long updCntr)protected longGridCacheMapEntry. nextPartitionCounter(IgniteInternalTx tx, @Nullable Long updateCntr)voidGridCacheEventManager. readEvent(KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable String txLbl, @Nullable CacheObject val, @Nullable String taskName, boolean keepBinary)protected @Nullable ObjectGridCacheMapEntry. readThrough(@Nullable IgniteInternalTx tx, KeyCacheObject key, boolean reload, String taskName)booleanGridCacheEntryEx. 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 StringGridCacheUtils. txDump(@Nullable IgniteInternalTx tx)Alias forGridCacheUtils.txString(IgniteInternalTx).static booleanGridCacheUtils. txOnPrimary(IgniteInternalTx tx)static StringGridCacheUtils. txString(@Nullable IgniteInternalTx tx)voidGridCacheEntryEx. txUnlock(IgniteInternalTx tx)Unlocks acquired lock.voidGridCacheMapEntry. txUnlock(IgniteInternalTx tx)Unlocks acquired lock.@Nullable StringGridCacheSharedContext. verifyTxCompatibility(IgniteInternalTx tx, GridIntList activeCacheIds, GridCacheContext<K,V> cacheCtx) -
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 Description classGridDistributedTxRemoteAdapterTransaction created by system implicitly on remote nodes.Methods in org.apache.ignite.internal.processors.cache.distributed that return IgniteInternalTx Modifier and Type Method Description IgniteInternalTxGridCacheTxRecoveryFuture. tx()Methods in org.apache.ignite.internal.processors.cache.distributed that return types with arguments of type IgniteInternalTx Modifier and Type Method Description IgniteInternalFuture<IgniteInternalTx>GridDistributedTxRemoteAdapter. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.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 Description booleanGridDistributedCacheEntry. 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 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 Description classGridDhtTxLocalReplicated user transaction.classGridDhtTxLocalAdapterReplicated user transaction.classGridDhtTxRemoteTransaction 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 Description IgniteInternalFuture<IgniteInternalTx>GridDhtTxLocal. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.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 Description protected longGridDhtCacheEntry. nextPartitionCounter(IgniteInternalTx tx, @Nullable Long primaryCntr)booleanGridDhtTxFinishFuture. onDone(IgniteInternalTx tx, Throwable err)Callback to notify that future is finished.booleanGridDhtCacheEntry. 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 Description protected WALPointerGridDhtDetachedCacheEntry. logTxUpdate(IgniteInternalTx tx, CacheObject val, GridCacheVersion writeVer, 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 Description longGridDhtLocalPartition. 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 Description classGridNearTxLocalReplicated user transaction.classGridNearTxRemoteTransaction created by system implicitly on remote nodes.Methods in org.apache.ignite.internal.processors.cache.distributed.near that return IgniteInternalTx Modifier and Type Method Description IgniteInternalTxGridNearTxPrepareFutureAdapter. tx()Methods in org.apache.ignite.internal.processors.cache.distributed.near that return types with arguments of type IgniteInternalTx Modifier and Type Method Description IgniteInternalFuture<IgniteInternalTx>GridNearTxLocal. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.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 Description IgniteInternalFuture<Map<K,V>>GridNearCacheAdapter. loadAsync(@Nullable IgniteInternalTx tx, @Nullable Collection<KeyCacheObject> keys, boolean forcePrimary, String taskName, boolean deserializeBinary, boolean recovery, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, boolean skipVal, boolean skipStore, boolean needVer)booleanGridNearCacheEntry. loadedValue(@Nullable IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, long ttl, long expireTime, boolean evt, boolean keepBinary, AffinityTopologyVersion topVer)protected WALPointerGridNearCacheEntry. logTxUpdate(IgniteInternalTx tx, CacheObject val, GridCacheVersion writeVer, long expireTime, long updCntr)booleanGridNearOptimisticSerializableTxPrepareFuture. onDone(IgniteInternalTx t, Throwable err)Callback to notify that future is finished.booleanGridNearOptimisticTxPrepareFuture. onDone(IgniteInternalTx t, Throwable err)Callback to notify that future is finished.booleanGridNearPessimisticTxPrepareFuture. onDone(@Nullable IgniteInternalTx res, @Nullable Throwable err)Callback to notify that future is finished.booleanGridNearTxFinishFuture. onDone(IgniteInternalTx tx0, Throwable err)Callback to notify that future is finished.protected ObjectGridNearCacheEntry. readThrough(IgniteInternalTx tx, KeyCacheObject key, boolean reload, 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 Description protected IgniteInternalTxGridNearReadRepairAbstractFuture. txTx.Constructors in org.apache.ignite.internal.processors.cache.distributed.near.consistency with parameters of type IgniteInternalTx Constructor Description GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer, GridCacheContext<?,?> ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, IgniteInternalTx tx, GridNearReadRepairAbstractFuture remappedFut)Creates a new instance of GridNearReadRepairAbstractFuture.GridNearReadRepairCheckOnlyFuture(AffinityTopologyVersion topVer, GridCacheContext<?,?> ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, IgniteInternalTx tx)Creates a new instance of GridNearReadRepairCheckOnlyFuture.GridNearReadRepairFuture(AffinityTopologyVersion topVer, GridCacheContext ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, IgniteInternalTx tx)Creates a new instance of GridNearReadRepairFuture. -
Uses of 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 Description @Nullable ObjectCacheStoreManager. load(@Nullable IgniteInternalTx tx, KeyCacheObject key)Loads data from persistent store.@Nullable ObjectGridCacheStoreManagerAdapter. load(@Nullable IgniteInternalTx tx, KeyCacheObject key)Loads data from persistent store.booleanCacheStoreManager. loadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, IgniteBiInClosure<KeyCacheObject,Object> vis)Loads data from persistent store.booleanGridCacheStoreManagerAdapter. loadAll(@Nullable IgniteInternalTx tx, Collection keys, IgniteBiInClosure vis)Loads data from persistent store.voidCacheStoreManager. localStoreLoadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis)voidGridCacheStoreManagerAdapter. localStoreLoadAll(@Nullable IgniteInternalTx tx, Collection keys, GridInClosure3 vis)booleanCacheStoreManager. put(@Nullable IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver)Puts key-value pair into storage.booleanGridCacheStoreManagerAdapter. put(@Nullable IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver)Puts key-value pair into storage.booleanCacheStoreManager. putAll(@Nullable IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)Puts key-value pair into storage.booleanGridCacheStoreManagerAdapter. putAll(@Nullable IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)Puts key-value pair into storage.booleanCacheStoreManager. remove(@Nullable IgniteInternalTx tx, KeyCacheObject key)booleanGridCacheStoreManagerAdapter. remove(@Nullable IgniteInternalTx tx, KeyCacheObject key)booleanCacheStoreManager. removeAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)booleanGridCacheStoreManagerAdapter. removeAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)voidCacheStoreManager. sessionEnd(IgniteInternalTx tx, boolean commit, boolean last, boolean storeSessionEnded)voidGridCacheStoreManagerAdapter. sessionEnd(IgniteInternalTx tx, boolean commit, boolean last, boolean storeSesEnded) -
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 Description interfaceIgniteTxLocalExLocal transaction API.interfaceIgniteTxRemoteExLocal transaction API.Classes in org.apache.ignite.internal.processors.cache.transactions that implement IgniteInternalTx Modifier and Type Class Description classIgniteTxAdapterManaged transaction adapter.classIgniteTxLocalAdapterTransaction adapter for cache transactions.Fields in org.apache.ignite.internal.processors.cache.transactions declared as IgniteInternalTx Modifier and Type Field Description IgniteInternalTxIgniteTxEntry. txOwning transaction.Methods in org.apache.ignite.internal.processors.cache.transactions with type parameters of type IgniteInternalTx Modifier and Type Method Description <T extends IgniteInternalTx>
TIgniteTxManager. nearTx(GridCacheVersion txId)<T extends IgniteInternalTx>
TIgniteTxManager. onCreated(@Nullable GridCacheContext cacheCtx, T tx)<T extends IgniteInternalTx>
TIgniteTxManager. tx()<T extends IgniteInternalTx>
TIgniteTxManager. tx(GridCacheVersion txId)Methods in org.apache.ignite.internal.processors.cache.transactions that return IgniteInternalTx Modifier and Type Method Description IgniteInternalTxIgniteTxManager. 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 Description Collection<IgniteInternalTx>IgniteTxManager. activeTransactions()IgniteInternalFuture<IgniteInternalTx>IgniteInternalTx. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.@Nullable IgniteInternalFuture<IgniteInternalTx>IgniteTxHandler. finish(UUID nodeId, @Nullable GridNearTxLocal locTx, GridNearTxFinishRequest req)IgniteInternalFuture<IgniteInternalTx>IgniteTxHandler. finishColocatedLocal(boolean commit, GridNearTxLocal tx)IgniteInternalFuture<IgniteInternalTx>IgniteInternalTx. finishFuture()IgniteInternalFuture<IgniteInternalTx>IgniteTxAdapter. 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 Description voidIgniteTxManager. addAlternateVersion(GridCacheVersion ver, IgniteInternalTx tx)voidIgniteTxManager. addCommittedTx(IgniteInternalTx tx)booleanIgniteTxManager. addCommittedTx(IgniteInternalTx tx, GridCacheVersion xidVer, @Nullable GridCacheVersion nearXidVer)voidIgniteTxManager. addCommittedTxReturn(IgniteInternalTx tx, GridCacheReturnCompletableWrapper ret)booleanIgniteTxManager. addRolledbackTx(IgniteInternalTx tx)booleanIgniteTxManager. addRolledbackTx(IgniteInternalTx tx, GridCacheVersion xidVer)voidIgniteTxManager. 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).voidIgniteTxManager. 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)voidIgniteTxManager. finishTxOnRecovery(IgniteInternalTx tx, boolean commit)Commits or rolls back prepared transaction.@Nullable AffinityTopologyVersionIgniteTxManager. lockedTopologyVersion(long threadId, IgniteInternalTx ignore)booleanIgniteTxManager. needWaitTransaction(IgniteInternalTx tx, AffinityTopologyVersion topVer)booleanIgniteTxManager. onStarted(IgniteInternalTx tx)Transaction start callback (has to do with when any operation was performed on this transaction).voidIgniteTxImplicitSingleStateImpl. onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)protected voidIgniteTxLocalStateAdapter. onTxEnd(GridCacheContext cacheCtx, IgniteInternalTx tx, boolean commit)voidIgniteTxRemoteStateAdapter. onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)voidIgniteTxState. onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)voidIgniteTxStateImpl. onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)voidIgniteTxManager. prepareTx(IgniteInternalTx tx, @Nullable Collection<IgniteTxEntry> entries)Handles prepare stage.voidIgniteTxManager. removeCommittedTx(IgniteInternalTx tx)voidIgniteTxManager. rollbackTx(IgniteInternalTx tx, boolean clearThreadMap, boolean skipCompletedVers)Rolls back a transaction.voidIgniteTxManager. salvageTx(IgniteInternalTx tx)Invalidates transaction.voidIgniteTxManager. sendTransactionMessage(UUID nodeId, GridCacheMessage msg, IgniteInternalTx tx, byte plc)Sends transaction message after transforming it.voidIgniteTxManager. sendTransactionMessage(ClusterNode n, GridCacheMessage msg, IgniteInternalTx tx, byte plc)Sends transaction message after transforming it.IgniteInternalTxIgniteTxManager. tx(IgniteInternalTx tx)Sets transaction for current thread.voidIgniteTxManager. txContext(IgniteInternalTx tx)Method parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteInternalTx Modifier and Type Method Description voidIgniteTxManager. onCommitCallback(Consumer<IgniteInternalTx> callback)voidIgniteTxManager. txMessageTransformer(BiFunction<GridCacheMessage,IgniteInternalTx,GridCacheMessage> transform)Constructors in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteInternalTx Constructor Description 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.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. -
Uses of IgniteInternalTx in org.apache.ignite.internal.processors.odbc
Methods in org.apache.ignite.internal.processors.odbc that return types with arguments of type IgniteInternalTx Modifier and Type Method Description default IgniteInternalFuture<IgniteInternalTx>ClientTxSupport. endTxAsync(ClientListenerAbstractConnectionContext ctx, int txId, boolean committed)End transaction asynchronously. -
Uses of IgniteInternalTx in org.apache.ignite.spi.systemview.view
Constructors in org.apache.ignite.spi.systemview.view with parameters of type IgniteInternalTx Constructor Description TransactionView(IgniteInternalTx tx)
-