| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheMapEntry
Adapter for cache entry.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheEntryEx |
EvictableEntryImpl.cached
Cached entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
boolean touch) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
long topVer) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(Object key) |
protected GridCacheEntryEx |
GridCacheAdapter.entryExSafe(KeyCacheObject key,
long topVer) |
<V> GridCacheEntryEx |
GridCacheMvccCandidate.parent() |
GridCacheEntryEx |
GridCacheAdapter.peekEx(KeyCacheObject key) |
GridCacheEntryEx |
GridCacheAdapter.peekEx(Object key) |
| Modifier and Type | Method and Description |
|---|---|
Set<GridCacheEntryEx> |
GridCacheAdapter.allEntries() |
Set<GridCacheEntryEx> |
GridCacheConcurrentMap.allEntries0()
Gets all internal entry set, including
GridCacheInternal entries. |
Set<GridCacheEntryEx> |
GridCacheAdapter.entries() |
Set<GridCacheEntryEx> |
GridCacheConcurrentMap.entries0()
Internal entry set, excluding
GridCacheInternal entries. |
static IgniteClosure<GridCacheEntryEx,KeyCacheObject> |
GridCacheUtils.entry2Key() |
Iterator<GridCacheEntryEx> |
GridCacheConcurrentMap.stripedEntryIterator(int id,
int totalCnt)
Get striped entry iterator.
|
static <K,V> IgniteClosure<IgniteTxEntry,GridCacheEntryEx> |
GridCacheUtils.tx2entry() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle) |
GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
UUID nearNodeId,
GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc) |
GridCacheMvccCandidate |
GridCacheMvcc.addNearLocal(GridCacheEntryEx parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle)
Adds new near local lock candidate.
|
GridCacheMvccCandidate |
GridCacheMvcc.addRemote(GridCacheEntryEx parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle,
boolean nearLoc)
Adds new remote lock candidate (either near remote or dht remote).
|
boolean |
CacheEntryPredicateHasValue.apply(GridCacheEntryEx e)
Predicate body.
|
boolean |
CacheEntrySerializablePredicate.apply(GridCacheEntryEx e)
Predicate body.
|
boolean |
CacheEntryPredicateContainsValue.apply(GridCacheEntryEx e)
Predicate body.
|
boolean |
CacheEntryPredicateNoValue.apply(GridCacheEntryEx e)
Predicate body.
|
protected void |
GridCacheClearAllRunnable.clearEntry(GridCacheEntryEx e)
Clear entry from cache.
|
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx entry,
boolean deserializePortable,
CacheEntryPredicate... filter) |
protected IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean readThrough,
GridCacheEntryEx cached,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean forcePrimary,
IgniteCacheExpiryPolicy expiry,
boolean skipVals) |
boolean |
GridCacheContext.isAll(GridCacheEntryEx e,
CacheEntryPredicate[] p) |
<K1,V1> boolean |
GridCacheContext.isAll(GridCacheEntryEx e,
IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
boolean |
GridCacheContext.isAllLocked(GridCacheEntryEx e,
CacheEntryPredicate[] p) |
void |
GridCacheContext.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
abstract void |
GridCacheAdapter.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridCacheMvccFuture.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner) |
void |
GridCacheMvccCallback.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate prev,
GridCacheMvccCandidate owner)
Called when entry lock ownership changes.
|
void |
GridCacheMvccCandidate.parent(GridCacheEntryEx parent) |
protected CacheObject |
CacheEntryPredicateAdapter.peekVisibleValue(GridCacheEntryEx entry) |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheConcurrentMap.removeEntry(GridCacheEntryEx e)
Removes passed in entry if it presents in the map.
|
void |
GridCacheAdapter.removeEntry(GridCacheEntryEx entry) |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridCacheEvictionManager.touch(GridCacheEntryEx e,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
protected Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.iterator(Iterator<GridCacheEntryEx> it,
boolean deserializePortable) |
| Constructor and Description |
|---|
EvictableEntryImpl(GridCacheEntryEx cached) |
GridCacheMvccCandidate(GridCacheEntryEx parent,
UUID nodeId,
UUID otherNodeId,
GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedCacheEntry
Entry for distributed (replicated/partitioned) cache.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDistributedTxRemoteAdapter.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtCacheEntry
Replicated cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx |
GridDhtCacheAdapter.entryEx(KeyCacheObject key,
boolean touch) |
GridCacheEntryEx |
GridDhtCacheAdapter.entryEx(KeyCacheObject key,
long topVer) |
GridCacheEntryEx |
GridDhtCacheAdapter.entryExx(KeyCacheObject key,
long topVer,
boolean allowDetached,
boolean touch)
Gets or creates entry for given key.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
void |
GridDhtCacheAdapter.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridDhtLockFuture.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback for whenever entry lock ownership changes.
|
boolean |
GridDhtTxPrepareFuture.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner) |
boolean |
GridNoStorageCacheMap.removeEntry(GridCacheEntryEx e)
Removes passed in entry if it presents in the map.
|
protected void |
GridDhtTxLocal.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtAtomicCacheEntry
DHT atomic cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
V |
GridDhtAtomicCache.put(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridDhtAtomicCache.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedCacheEntry
Cache entry for colocated cache.
|
class |
GridDhtDetachedCacheEntry
Detached cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx |
GridDhtColocatedCache.entryExSafe(KeyCacheObject key,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearCacheEntry
Near cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
long topVer)
Gets cache entry for given key and topology version.
|
GridCacheEntryEx |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
boolean touch) |
GridCacheEntryEx |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e,
GridCacheVersion obsoleteVer,
long topVer) |
protected IgniteInternalFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
protected boolean |
GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx e,
long topVer) |
void |
GridNearAtomicCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
void |
GridNearTransactionalCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridNearTxPrepareFuture.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner) |
boolean |
GridNearLockFuture.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback for whenever entry lock ownership changes.
|
boolean |
GridNearTxLocal.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
boolean |
GridNearTxLocal.ownsLock(GridCacheEntryEx entry) |
boolean |
GridNearTxLocal.ownsLockUnsafe(GridCacheEntryEx entry) |
V |
GridNearAtomicCache.put(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
protected void |
GridNearTxLocal.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridLocalCacheEntry
Cache entry for local caches.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridLocalLockFuture.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridLocalAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
void |
GridLocalAtomicCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
V |
GridLocalAtomicCache.put(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx entry,
long ttl,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridLocalAtomicCache.remove(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx entry,
CacheEntryPredicate... filter)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryManager.onEntryExpired(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject oldVal) |
void |
CacheContinuousQueryManager.onEntryUpdated(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean preload) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx |
IgniteTxEntry.cached() |
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
long topVer)
Gets cache entry for given key and topology version.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteTxEntry |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
CacheObject val,
javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx entry,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
void |
IgniteTxEntry.cached(GridCacheEntryEx entry) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
protected <K,V> IgniteInternalFuture<Set<KeyCacheObject>> |
IgniteTxLocalAdapter.enlistWrite(GridCacheContext cacheCtx,
Collection<?> keys,
GridCacheEntryEx cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean implicit,
Map<?,?> lookup,
Map<?,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap,
Object[] invokeArgs,
boolean retval,
boolean lockOnly,
CacheEntryPredicate[] filter,
GridCacheReturn ret,
Collection<KeyCacheObject> enlisted,
Map<KeyCacheObject,GridCacheDrInfo> drPutMap,
Map<KeyCacheObject,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalEx.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects) |
boolean |
IgniteTxManager.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback invoked whenever a member of a transaction acquires
lock ownership.
|
boolean |
IgniteTxLocalAdapter.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
boolean |
IgniteInternalTx.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
boolean |
IgniteTxAdapter.ownsLock(GridCacheEntryEx entry) |
boolean |
IgniteInternalTx.ownsLock(GridCacheEntryEx entry) |
boolean |
IgniteTxAdapter.ownsLockUnsafe(GridCacheEntryEx entry) |
boolean |
IgniteInternalTx.ownsLockUnsafe(GridCacheEntryEx entry) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
protected void |
IgniteTxLocalAdapter.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx entry,
CacheEntryPredicate[] filters,
GridCacheVersion conflictVer)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
GridCacheVersion conflictVer)
This constructor is meant for remote transactions.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015