| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteTransactionsEx.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx |
GridCacheProjectionImpl.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
CacheProjection.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
GridCacheProxyImpl.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
GridCacheAdapter.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
static IgniteInternalTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
CacheProjection prj,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<IgniteInternalTx> |
GridCacheAdapter.commitTxAsync(IgniteInternalTx tx)
Asynchronously commits transaction after all previous asynchronous operations are completed.
|
IgniteInternalFuture<IgniteInternalTx> |
GridCacheSharedContext.commitTxAsync(IgniteInternalTx<K,V> tx) |
Set<IgniteInternalTx<K,V>> |
GridCacheMultiTxFuture.remainingTxs() |
static <K,V> IgniteClosure<IgniteInternalTx<K,V>,GridCacheVersion> |
GridCacheUtils.tx2xidVersion() |
Set<IgniteInternalTx<K,V>> |
GridCacheMultiTxFuture.txs() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheEventManager.addEvent(int part,
K key,
IgniteInternalTx tx,
GridCacheMvccCandidate<K> owner,
int type,
V newVal,
boolean hasNewVal,
V oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName) |
void |
GridCacheEventManager.addEvent(int part,
K key,
UUID nodeId,
IgniteInternalTx tx,
GridCacheMvccCandidate<K> owner,
int type,
V newVal,
boolean hasNewVal,
V oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName) |
void |
GridCacheMultiTxFuture.addTx(IgniteInternalTx<K,V> tx) |
IgniteInternalFuture<IgniteInternalTx> |
GridCacheAdapter.commitTxAsync(IgniteInternalTx tx)
Asynchronously commits transaction after all previous asynchronous operations are completed.
|
IgniteInternalFuture<IgniteInternalTx> |
GridCacheSharedContext.commitTxAsync(IgniteInternalTx<K,V> tx) |
void |
GridCacheSharedContext.endTx(IgniteInternalTx<K,V> tx) |
V |
GridCacheMapEntry.innerGet(IgniteInternalTx<K,V> tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc) |
V |
GridCacheEntryEx.innerGet(IgniteInternalTx<K,V> tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerRemove(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerRemove(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerSet(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerSet(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
boolean |
GridCacheStoreManager.loadAllFromStore(IgniteInternalTx tx,
Collection<? extends K> keys,
IgniteBiInClosure<K,V> vis)
Loads data from persistent store.
|
V |
GridCacheStoreManager.loadFromStore(IgniteInternalTx tx,
K key)
Loads data from persistent store.
|
void |
GridCacheStoreManager.localStoreLoadAll(IgniteInternalTx tx,
Collection<? extends K> keys,
GridInClosure3<K,V,GridCacheVersion> vis) |
GridTuple<V> |
GridCacheMapEntry.peek0(boolean failFast,
GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
IgniteInternalTx<K,V> tx) |
GridTuple<V> |
GridCacheEntryEx.peek0(boolean failFast,
GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
IgniteInternalTx<K,V> tx) |
protected GridTuple<V> |
GridCacheAdapter.peek0(boolean failFast,
K key,
Collection<GridCachePeekMode> modes,
IgniteInternalTx<K,V> tx) |
protected V |
GridCacheAdapter.peek0(K key,
Collection<GridCachePeekMode> modes,
IgniteInternalTx<K,V> tx) |
protected Map<K,V> |
GridCacheAdapter.peekAll0(Collection<? extends K> keys,
Collection<GridCachePeekMode> modes,
IgniteInternalTx<K,V> tx,
Collection<K> skipped) |
boolean |
GridCacheStoreManager.putAllToStore(IgniteInternalTx tx,
Map<K,IgniteBiTuple<V,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManager.putToStore(IgniteInternalTx tx,
K key,
V val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
protected V |
GridCacheMapEntry.readThrough(IgniteInternalTx<K,V> tx,
K key,
boolean reload,
UUID subjId,
String taskName) |
IgniteInternalFuture<Object> |
GridCacheAdapter.readThroughAllAsync(Collection<? extends K> keys,
boolean reload,
boolean skipVals,
IgniteInternalTx<K,V> tx,
UUID subjId,
String taskName,
IgniteBiInClosure<K,V> vis) |
boolean |
GridCacheStoreManager.removeAllFromStore(IgniteInternalTx tx,
Collection<?> keys) |
boolean |
GridCacheStoreManager.removeFromStore(IgniteInternalTx tx,
K key) |
IgniteInternalFuture |
GridCacheSharedContext.rollbackTxAsync(IgniteInternalTx<K,V> tx) |
static <K,V> UUID |
GridCacheUtils.subjectId(IgniteInternalTx<K,V> tx,
GridCacheSharedContext<K,V> ctx)
Gets subject ID by transaction.
|
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx<K,V> tx,
long timeout)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
boolean |
GridCacheSharedContext.txCompatible(IgniteInternalTx<K,V> tx,
Iterable<Integer> activeCacheIds,
GridCacheContext<K,V> cacheCtx) |
void |
GridCacheStoreManager.txEnd(IgniteInternalTx tx,
boolean commit) |
static String |
GridCacheUtils.txString(IgniteInternalTx tx) |
void |
GridCacheEntryEx.txUnlock(IgniteInternalTx<K,V> tx)
Unlocks acquired lock.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedTxRemoteAdapter<K,V>
Transaction created by system implicitly on remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<IgniteInternalTx> |
GridDistributedTxRemoteAdapter.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteInternalFuture<IgniteInternalTx<K,V>> |
GridDistributedTxRemoteAdapter.prepareAsync()
Prepare stage.
|
IgniteInternalFuture<IgniteInternalTx> |
GridDistributedTxRemoteAdapter.rollbackAsync()
Asynchronously rollback this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDistributedCacheEntry.tmLock(IgniteInternalTx<K,V> tx,
long timeout)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridDistributedCacheEntry.txUnlock(IgniteInternalTx<K,V> tx)
Unlocks acquired lock.
|
| Constructor and Description |
|---|
GridCacheCommittedTxInfo(IgniteInternalTx<K,V> tx) |
GridCacheOptimisticCheckPreparedTxFuture(GridCacheSharedContext<K,V> cctx,
IgniteInternalTx<K,V> tx,
UUID failedNodeId,
Map<UUID,Collection<UUID>> txNodes) |
GridCacheOptimisticCheckPreparedTxRequest(IgniteInternalTx<K,V> tx,
int txNum,
IgniteUuid futId,
IgniteUuid miniId) |
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) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtTxLocal<K,V>
Replicated user transaction.
|
class |
GridDhtTxLocalAdapter<K,V>
Replicated user transaction.
|
class |
GridDhtTxRemote<K,V>
Transaction created by system implicitly on remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteInternalFuture<IgniteInternalTx<K,V>> |
GridDhtTxLocal.prepareAsync()
Prepare stage.
|
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.
|
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.rollbackAsync()
Asynchronously rollback this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtTxPrepareFuture.onDone(IgniteInternalTx<K,V> tx0,
Throwable err)
Callback to notify that future is finished.
|
boolean |
GridDhtTxFinishFuture.onDone(IgniteInternalTx tx,
Throwable err)
Callback to notify that future is finished.
|
boolean |
GridDhtCacheEntry.tmLock(IgniteInternalTx<K,V> tx,
long timeout)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearTxLocal<K,V>
Replicated user transaction.
|
class |
GridNearTxRemote<K,V>
Transaction created by system implicitly on remote nodes.
|
| 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<K,V>> |
GridNearTxLocal.prepareAsync()
Prepare stage.
|
IgniteInternalFuture<IgniteInternalTx<K,V>> |
GridNearTxLocal.prepareAsyncLocal(Collection<IgniteTxEntry<K,V>> reads,
Collection<IgniteTxEntry<K,V>> writes,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups,
IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb)
Prepares next batch of entries in dht transaction.
|
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.rollbackAsync()
Asynchronously rollback this transaction.
|
IgniteInternalFuture<IgniteInternalTx> |
GridNearTxLocal.rollbackAsyncLocal()
Rolls back local part of colocated transaction.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridNearCacheAdapter.loadAsync(IgniteInternalTx tx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializePortable,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean skipVal) |
boolean |
GridNearCacheEntry.loadedValue(IgniteInternalTx tx,
UUID primaryNodeId,
V val,
byte[] valBytes,
GridCacheVersion ver,
GridCacheVersion dhtVer,
GridCacheVersion expVer,
long ttl,
long expireTime,
boolean evt,
long topVer,
UUID subjId) |
boolean |
GridNearTxPrepareFuture.onDone(IgniteInternalTx<K,V> t,
Throwable err)
Callback to notify that future is finished.
|
boolean |
GridNearTxFinishFuture.onDone(IgniteInternalTx tx,
Throwable err)
Callback to notify that future is finished.
|
protected V |
GridNearCacheEntry.readThrough(IgniteInternalTx<K,V> tx,
K key,
boolean reload,
UUID subjId,
String taskName) |
IgniteInternalFuture<Object> |
GridNearCacheAdapter.readThroughAllAsync(Collection<? extends K> keys,
boolean reload,
boolean skipVals,
IgniteInternalTx<K,V> tx,
UUID subjId,
String taskName,
IgniteBiInClosure<K,V> vis) |
| Constructor and Description |
|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx<K,V> tx,
long timeout)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridLocalCacheEntry.txUnlock(IgniteInternalTx<K,V> tx)
Unlocks lock if it is currently owned.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
IgniteTxLocalEx<K,V>
Local transaction API.
|
interface |
IgniteTxRemoteEx<K,V>
Local transaction API.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteTxAdapter<K,V>
Managed transaction adapter.
|
class |
IgniteTxLocalAdapter<K,V>
Transaction adapter for cache transactions.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends IgniteInternalTx<K,V>> |
IgniteTxManager.nearTx(GridCacheVersion txId) |
<T extends IgniteInternalTx<K,V>> |
IgniteTxManager.onCreated(T tx) |
<T extends IgniteInternalTx<K,V>> |
IgniteTxManager.tx(GridCacheVersion txId) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx<K,V> |
IgniteTxManager.localTxForRecovery(GridCacheVersion nearXidVer,
boolean markFinalizing)
Gets local transaction for pessimistic tx recovery.
|
IgniteInternalTx<K,V> |
IgniteTxManager.localTxx() |
IgniteInternalTx<K,V> |
TransactionProxyImpl.tx() |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
IgniteInternalTx<K,V> |
IgniteTxManager.txx() |
IgniteInternalTx<K,V> |
IgniteTxManager.txx(GridCacheVersion txId) |
IgniteInternalTx |
IgniteTxManager.userTx() |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxManager.addAlternateVersion(GridCacheVersion ver,
IgniteInternalTx<K,V> tx) |
boolean |
IgniteTxManager.addCommittedTx(IgniteInternalTx<K,V> tx) |
boolean |
IgniteTxManager.addRolledbackTx(IgniteInternalTx<K,V> tx) |
void |
IgniteTxManager.commitTx(IgniteInternalTx<K,V> tx)
Commits a transaction.
|
void |
IgniteTxManager.finishOptimisticTxOnRecovery(IgniteInternalTx<K,V> tx,
boolean commit)
Commits or rolls back prepared transaction.
|
void |
IgniteTxManager.finishPessimisticTxOnRecovery(IgniteInternalTx<K,V> tx,
GridCacheCommittedTxInfo<K,V> commitInfo)
Commits or rolls back pessimistic transaction.
|
boolean |
IgniteTxManager.isCompleted(IgniteInternalTx<K,V> tx) |
boolean |
IgniteTxManager.onStarted(IgniteInternalTx<K,V> tx)
Transaction start callback (has to do with when any operation was
performed on this transaction).
|
void |
IgniteTxManager.onTxStateChange(TransactionState prevState,
TransactionState newState,
IgniteInternalTx tx) |
void |
IgniteTxManager.prepareTx(IgniteInternalTx<K,V> tx)
Handles prepare stage of 2PC.
|
void |
IgniteTxManager.removeCommittedTx(IgniteInternalTx<K,V> tx) |
void |
IgniteTxManager.rollbackTx(IgniteInternalTx<K,V> tx)
Rolls back a transaction.
|
boolean |
IgniteTxManager.salvageTx(IgniteInternalTx<K,V> tx)
Invalidates transaction.
|
void |
IgniteTxManager.txContext(IgniteInternalTx tx) |
void |
IgniteTxManager.uncommitTx(IgniteInternalTx<K,V> tx)
Tries to minimize damage from partially-committed transaction.
|
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
javax.cache.processor.EntryProcessor<K,V,?> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
long ttl,
long drExpireTime,
GridCacheEntryEx<K,V> entry,
GridCacheVersion drVer)
This constructor is meant for remote transactions.
|
TransactionProxyImpl(IgniteInternalTx<K,V> tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
DataStructuresProcessor.onTxCommitted(IgniteInternalTx<K,V> tx)
Transaction committed callback for transaction manager.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015