| Modifier and Type | Method and Description |
|---|---|
IgniteTxKey |
GridCacheEntryEx.txKey() |
IgniteTxKey |
GridCacheMapEntry.txKey() |
IgniteTxKey |
GridCacheContext.txKey(KeyCacheObject key) |
| Modifier and Type | Field and Description |
|---|---|
protected Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.readMap
Read set.
|
protected Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.writeMap
Write map.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteTxKey |
GridDistributedTxPrepareRequest.groupLockKey() |
IgniteTxKey |
GridDistributedTxFinishRequest.groupLockKey() |
IgniteTxKey |
GridDistributedLockRequest.groupLockKey() |
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteTxKey,GridCacheVersion> |
GridDistributedTxPrepareRequest.dhtVersions() |
Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.readMap() |
Set<IgniteTxKey> |
GridDistributedTxRemoteAdapter.readSet() |
Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.writeMap() |
Set<IgniteTxKey> |
GridDistributedTxRemoteAdapter.writeSet() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxPrepareRequest.addDhtVersion(IgniteTxKey key,
GridCacheVersion dhtVer)
Adds version to be verified on remote node.
|
void |
GridDistributedTxRemoteAdapter.clearEntry(IgniteTxKey key)
Clears entry from transaction as it never happened.
|
IgniteTxEntry |
GridDistributedTxRemoteAdapter.entry(IgniteTxKey key) |
void |
GridDistributedTxRemoteAdapter.groupLockKey(IgniteTxKey key)
Adds group lock key to remote transaction.
|
boolean |
GridDistributedTxRemoteAdapter.hasWriteKey(IgniteTxKey key) |
boolean |
GridDistributedTxRemoteAdapter.removed(IgniteTxKey key)
Checks whether given key has been removed within transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxMapping.evictReaders(Collection<IgniteTxKey> keys) |
| 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,
GridIoPolicy plc,
boolean syncCommit,
boolean syncRollback,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
IgniteTxKey grpLockKey) |
GridDistributedTxPrepareRequest(IgniteInternalTx tx,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
IgniteTxKey grpLockKey,
boolean partLock,
Map<UUID,Collection<UUID>> txNodes,
boolean onePhaseCommit) |
GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx,
UUID nodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxKey> |
GridDhtTxPrepareResponse.nearEvicted() |
Collection<IgniteTxKey> |
GridDhtLockResponse.nearEvicted() |
Map<IgniteTxKey,GridCacheVersion> |
GridDhtTxPrepareRequest.owned() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
CacheObject val,
Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl) |
void |
GridDhtTxPrepareRequest.owned(IgniteTxKey key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtTxLocalAdapter.addGroupTxMapping(Collection<IgniteTxKey> keys)
Adds key mapping to transaction.
|
void |
GridDhtTxPrepareResponse.nearEvicted(Collection<IgniteTxKey> nearEvicted) |
void |
GridDhtLockResponse.nearEvicted(Collection<IgniteTxKey> nearEvicted) |
IgniteInternalFuture<IgniteInternalTx> |
GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry> reads,
Iterable<IgniteTxEntry> writes,
Map<IgniteTxKey,GridCacheVersion> verMap,
long msgId,
IgniteUuid nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups,
IgniteInClosure<GridNearTxPrepareResponse> completeCb)
Prepares next batch of entries in dht transaction.
|
| Constructor and Description |
|---|
GridDhtLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion lockVer,
AffinityTopologyVersion 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,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
GridIoPolicy plc,
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 cctx,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
IgniteUuid nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
GridIoPolicy plc,
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 cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
GridIoPolicy plc,
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,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
IgniteTxKey grpLockKey,
boolean partLock,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash) |
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
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 ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
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 and Description |
|---|
GridDhtTxPrepareFuture(GridCacheSharedContext cctx,
GridDhtTxLocalAdapter tx,
IgniteUuid nearMiniId,
Map<IgniteTxKey,GridCacheVersion> dhtVerMap,
boolean last,
boolean retVal,
Collection<UUID> lastBackups,
IgniteInClosure<GridNearTxPrepareResponse> completeCb) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxKey> |
GridNearTxRemote.evicted() |
Collection<IgniteTxKey> |
GridNearTxPrepareResponse.filterFailedKeys() |
Map<IgniteTxKey,CacheVersionedValue> |
GridNearTxPrepareResponse.ownedValues() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
GridCacheVersion drVer) |
void |
GridNearTxRemote.addEvicted(IgniteTxKey key)
Adds evicted key bytes to evicted collection.
|
void |
GridNearTxLocal.addKeyMapping(IgniteTxKey key,
ClusterNode node)
Adds key mapping to dht mapping.
|
void |
GridNearTxPrepareResponse.addOwnedValue(IgniteTxKey key,
GridCacheVersion ver,
CacheObject val)
Adds owned value.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
boolean |
GridNearTxPrepareResponse.hasOwnedValue(IgniteTxKey key) |
GridCacheVersion |
GridNearTxRemote.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridNearTxLocal.addGroupTxMapping(Collection<IgniteTxKey> keys)
Adds key mapping to transaction.
|
void |
GridNearTxPrepareResponse.filterFailedKeys(Collection<IgniteTxKey> filterFailedKeys) |
void |
GridNearTxRemote.ownedVersions(Map<IgniteTxKey,GridCacheVersion> vers)
Adds owned versions to map.
|
| Constructor and Description |
|---|
GridNearLockRequest(int cacheId,
AffinityTopologyVersion topVer,
UUID nodeId,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean implicitTx,
boolean implicitSingleTx,
boolean isRead,
boolean retVal,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean syncCommit,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash,
long accessTtl) |
GridNearTxLocal(GridCacheSharedContext ctx,
boolean implicit,
boolean implicitSingle,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
IgniteInternalTx tx,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> 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 ctx,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(GridCacheSharedContext ctx,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteTxKey |
IgniteTxAdapter.grpLockKey
Group lock key, if any.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxLocalAdapter.txMap
Per-transaction read map.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteTxKey |
IgniteInternalTx.groupLockKey() |
IgniteTxKey |
IgniteTxAdapter.groupLockKey() |
IgniteTxKey |
IgniteTxEntry.txKey() |
| Modifier and Type | Method and Description |
|---|---|
Set<Map.Entry<IgniteTxKey,IgniteTxEntry>> |
IgniteTxMap.entrySet() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxLocalAdapter.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteInternalTx.readMap() |
Set<IgniteTxKey> |
IgniteTxLocalAdapter.readSet() |
Set<IgniteTxKey> |
IgniteInternalTx.readSet() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxLocalAdapter.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteInternalTx.writeMap() |
Set<IgniteTxKey> |
IgniteTxLocalAdapter.writeSet() |
Set<IgniteTxKey> |
IgniteInternalTx.writeSet() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
protected boolean |
IgniteTxAdapter.checkInternal(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxLocalAdapter.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteInternalTx.entry(IgniteTxKey key) |
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
long |
IgniteTxLocalAdapter.entryExpireTime(IgniteTxKey key) |
long |
IgniteTxLocalAdapter.entryTtl(IgniteTxKey key) |
boolean |
IgniteTxLocalAdapter.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteInternalTx.hasWriteKey(IgniteTxKey key) |
IgniteTxLocalAdapter |
IgniteTxManager.newTx(boolean implicit,
boolean implicitSingle,
GridCacheContext sysCacheCtx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock) |
GridCacheVersion |
IgniteInternalTx.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
IgniteTxAdapter.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
boolean |
IgniteTxLocalAdapter.removed(IgniteTxKey key)
Checks whether given key has been removed within transaction.
|
boolean |
IgniteInternalTx.removed(IgniteTxKey key)
Checks whether given key has been removed within transaction.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
IgniteTxLocalAdapter.addGroupTxMapping(Collection<IgniteTxKey> keys)
Adds key mapping to transaction.
|
| Constructor and Description |
|---|
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
GridIoPolicy plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
| Constructor and Description |
|---|
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap,
IgnitePredicate<IgniteTxEntry> filter) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015