@Nullable GridCacheMvccCandidate |
GridCacheEntryEx.candidate(UUID nodeId,
long threadId) |
|
@Nullable GridCacheMvccCandidate |
GridCacheEntryEx.candidate(GridCacheVersion ver) |
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate |
GridCacheMapEntry.candidate(UUID nodeId,
long threadId) |
@Nullable GridCacheMvccCandidate |
GridCacheMapEntry.candidate(GridCacheVersion ver) |
Gets lock candidate for given lock ID.
|
protected void |
GridCacheMapEntry.checkObsolete() |
|
boolean |
GridCacheEntryEx.checkSerializableReadVersion(GridCacheVersion serReadVer) |
Checks if there was read/write conflict in serializable transaction.
|
boolean |
GridCacheMapEntry.checkSerializableReadVersion(GridCacheVersion serReadVer) |
Checks if there was read/write conflict in serializable transaction.
|
protected void |
GridCacheMapEntry.clearReader(UUID nodeId) |
|
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
@Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
|
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
|
long |
GridCacheEntryEx.expireTime() |
|
long |
GridCacheMapEntry.expireTime() |
boolean |
GridCacheEntryEx.hasLockCandidate(long threadId) |
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheEntryEx.hasLockCandidate(GridCacheVersion ver) |
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheMapEntry.hasLockCandidate(long threadId) |
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheMapEntry.hasLockCandidate(GridCacheVersion ver) |
Checks if the candidate is either owner or pending.
|
protected boolean |
GridCacheMapEntry.hasReaders() |
|
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
boolean primary) |
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
boolean primary,
@Nullable CacheDataRow row) |
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
boolean primary,
CacheDataRow row) |
Sets new value if current version is 0
|
CacheObject |
GridCacheEntryEx.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
|
CacheObject |
GridCacheMapEntry.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
|
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
|
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
@Nullable CacheObject |
GridCacheEntryEx.innerReload() |
Reloads entry from underlying storage.
|
@Nullable CacheObject |
GridCacheMapEntry.innerReload() |
Reloads entry from underlying storage.
|
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
|
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
@Nullable CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
|
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
boolean readRepairRecovery,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
|
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
boolean readRepairRecovery,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
boolean |
GridCacheEntryEx.isNew() |
Checks if entry is new assuming lock is held externally.
|
boolean |
GridCacheMapEntry.isNew() |
Checks if entry is new assuming lock is held externally.
|
boolean |
GridCacheEntryEx.isNewLocked() |
Checks if entry is new while holding lock.
|
boolean |
GridCacheMapEntry.isNewLocked() |
Checks if entry is new while holding lock.
|
@Nullable GridCacheMvccCandidate |
GridCacheEntryEx.localCandidate(long threadId) |
|
GridCacheMvccCandidate |
GridCacheMapEntry.localCandidate(long threadId) |
Collection<GridCacheMvccCandidate> |
GridCacheEntryEx.localCandidates(@Nullable GridCacheVersion... exclude) |
Gets all local candidates.
|
Collection<GridCacheMvccCandidate> |
GridCacheMapEntry.localCandidates(GridCacheVersion... exclude) |
Gets all local candidates.
|
@Nullable GridCacheMvccCandidate |
GridCacheEntryEx.localOwner() |
|
GridCacheMvccCandidate |
GridCacheMapEntry.localOwner() |
boolean |
GridCacheEntryEx.lockedBy(GridCacheVersion ver) |
|
boolean |
GridCacheMapEntry.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.lockedByAny(GridCacheVersion... exclude) |
|
boolean |
GridCacheMapEntry.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheEntryEx.lockedByThread() |
|
boolean |
GridCacheEntryEx.lockedByThread(long threadId) |
|
boolean |
GridCacheEntryEx.lockedByThread(long threadId,
GridCacheVersion exclude) |
|
boolean |
GridCacheMapEntry.lockedByThread() |
boolean |
GridCacheMapEntry.lockedByThread(long threadId) |
boolean |
GridCacheMapEntry.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheEntryEx.lockedLocally(GridCacheVersion lockVer) |
|
boolean |
GridCacheMapEntry.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheEntryEx.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
|
boolean |
GridCacheMapEntry.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheEntryEx.onTtlExpired(GridCacheVersion obsoleteVer) |
Callback from ttl processor to cache entry indicating that entry is expired.
|
boolean |
GridCacheMapEntry.onTtlExpired(GridCacheVersion obsoleteVer) |
Callback from ttl processor to cache entry indicating that entry is expired.
|
@Nullable CacheObject |
GridCacheEntryEx.peek() |
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy plc) |
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheMapEntry.peek() |
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy expiryPlc) |
Peeks into entry without loading value or updating statistics.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
|
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable GridCacheVersion serOrder,
@Nullable GridCacheVersion serReadVer,
boolean read) |
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
long |
GridCacheEntryEx.ttl() |
|
long |
GridCacheMapEntry.ttl() |
void |
GridCacheEntryEx.txUnlock(IgniteInternalTx tx) |
Unlocks acquired lock.
|
void |
GridCacheMapEntry.txUnlock(IgniteInternalTx tx) |
Unlocks acquired lock.
|
@Nullable CacheObject |
GridCacheEntryEx.unswap() |
|
@Nullable CacheObject |
GridCacheEntryEx.unswap(boolean needVal) |
Unswap ignoring flags.
|
@Nullable CacheObject |
GridCacheEntryEx.unswap(CacheDataRow row) |
|
CacheObject |
GridCacheMapEntry.unswap() |
@Nullable CacheObject |
GridCacheMapEntry.unswap(boolean needVal) |
Unswap ignoring flags.
|
protected @Nullable CacheDataRow |
GridCacheMapEntry.unswap(@Nullable CacheDataRow row,
boolean checkExpire) |
Unswaps an entry.
|
CacheObject |
GridCacheMapEntry.unswap(CacheDataRow row) |
void |
GridCacheEntryEx.updateIndex(SchemaIndexCacheVisitorClosure clo) |
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheMapEntry.updateIndex(SchemaIndexCacheVisitorClosure clo) |
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheEntryEx.updateTtl(@Nullable GridCacheVersion ver,
long ttl) |
|
void |
GridCacheEntryEx.updateTtl(GridCacheVersion ver,
IgniteCacheExpiryPolicy expiryPlc) |
|
void |
GridCacheMapEntry.updateTtl(@Nullable GridCacheVersion ver,
long ttl) |
void |
GridCacheMapEntry.updateTtl(GridCacheVersion ver,
IgniteCacheExpiryPolicy expiryPlc) |
CacheObject |
GridCacheEntryEx.valueBytes() |
|
@Nullable CacheObject |
GridCacheEntryEx.valueBytes(@Nullable GridCacheVersion ver) |
Gets cached serialized value bytes.
|
CacheObject |
GridCacheMapEntry.valueBytes() |
@Nullable CacheObject |
GridCacheMapEntry.valueBytes(@Nullable GridCacheVersion ver) |
Gets cached serialized value bytes.
|
GridCacheVersion |
GridCacheEntryEx.version() |
|
GridCacheVersion |
GridCacheMapEntry.version() |
<K,V> GridCacheVersionedEntryEx<K,V> |
GridCacheEntryEx.versionedEntry(boolean keepBinary) |
Create versioned entry for this cache entry.
|
GridCacheVersionedEntryEx |
GridCacheMapEntry.versionedEntry(boolean keepBinary) |
Create versioned entry for this cache entry.
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
@Nullable GridCacheVersion curVer,
@Nullable GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs) |
Sets new value if passed in version matches the current version
(used for read-through only).
|
EntryGetResult |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs) |
Sets new value if passed in version matches the current version
(used for read-through only).
|