| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.dht.colocated | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.local | |
| org.apache.ignite.internal.processors.cache.transactions |
| Modifier and Type | Field and Description |
|---|---|
ConcurrentMap<KeyCacheObject,GridCacheMapEntry> |
GridCacheConcurrentMap.CacheMapHolder.map |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key) |
@Nullable GridCacheMapEntry |
GridNoStorageCacheMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
@Nullable GridCacheMapEntry |
GridCacheConcurrentMapImpl.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
@Nullable GridCacheMapEntry |
GridCacheConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
protected GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(@Nullable GridCacheConcurrentMap.CacheMapHolder hld,
GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
@Nullable GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
@Nullable GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
| Modifier and Type | Method and Description |
|---|---|
Iterable<GridCacheMapEntry> |
GridNoStorageCacheMap.entries(int cacheId,
CacheEntryPredicate... filter) |
Collection<GridCacheMapEntry> |
GridCacheConcurrentMapImpl.entries(int cacheId,
CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridCacheConcurrentMap.entries(int cacheId,
CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridNoStorageCacheMap.entrySet(int cacheId,
CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridCacheConcurrentMapImpl.entrySet(int cacheId,
CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridCacheConcurrentMap.entrySet(int cacheId,
CacheEntryPredicate... filter) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgniteCacheOffheapManager.containsKey(GridCacheMapEntry entry)
TODO: GG-10884, used on only from initialValue.
|
boolean |
IgniteCacheOffheapManagerImpl.containsKey(GridCacheMapEntry entry)
TODO: GG-10884, used on only from initialValue.
|
void |
GridCacheContext.decrementPublicSize(GridCacheMapEntry e) |
void |
GridCacheAdapter.decrementSize(GridCacheMapEntry e)
Decrements map public size.
|
void |
GridCacheContext.incrementPublicSize(GridCacheMapEntry e) |
void |
GridCacheAdapter.incrementSize(GridCacheMapEntry e)
Increments map public size.
|
boolean |
IgniteCacheOffheapManager.mvccApplyHistoryIfAbsent(GridCacheMapEntry entry,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
boolean |
IgniteCacheOffheapManagerImpl.mvccApplyHistoryIfAbsent(GridCacheMapEntry entry,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
boolean |
IgniteCacheOffheapManager.mvccInitialValue(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.mvccInitialValue(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
@Nullable MvccUpdateResult |
IgniteCacheOffheapManager.mvccLock(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot) |
@Nullable MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccLock(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot) |
@Nullable MvccUpdateResult |
IgniteCacheOffheapManager.mvccRemove(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHist,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccRemove(GridCacheMapEntry entry,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHistory,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal) |
void |
IgniteCacheOffheapManager.mvccRemoveAll(GridCacheMapEntry entry) |
void |
IgniteCacheOffheapManagerImpl.mvccRemoveAll(GridCacheMapEntry entry) |
MvccUpdateResult |
IgniteCacheOffheapManager.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
boolean |
IgniteCacheOffheapManager.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
@Nullable CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheMapEntry entry) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.read(GridCacheMapEntry entry) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheMetricsImpl.keyCollisionsInfo(Supplier<List<Map.Entry<GridCacheMapEntry,Integer>>> coll)
Set callback for tx key collisions detection.
|
| Constructor and Description |
|---|
CacheMapHolder(GridCacheContext cctx,
ConcurrentMap<KeyCacheObject,GridCacheMapEntry> map) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedCacheEntry
Entry for distributed (replicated/partitioned) cache.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtCacheEntry
Replicated cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheMapEntry |
GridCachePartitionedConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean touch) |
| Modifier and Type | Method and Description |
|---|---|
Iterable<GridCacheMapEntry> |
GridCachePartitionedConcurrentMap.entries(int cacheId,
CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridCachePartitionedConcurrentMap.entrySet(int cacheId,
CacheEntryPredicate... filter) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtDetachedCacheEntry
Detached cache entry.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearCacheEntry
Near cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheMapEntry |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridLocalCacheEntry
Cache entry for local caches.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxManager.pushCollidingKeysWithQueueSize(GridCacheMapEntry key,
int queueSize)
Collect queue size per key collisions info.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020