| Package | Description |
|---|---|
| org.gridgain.grid.cache |
Contains main Data Grid APIs.
|
| org.gridgain.grid.cache.store |
Contains cache store interfaces.
|
| org.gridgain.grid.cache.store.jdbc |
Contains reference JDBC-based cache store implementation.
|
| org.gridgain.grid.kernal.processors.cache | |
| org.gridgain.grid.kernal.processors.cache.distributed | |
| org.gridgain.grid.kernal.processors.cache.distributed.dht | |
| org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated | |
| org.gridgain.grid.kernal.processors.cache.distributed.near |
| Modifier and Type | Method and Description |
|---|---|
GridCacheTx |
GridCacheProjection.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
GridCacheTx |
GridCacheProjection.txStart()
Starts transaction with default isolation, concurrency, timeout, and invalidation policy.
|
GridCacheTx |
GridCacheProjection.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheProjection.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheProjection.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProjection.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridCacheTx> |
GridCacheTx.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheTxSynchronization.onStateChanged(GridCacheTxState prevState,
GridCacheTxState newState,
GridCacheTx tx)
State change callback for transaction.
|
| Modifier and Type | Method and Description |
|---|---|
V |
GridCacheLoadOnlyStoreAdapter.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
V |
GridCacheStore.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
void |
GridCacheStore.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
void |
GridCacheStoreAdapter.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
void |
GridCacheLoadOnlyStoreAdapter.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheStore.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheStore.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheStoreAdapter.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
void |
GridCacheStore.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheStore.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheStoreAdapter.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
void |
GridCacheLoadOnlyStoreAdapter.txEnd(GridCacheTx tx,
boolean commit)
Tells store to commit or rollback a transaction depending on the value of the
'commit'
parameter. |
void |
GridCacheStore.txEnd(GridCacheTx tx,
boolean commit)
Tells store to commit or rollback a transaction depending on the value of the
'commit'
parameter. |
void |
GridCacheStoreAdapter.txEnd(GridCacheTx tx,
boolean commit)
Default empty implementation for ending transactions.
|
| Modifier and Type | Method and Description |
|---|---|
V |
GridCacheJdbcBlobStore.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
void |
GridCacheJdbcBlobStore.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheJdbcBlobStore.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
void |
GridCacheJdbcBlobStore.txEnd(GridCacheTx tx,
boolean commit)
Default empty implementation for ending transactions.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridCacheTxEx<K,V>
Transaction managed by cache (
'Ex' stands for external). |
interface |
GridCacheTxLocalEx<K,V>
Local transaction API.
|
interface |
GridCacheTxProxy
Marker interface for transaction proxy.
|
interface |
GridCacheTxRemoteEx<K,V>
Local transaction API.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheTxAdapter<K,V>
Managed transaction adapter.
|
class |
GridCacheTxLocalAdapter<K,V>
Transaction adapter for cache transactions.
|
class |
GridCacheTxProxyImpl<K,V>
Cache transaction proxy.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheTx |
GridCacheProjectionImpl.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
GridCacheTx |
GridCacheAdapter.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
GridCacheTx |
GridCacheProxyImpl.tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
GridCacheTx |
GridCacheProjectionImpl.txStart()
Starts transaction with default isolation, concurrency, timeout, and invalidation policy.
|
GridCacheTx |
GridCacheAdapter.txStart()
Starts transaction with default isolation, concurrency, timeout, and invalidation policy.
|
GridCacheTx |
GridCacheProxyImpl.txStart()
Starts transaction with default isolation, concurrency, timeout, and invalidation policy.
|
GridCacheTx |
GridCacheProjectionImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheAdapter.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheProxyImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheProjectionImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheAdapter.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheProxyImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheProjectionImpl.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheAdapter.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProxyImpl.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
static GridCacheTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
GridCacheProjection prj,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation) |
GridCacheTx |
GridCacheProjectionImpl.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheAdapter.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheProxyImpl.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheTxManager.userTx() |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridCacheTx> |
GridCacheTxProxyImpl.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<GridCacheTx> |
GridCacheTxAdapter.finishFuture() |
GridFuture<GridCacheTx> |
GridCacheTxEx.finishFuture() |
GridFuture<GridCacheTx> |
GridCacheTxEx.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
static GridClosure<GridCacheTx,GridUuid> |
GridCacheUtils.tx2xid() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheEventManager.addEvent(int part,
K key,
GridCacheTx tx,
GridCacheMvccCandidate<K> owner,
int type,
V newVal,
boolean hasNewVal,
V oldVal,
boolean hasOldVal,
UUID subjId) |
void |
GridCacheEventManager.addEvent(int part,
K key,
UUID nodeId,
GridCacheTx tx,
GridCacheMvccCandidate<K> owner,
int type,
V newVal,
boolean hasNewVal,
V oldVal,
boolean hasOldVal,
UUID subjId) |
V |
GridCacheWriteBehindStore.load(GridCacheTx tx,
K key)
Loads value for the key from underlying persistent storage.
|
void |
GridCacheWriteBehindStore.loadAll(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> c)
Loads all values for given keys and passes every value to the provided closure.
|
boolean |
GridCacheStoreManager.loadAllFromStore(GridCacheTx tx,
Collection<? extends K> keys,
GridBiInClosure<K,V> vis)
Loads data from persistent store.
|
V |
GridCacheStoreManager.loadFromStore(GridCacheTx tx,
K key)
Loads data from persistent store.
|
void |
GridCacheTxManager.onTxStateChange(GridCacheTxState prevState,
GridCacheTxState newState,
GridCacheTx tx) |
void |
GridCacheWriteBehindStore.put(GridCacheTx tx,
K key,
V val)
Stores a given value in persistent storage.
|
void |
GridCacheWriteBehindStore.putAll(GridCacheTx tx,
Map<? extends K,? extends V> map)
Stores given key value pairs in persistent storage.
|
boolean |
GridCacheStoreManager.putAllToStore(GridCacheTx tx,
Map<K,GridBiTuple<V,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManager.putToStore(GridCacheTx tx,
K key,
V val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
void |
GridCacheWriteBehindStore.remove(GridCacheTx tx,
K key)
Removes the value identified by given key from persistent storage.
|
void |
GridCacheWriteBehindStore.removeAll(GridCacheTx tx,
Collection<? extends K> keys)
Removes all vales identified by given keys from persistent storage.
|
boolean |
GridCacheStoreManager.removeAllFromStore(GridCacheTx tx,
Collection<? extends K> keys) |
boolean |
GridCacheStoreManager.removeFromStore(GridCacheTx tx,
K key) |
void |
GridCacheStoreManager.txEnd(GridCacheTx tx,
boolean commit) |
void |
GridCacheWriteBehindStore.txEnd(GridCacheTx tx,
boolean commit)
Tells store to commit or rollback a transaction depending on the value of the
'commit'
parameter. |
static String |
GridCacheUtils.txString(GridCacheTx tx) |
| Constructor and Description |
|---|
GridCacheTxProxyImpl(GridCacheTx tx,
GridCacheAdapter<K,V> cache,
GridCacheGateway gate) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedTxRemoteAdapter<K,V>
Transaction created by system implicitly on remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridCacheTx> |
GridDistributedTxRemoteAdapter.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<GridCacheTx> |
GridDistributedTxRemoteAdapter.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
| 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 |
|---|---|
GridFuture<GridCacheTx> |
GridDhtTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<GridCacheTx> |
GridDhtTransactionalCacheAdapter.commitTx(UUID nodeId,
GridNearTxFinishRequest<K,V> req) |
GridFuture<GridCacheTx> |
GridDhtTxLocal.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
GridFuture<GridCacheTx> |
GridDhtTransactionalCacheAdapter.rollbackTx(UUID nodeId,
GridNearTxFinishRequest<K,V> req) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtTxFinishFuture.onDone(GridCacheTx tx,
Throwable err)
Callback to notify that future is finished.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedTxLocal<K,V>
Colocated transaction.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridCacheTx> |
GridDhtColocatedTxLocal.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
GridFuture<GridCacheTx> |
GridDhtColocatedTxLocal.rollbackAsync()
TODO-gg-4004 Put rollback async on public API?
Asynchronously rollback this transaction.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtColocatedTxFinishFuture.onDone(GridCacheTx tx,
Throwable err)
Callback to notify that future is finished.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearTxRemote<K,V>
Transaction created by system implicitly on remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearTxFinishFuture.onDone(GridCacheTx tx,
Throwable err)
Callback to notify that future is finished.
|
Copyright © 2014. All rights reserved.