| Package | Description |
|---|---|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.colocated | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.mvcc | |
| org.apache.ignite.internal.processors.cache.transactions | |
| org.apache.ignite.internal.processors.platform.client.tx |
| Modifier and Type | Method and Description |
|---|---|
GridNearTxLocal |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
GridNearTxLocal |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
| Modifier and Type | Method and Description |
|---|---|
protected GridNearTxLocal |
GridCacheAdapter.checkCurrentTx() |
@Nullable GridNearTxLocal |
GridCacheAdapter.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
GridNearTxLocal |
GridCacheProxyImpl.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
@Nullable GridNearTxLocal |
IgniteInternalCache.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
GridNearTxLocal |
GridCacheAdapter.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
GridNearTxLocal |
GridCacheProxyImpl.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
GridNearTxLocal |
IgniteInternalCache.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
static GridNearTxLocal |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
IgniteInternalCache prj,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
| Modifier and Type | Method and Description |
|---|---|
protected <T> IgniteInternalFuture<T> |
GridCacheAdapter.asyncOp(GridNearTxLocal tx,
GridCacheAdapter.AsyncOp<T> op,
CacheOperationContext opCtx,
boolean retry) |
IgniteInternalFuture<IgniteInternalTx> |
GridCacheSharedContext.commitTxAsync(GridNearTxLocal tx) |
void |
GridCacheSharedContext.endTx(GridNearTxLocal tx) |
abstract IgniteInternalFuture<T> |
GridCacheAdapter.AsyncOp.op(GridNearTxLocal tx,
AffinityTopologyVersion readyTopVer) |
IgniteInternalFuture<T> |
GridCacheAdapter.AsyncOp.op(GridNearTxLocal tx,
CacheOperationContext opCtx) |
void |
GridCacheSharedContext.resumeTx(GridNearTxLocal tx)
Resume transaction if it was previously suspended.
|
IgniteInternalFuture |
GridCacheSharedContext.rollbackTxAsync(GridNearTxLocal tx) |
void |
GridCacheSharedContext.suspendTx(GridNearTxLocal tx)
Suspends transaction.
|
| Constructor and Description |
|---|
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,
@Nullable String lb,
GridNearTxLocal parentTx) |
| Constructor and Description |
|---|
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
@Nullable GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary,
boolean recovery) |
| Modifier and Type | Field and Description |
|---|---|
protected GridNearTxLocal |
GridNearTxPrepareFutureAdapter.tx
Transaction.
|
protected GridNearTxLocal |
GridNearTxAbstractEnlistFuture.tx
Transaction.
|
| Modifier and Type | Method and Description |
|---|---|
GridNearTxLocal |
NearTxFinishFuture.tx() |
GridNearTxLocal |
GridNearTxFinishFuture.tx() |
GridNearTxLocal |
GridNearTxFastFinishFuture.tx() |
GridNearTxLocal |
GridNearTxFinishAndAckFuture.tx() |
| Modifier and Type | Method and Description |
|---|---|
static GridNearTxLocal |
MvccUtils.checkActive(GridNearTxLocal tx)
Checks transaction state.
|
static @Nullable GridNearTxLocal |
MvccUtils.tx(GridKernalContext ctx) |
static @Nullable GridNearTxLocal |
MvccUtils.tx(GridKernalContext ctx,
@Nullable GridCacheVersion txId) |
static GridNearTxLocal |
MvccUtils.txStart(GridCacheContext cctx,
long timeout) |
static GridNearTxLocal |
MvccUtils.txStart(GridKernalContext ctx,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
static GridNearTxLocal |
MvccUtils.checkActive(GridNearTxLocal tx)
Checks transaction state.
|
static @NotNull MvccQueryTracker |
MvccUtils.mvccTracker(GridCacheContext cctx,
GridNearTxLocal tx)
Initialises MVCC filter and returns MVCC query tracker if needed.
|
static MvccSnapshot |
MvccUtils.requestSnapshot(@NotNull GridNearTxLocal tx) |
| Modifier and Type | Method and Description |
|---|---|
GridNearTxLocal |
IgniteTxManager.newTx(boolean implicit,
boolean implicitSingle,
@Nullable GridCacheContext sysCacheCtx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean storeEnabled,
Boolean mvccOp,
int txSize,
@Nullable String lb,
boolean tracingEnabled) |
GridNearTxLocal |
IgniteTxManager.threadLocalTx(GridCacheContext cctx) |
GridNearTxLocal |
TransactionProxyImpl.tx() |
GridNearTxLocal |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
GridNearTxLocal |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
@Nullable GridNearTxLocal |
IgniteTxManager.userTx() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxManager.fastFinishTx(GridNearTxLocal tx,
boolean commit,
boolean clearThreadMap)
Fast finish transaction.
|
@Nullable IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.finish(UUID nodeId,
@Nullable GridNearTxLocal locTx,
GridNearTxFinishRequest req) |
IgniteInternalFuture<IgniteInternalTx> |
IgniteTxHandler.finishColocatedLocal(boolean commit,
GridNearTxLocal tx) |
IgniteInternalFuture<GridNearTxPrepareResponse> |
IgniteTxHandler.prepareColocatedTx(GridNearTxLocal locTx,
GridNearTxPrepareRequest req)
Prepares local colocated tx.
|
IgniteInternalFuture<GridNearTxPrepareResponse> |
IgniteTxHandler.prepareNearTxLocal(GridNearTxLocal originTx,
GridNearTxPrepareRequest req) |
void |
IgniteTxManager.resumeTx(GridNearTxLocal tx,
long threadId)
Resume transaction in current thread.
|
void |
IgniteTxAdapter.setParentTx(GridNearTxLocal parentTx) |
void |
IgniteTxManager.suspendTx(GridNearTxLocal tx)
Suspends transaction.
|
| Constructor and Description |
|---|
TransactionEventProxyImpl(GridNearTxLocal tx) |
TransactionProxyImpl(GridNearTxLocal tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
TransactionProxyRollbackOnlyImpl(GridNearTxLocal tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
| Modifier and Type | Method and Description |
|---|---|
GridNearTxLocal |
ClientTxContext.tx()
Gets transaction.
|
| Constructor and Description |
|---|
ClientTxContext(int txId,
GridNearTxLocal tx)
Constructor.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020