| Modifier and Type | Method and Description |
|---|---|
Transaction |
IgniteTransactions.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
IgniteTransactions.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
| Modifier and Type | Field and Description |
|---|---|
static TransactionIsolation |
TransactionConfiguration.DFLT_TX_ISOLATION
Default transaction isolation level.
|
| Modifier and Type | Method and Description |
|---|---|
TransactionIsolation |
TransactionConfiguration.getDefaultTxIsolation()
Default cache transaction isolation to use when one is not explicitly
specified.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TransactionConfiguration.setDefaultTxIsolation(TransactionIsolation dfltIsolation)
Sets default transaction isolation.
|
| 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) |
Transaction |
IgniteTransactionsEx.txStartSystem(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> void |
GridCacheUtils.inTx(CacheProjection<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<CacheProjection<K,V>> clo)
Execute closure inside cache transaction.
|
static <K,V> void |
GridCacheUtils.inTx(Ignite ignite,
IgniteCache<K,V> cache,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
IgniteInClosureX<IgniteCache<K,V>> clo)
Execute closure inside cache transaction.
|
abstract IgniteInternalFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
Transaction |
GridCacheProjectionImpl.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
CacheProjection.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
GridCacheProxyImpl.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
GridCacheAdapter.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
GridCacheProjectionImpl.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
Transaction |
CacheProjection.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
Transaction |
GridCacheProxyImpl.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
Transaction |
GridCacheAdapter.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
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 |
|---|---|
TransactionIsolation |
GridDistributedLockRequest.isolation() |
TransactionIsolation |
GridDistributedTxPrepareRequest.isolation() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean isInvalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| 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) |
GridDistributedTxRemoteAdapter(GridCacheSharedContext<K,V> ctx,
UUID nodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
| Modifier and Type | Method and Description |
|---|---|
TransactionIsolation |
GridDhtTxFinishRequest.isolation() |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridDhtFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Acquires locks in partitioned cache.
|
| Constructor and Description |
|---|
GridDhtLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion lockVer,
long 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,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
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<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
IgniteUuid nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
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<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
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<K,V> ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
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.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
This is an entry point to pessimistic locking within transaction.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
protected IgniteInternalFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Constructor and Description |
|---|
GridNearLockRequest(int cacheId,
long topVer,
UUID nodeId,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean implicitTx,
boolean implicitSingleTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean syncCommit,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash,
long accessTtl) |
GridNearTxLocal(GridCacheSharedContext<K,V> ctx,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
GridNearTxRemote(GridCacheSharedContext<K,V> ctx,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry<K,V>> writeEntries,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(GridCacheSharedContext<K,V> ctx,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
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 | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Field and Description |
|---|---|
protected TransactionIsolation |
IgniteTxAdapter.isolation
Isolation.
|
| Modifier and Type | Method and Description |
|---|---|
TransactionIsolation |
IgniteTxAdapter.isolation()
Cache transaction isolation level.
|
TransactionIsolation |
IgniteInternalTx.isolation()
Cache transaction isolation level.
|
TransactionIsolation |
TransactionProxyImpl.isolation()
Cache transaction isolation level.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteTxLocalAdapter<K,V> |
IgniteTxManager.newTx(boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock) |
Transaction |
IgniteTransactionsImpl.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
IgniteTransactionsImpl.txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteTransactionsImpl.txStartEx(GridCacheContext ctx,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize) |
Transaction |
IgniteTransactionsImpl.txStartSystem(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
| Constructor and Description |
|---|
IgniteTxAdapter(GridCacheSharedContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxAdapter(GridCacheSharedContext<K,V> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize,
IgniteTxKey grpLockKey,
UUID subjId,
int taskNameHash) |
IgniteTxLocalAdapter(GridCacheSharedContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
int txSize,
IgniteTxKey grpLockKey,
boolean partLock,
UUID subjId,
int taskNameHash) |
| Modifier and Type | Method and Description |
|---|---|
TransactionIsolation |
VisorCacheDefaultConfiguration.txIsolation() |
| Modifier and Type | Method and Description |
|---|---|
void |
VisorCacheDefaultConfiguration.txIsolation(TransactionIsolation txIsolation) |
| Modifier and Type | Method and Description |
|---|---|
TransactionIsolation |
VisorTransactionConfiguration.defaultTxIsolation() |
| Modifier and Type | Method and Description |
|---|---|
void |
VisorTransactionConfiguration.defaultTxIsolation(TransactionIsolation dfltIsolation) |
| Modifier and Type | Method and Description |
|---|---|
static TransactionIsolation |
TransactionIsolation.fromOrdinal(int ord)
Efficiently gets enumerated value from its ordinal.
|
TransactionIsolation |
Transaction.isolation()
Cache transaction isolation level.
|
static TransactionIsolation |
TransactionIsolation.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TransactionIsolation[] |
TransactionIsolation.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015