| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheMapEntry
Adapter for cache entry.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheEntryEx |
CacheEvictableEntryImpl.cached
Cached entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
boolean touch) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(Object key) |
protected GridCacheEntryEx |
GridCacheAdapter.entryExSafe(KeyCacheObject key,
AffinityTopologyVersion 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.
|
| 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 |
CacheEntrySerializablePredicate.apply(GridCacheEntryEx e)
Predicate body.
|
boolean |
CacheEntryPredicateHasValue.apply(GridCacheEntryEx e)
Predicate body.
|
boolean |
CacheEntryPredicateNoValue.apply(GridCacheEntryEx e)
Predicate body.
|
boolean |
CacheEntryPredicateContainsValue.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) |
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,
boolean canRemap) |
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 canRemap) |
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) |
boolean |
GridCacheConcurrentMap.removeEntry(GridCacheEntryEx e)
Removes passed in entry if it presents in the map.
|
void |
GridCacheAdapter.removeEntry(GridCacheEntryEx entry) |
void |
GridCacheEvictionManager.touch(GridCacheEntryEx e,
AffinityTopologyVersion 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 |
|---|
CacheEvictableEntryImpl(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.
|
class |
GridDhtOffHeapCacheEntry
Replicated cache entry for off-heap tiered or off-heap values modes.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx |
GridDhtCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridCacheEntryEx |
GridDhtCacheAdapter.entryEx(KeyCacheObject key,
boolean touch) |
GridCacheEntryEx |
GridDhtCacheAdapter.entryExx(KeyCacheObject key,
AffinityTopologyVersion 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,
boolean canRemap)
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.
|
class |
GridDhtAtomicOffHeapCacheEntry
DHT atomic cache entry for off-heap tiered or off-heap values modes.
|
| 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,
boolean canRemap)
This method is used internally.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedCacheEntry
Cache entry for colocated cache.
|
class |
GridDhtColocatedOffHeapCacheEntry
Cache entry for colocated cache for off-heap tiered or off-heap values modes.
|
class |
GridDhtDetachedCacheEntry
Detached cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx |
GridDhtColocatedCache.entryExSafe(KeyCacheObject key,
AffinityTopologyVersion 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,
boolean canRemap)
This method is used internally.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearCacheEntry
Near cache entry.
|
class |
GridNearOffHeapCacheEntry
Near cache entry for off-heap tiered or off-heap values modes.
|
| 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,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
GridCacheEntryEx |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridCacheEntryEx |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
boolean touch) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e,
GridCacheVersion obsoleteVer,
AffinityTopologyVersion 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,
boolean canRemap) |
IgniteInternalFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals,
boolean canRemap) |
protected boolean |
GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx e,
AffinityTopologyVersion topVer) |
void |
GridNearAtomicCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
void |
GridNearTransactionalCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridNearOptimisticTxPrepareFuture.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) |
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,
boolean canRemap) |
void |
GridLocalAtomicCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
| 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,
AffinityTopologyVersion 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,
boolean skipStore) |
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,
boolean skipStore)
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,
boolean skipStore) |
<K,V> IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys,
GridCacheEntryEx cached,
boolean deserializePortable,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore) |
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 |
IgniteTxManager.onOwnerChanged(GridCacheEntryEx entry,
GridCacheMvccCandidate owner)
Callback invoked whenever a member of a transaction acquires
lock ownership.
|
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,
boolean skipStore)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
GridCacheVersion conflictVer,
boolean skipStore)
This constructor is meant for remote transactions.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.4.0 Release Date : September 24 2015