| Modifier and Type | Class and Description |
|---|---|
class |
BinaryEnumObjectImpl
Binary enum object.
|
class |
BinaryObjectImpl
Binary object implementation.
|
class |
BinaryObjectOffheapImpl
Binary object implementation over offheap memory
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
BinaryObjectOffheapImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
BinaryEnumObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
BinaryObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
| Modifier and Type | Field and Description |
|---|---|
protected @Nullable CacheObject |
DataEntry.val
Cache object value.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
DataEntry.value() |
CacheObject |
LazyDataEntry.value() |
CacheObject |
LazyMvccDataEntry.value() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
MvccDataEntry(int cacheId,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
UnwrapDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary) |
UnwrapMvccDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
KeyCacheObject |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheObjectAdapter |
class |
CacheObjectByteArrayImpl
Cache object over byte array.
|
class |
CacheObjectImpl |
class |
KeyCacheObjectImpl |
| Modifier and Type | Field and Description |
|---|---|
protected CacheObject |
GridCacheMapEntry.val
Value.
|
protected CacheObject |
CacheLazyEntry.valObj
Cache object value.
|
| Modifier and Type | Method and Description |
|---|---|
static @Nullable CacheObject |
GridCacheUtils.failed(boolean err) |
static @Nullable CacheObject |
GridCacheUtils.failed(boolean err,
CacheObject val) |
CacheObject |
GridCacheEntryEx.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
CacheObject |
GridCacheMapEntry.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
@Nullable CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
@Nullable CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
@Nullable CacheObject |
GridCacheEntryEx.mvccPeek(boolean onheapOnly)
Retrieves the last committed MVCC entry version.
|
@Nullable CacheObject |
GridCacheMapEntry.mvccPeek(boolean onheapOnly)
Retrieves the last committed MVCC entry version.
|
CacheObject |
GridCacheUpdateTxResult.newValue() |
@Nullable CacheObject |
GridCacheUpdateAtomicResult.newValue() |
CacheObject |
GridCacheUpdateTxResult.oldValue() |
@Nullable CacheObject |
GridCacheUpdateAtomicResult.oldValue() |
@Nullable CacheObject |
GridCacheEntryEx.peek()
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheMapEntry.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(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheEntryEx.peekVisibleValue()
Peeks value provided to public API entries and to entry filters.
|
@Nullable CacheObject |
GridCacheMapEntry.peekVisibleValue()
Peeks value provided to public API entries and to entry filters.
|
protected @Nullable CacheObject |
CacheEntryPredicateAdapter.peekVisibleValue(GridCacheEntryEx entry) |
CacheObject |
CacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
KeyCacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
CacheObjectByteArrayImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
CacheObject.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
@Nullable CacheObject |
GridCacheUpdateTxResult.prevValue() |
CacheObject |
GridCacheEntryEx.rawGet() |
CacheObject |
GridCacheMapEntry.rawGet() |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
CacheObject |
CacheInvokeDirectResult.result() |
@Nullable CacheObject |
GridCacheContext.toCacheObject(@Nullable Object obj) |
@Nullable CacheObject |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap() |
@Nullable CacheObject |
GridCacheEntryEx.unswap(boolean needVal)
Unswap ignoring flags.
|
@Nullable CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswap ignoring flags.
|
@Nullable CacheObject |
GridCacheEntryEx.unswap(CacheDataRow row) |
CacheObject |
GridCacheMapEntry.unswap(CacheDataRow row) |
CacheObject |
GridCacheEntryInfo.value() |
CacheObject |
GridCacheFilterFailedException.value() |
CacheObject |
GridCacheEntryEx.valueBytes() |
CacheObject |
GridCacheMapEntry.valueBytes() |
@Nullable CacheObject |
GridCacheEntryEx.valueBytes(@Nullable GridCacheVersion ver)
Gets cached serialized value bytes.
|
@Nullable CacheObject |
GridCacheMapEntry.valueBytes(@Nullable GridCacheVersion ver)
Gets cached serialized value bytes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheGroupContext.addCacheEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
boolean keepBinary) |
void |
CacheGroupContext.addCacheEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
@Nullable IgniteInternalTx tx,
@Nullable GridCacheMvccCandidate owner,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
@Nullable IgniteInternalTx tx,
@Nullable GridCacheMvccCandidate owner,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
@Nullable GridCacheMvccCandidate owner,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
@Nullable GridCacheMvccCandidate owner,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID nodeId,
@Nullable IgniteInternalTx tx,
GridCacheMvccCandidate owner,
int type,
CacheObject newVal,
boolean hasNewVal,
CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
@Nullable IgniteInternalTx tx,
@Nullable String txLbl,
@Nullable Object lockId,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
@Nullable String cloClsName,
@Nullable String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
@Nullable IgniteInternalTx tx,
@Nullable String txLbl,
@Nullable Object lockId,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
@Nullable String cloClsName,
@Nullable String taskName,
boolean keepBinary) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
@Nullable EntryGetResult getRes,
GridCacheVersion ver,
long expireTime,
long ttl,
boolean needVer) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
GridCacheVersion ver,
long expireTime,
long ttl) |
protected void |
GridCacheMapEntry.checkOwnerChanged(@Nullable CacheLockCandidates prevOwners,
@Nullable CacheLockCandidates owners,
CacheObject val) |
protected void |
GridCacheMapEntry.checkOwnerChanged(@Nullable CacheLockCandidates prevOwners,
@Nullable CacheLockCandidates owners,
CacheObject val,
boolean inThreadChain) |
@Nullable CacheEntryPredicate |
CacheOperationFilter.createPredicate(@Nullable CacheObject val)
Creare predicate from operation filter.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
static @Nullable CacheObject |
GridCacheUtils.failed(boolean err,
CacheObject val) |
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
@Nullable CacheDataRow row)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
CacheDataRow row)
Sets new value if current version is 0
|
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,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
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,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
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,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
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,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
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,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
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,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
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,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
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,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
protected WALPointer |
GridCacheMapEntry.logMvccUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr,
MvccSnapshot mvccVer) |
protected WALPointer |
GridCacheMapEntry.logTxUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr) |
protected void |
GridCacheMapEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr) |
void |
IgniteCacheOffheapManager.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
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) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccSet(@Nullable IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
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.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
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.
|
void |
GridCacheUpdateTxResult.newValue(CacheObject newVal) |
void |
GridCacheUpdateTxResult.oldValue(CacheObject oldVal) |
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
void |
GridCacheUpdateTxResult.prevValue(@Nullable CacheObject prevVal) |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
void |
GridCacheEventManager.readEvent(KeyCacheObject key,
@Nullable IgniteInternalTx tx,
@Nullable String txLbl,
@Nullable CacheObject val,
@Nullable UUID subjId,
@Nullable String taskName,
boolean keepBinary) |
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
@Nullable CacheObject cacheObj,
boolean success,
boolean keepBinary) |
protected boolean |
GridCacheMapEntry.storeValue(@Nullable CacheObject val,
long expireTime,
GridCacheVersion ver)
Stores value in offheap.
|
protected boolean |
GridCacheMapEntry.storeValue(@Nullable CacheObject val,
long expireTime,
GridCacheVersion ver,
@Nullable IgnitePredicate<CacheDataRow> predicate,
@Nullable CacheDataRow row)
Stores value in off-heap.
|
static Object |
CacheObjectUtils.unwrapBinaryIfNeeded(CacheObjectValueContext ctx,
CacheObject o,
boolean keepBinary,
boolean cpy) |
protected void |
GridCacheMapEntry.update(@Nullable CacheObject val,
long expireTime,
long ttl,
GridCacheVersion ver,
boolean addTracked) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
protected void |
GridCacheMapEntry.updatePlatformCache(@Nullable CacheObject val,
@Nullable AffinityTopologyVersion ver)
Invokes platform cache update callback, if applicable.
|
void |
GridCacheContext.validateKeyAndValue(KeyCacheObject key,
CacheObject val)
Performs validation of provided key and value against configured constraints.
|
void |
GridCacheEntryInfo.value(CacheObject val) |
protected void |
GridCacheMapEntry.value(@Nullable CacheObject val)
Sets entry value.
|
static <T> T |
GridCacheUtils.value(@Nullable CacheObject cacheObj,
GridCacheContext ctx,
boolean cpy) |
GridCacheReturn |
GridCacheReturn.value(GridCacheContext cctx,
CacheObject v,
boolean keepBinary) |
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).
|
| Constructor and Description |
|---|
CacheEntryPredicateContainsValue(CacheObject val) |
CacheInvokeDirectResult(KeyCacheObject key,
CacheObject res) |
CacheInvokeEntry(KeyCacheObject keyObj,
@Nullable CacheObject valObj,
GridCacheVersion ver,
boolean keepBinary,
GridCacheEntryEx entry)
Constructor.
|
CacheInvokeEntry(KeyCacheObject keyObj,
K key,
@Nullable CacheObject valObj,
V val,
GridCacheVersion ver,
boolean keepBinary,
GridCacheEntryEx entry) |
CacheLazyEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
boolean keepBinary) |
CacheLazyEntry(GridCacheContext ctx,
KeyCacheObject keyObj,
K key,
CacheObject valObj,
V val,
boolean keepBinary) |
CacheLazyEntry(GridCacheContext ctx,
KeyCacheObject keyObj,
K key,
CacheObject valObj,
V val,
boolean keepBinary,
Long updateCntr) |
GridCacheFilterFailedException(CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheObject |
CacheObjectBinaryProcessorImpl.prepareForCache(@Nullable CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
ByteBuffer buf) |
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
@Nullable CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
@Nullable Object obj,
boolean userObj) |
@Nullable CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
@Nullable Object obj,
boolean userObj,
boolean failIfUnregistered) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheObject |
CacheObjectBinaryProcessorImpl.prepareForCache(@Nullable CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheObject |
GridDistributedLockResponse.value(int idx) |
| Modifier and Type | Method and Description |
|---|---|
GridTuple<CacheObject> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedLockResponse.addValue(CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
@Nullable CacheObject val,
@Nullable Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl,
boolean skipStore,
boolean keepBinary) |
| Modifier and Type | Field and Description |
|---|---|
protected CacheObject |
GridDhtAtomicSingleUpdateRequest.prevVal
Previous value.
|
protected CacheObject |
GridNearAtomicSingleUpdateRequest.val
Value to update.
|
protected CacheObject |
GridDhtAtomicSingleUpdateRequest.val
Value to update.
|
| Modifier and Type | Method and Description |
|---|---|
abstract @Nullable CacheObject |
GridDhtAtomicAbstractUpdateRequest.nearValue(int idx) |
@Nullable CacheObject |
GridDhtAtomicUpdateRequest.nearValue(int idx) |
@Nullable CacheObject |
GridNearAtomicUpdateResponse.nearValue(int idx) |
@Nullable CacheObject |
GridDhtAtomicSingleUpdateRequest.nearValue(int idx) |
abstract @Nullable CacheObject |
GridDhtAtomicAbstractUpdateRequest.previousValue(int idx) |
@Nullable CacheObject |
GridDhtAtomicUpdateRequest.previousValue(int idx) |
@Nullable CacheObject |
GridDhtAtomicSingleUpdateRequest.previousValue(int idx) |
abstract @Nullable CacheObject |
GridDhtAtomicAbstractUpdateRequest.value(int idx) |
@Nullable CacheObject |
GridDhtAtomicUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateRequest.value(int idx) |
abstract CacheObject |
GridNearAtomicAbstractUpdateRequest.value(int idx) |
@Nullable CacheObject |
GridDhtAtomicSingleUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateInvokeRequest.value(int idx) |
CacheObject |
GridNearAtomicFullUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateRequest.writeValue(int idx) |
abstract CacheObject |
GridNearAtomicAbstractUpdateRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicSingleUpdateInvokeRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicFullUpdateRequest.writeValue(int idx) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
GridDhtAtomicAbstractUpdateRequest.addNearWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridDhtAtomicUpdateRequest.addNearWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridDhtAtomicSingleUpdateRequest.addNearWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
| Modifier and Type | Method and Description |
|---|---|
protected WALPointer |
GridDhtDetachedCacheEntry.logTxUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr) |
protected void |
GridDhtDetachedCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr) |
void |
GridDhtDetachedCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver)
Sets value to detached entry so it can be retrieved in transactional gets.
|
protected boolean |
GridDhtDetachedCacheEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver)
Stores value in offheap.
|
protected void |
GridDhtDetachedCacheEntry.value(@Nullable CacheObject val)
Sets entry value.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
CacheVersionedValue.value() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
void |
GridNearTxPrepareResponse.addOwnedValue(IgniteTxKey key,
GridCacheVersion ver,
CacheObject val)
Adds owned value.
|
void |
GridNearLockResponse.addValueBytes(@Nullable CacheObject val,
boolean filterPassed,
@Nullable GridCacheVersion dhtVer,
@Nullable GridCacheVersion mappedVer) |
boolean |
GridNearCacheEntry.loadedValue(@Nullable IgniteInternalTx tx,
UUID primaryNodeId,
CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
long ttl,
long expireTime,
boolean evt,
boolean keepBinary,
AffinityTopologyVersion topVer,
UUID subjId) |
protected WALPointer |
GridNearCacheEntry.logTxUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr) |
protected void |
GridNearCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion ver,
long expireTime,
long updCntr) |
boolean |
GridNearCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
protected boolean |
GridNearCacheEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver)
Stores value in offheap.
|
void |
GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer,
@Nullable CacheObject val,
long expireTime,
long ttl,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
| Constructor and Description |
|---|
CacheVersionedValue(CacheObject val,
GridCacheVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
GridCacheDrInfo.value() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.replicate(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
| Constructor and Description |
|---|
GridCacheDrExpirationInfo(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime)
Constructor.
|
GridCacheDrInfo(CacheObject val,
GridCacheVersion ver)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
MvccTxEntry.oldValue() |
CacheObject |
MvccTxEntry.value() |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
void |
MvccTxEntry.oldValue(CacheObject oldVal) |
| Constructor and Description |
|---|
MvccTxEntry(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId) |
MvccTxEntry(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId) |
| Modifier and Type | Field and Description |
|---|---|
protected CacheObject |
CacheDataRowAdapter.val |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
CacheDataRow.value() |
@Nullable CacheObject |
DataRowCacheAware.value() |
CacheObject |
CacheDataRowAdapter.value() |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccVer,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
void |
GridCacheOffheapManager.GridCacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
| Constructor and Description |
|---|
CacheDataRowAdapter(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
DataRowCacheAware(KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
boolean storeCacheId) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryManager.onEntryExpired(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject oldVal) |
void |
CacheContinuousQueryManager.onEntryUpdated(KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean internal,
int partId,
boolean primary,
boolean preload,
long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
void |
CacheContinuousQueryManager.onEntryUpdated(Map<UUID,CacheContinuousQueryListener> lsnrCol,
KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean internal,
int partId,
boolean primary,
boolean preload,
long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.put(@Nullable IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.put(@Nullable IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.putAll(@Nullable IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.putAll(@Nullable IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
IgniteTxEntry.applyEntryProcessors(CacheObject cacheVal) |
@Nullable CacheObject |
IgniteTxEntry.oldValue() |
@Nullable CacheObject |
IgniteTxEntry.previousValue() |
CacheObject |
TxEntryValueHolder.value()
Gets stored value.
|
@Nullable CacheObject |
IgniteTxEntry.value() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
@Nullable GridCacheReturn ret) |
T2<GridCacheOperation,CacheObject> |
IgniteTxEntry.entryProcessorCalculatedValue() |
| Modifier and Type | Method and Description |
|---|---|
IgniteTxEntry |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
@Nullable CacheObject val,
@Nullable javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx entry,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary,
boolean addReader) |
protected void |
IgniteTxLocalAdapter.addInvokeResult(IgniteTxEntry txEntry,
CacheObject cacheVal,
GridCacheReturn ret,
GridCacheVersion ver) |
CacheObject |
IgniteTxEntry.applyEntryProcessors(CacheObject cacheVal) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
void |
IgniteTxEntry.oldValue(CacheObject oldVal) |
void |
IgniteTxEntry.readValue(@Nullable CacheObject val)
Sets read value if this tx entry does not have write value yet.
|
void |
IgniteTxEntry.setAndMarkValid(CacheObject val) |
void |
TxEntryValueHolder.value(@Nullable CacheObject val) |
void |
IgniteTxEntry.value(@Nullable CacheObject val,
boolean writeVal,
boolean readVal) |
void |
TxEntryValueHolder.value(GridCacheOperation op,
CacheObject val,
boolean hasWriteVal,
boolean hasReadVal) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxEntry.entryProcessorCalculatedValue(T2<GridCacheOperation,CacheObject> entryProcessorCalcVal) |
| 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,
boolean keepBinary,
boolean addReader)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
@Nullable GridCacheVersion conflictVer,
boolean skipStore,
boolean keepBinary)
This constructor is meant for remote transactions.
|
| Constructor and Description |
|---|
DataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
MvccUpdateResult.newValue() |
CacheObject |
MvccUpdateDataRow.newValue() |
CacheObject |
MvccUpdateResult.oldValue() |
CacheObject |
MvccUpdateDataRow.oldValue() |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccUpdateDataRow.value(CacheObject val0) |
| Constructor and Description |
|---|
MvccDataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateDataRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
PartitionEntryHashRecord.value() |
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionEntryHashRecord.value(CacheObject val) |
| Constructor and Description |
|---|
PartitionEntryHashRecord(int cacheId,
String cacheName,
KeyCacheObject key,
String keyStr,
byte[] keyBytes,
GridCacheVersion ver,
int valHash,
CacheObject val,
String valStr,
byte[] valBytes) |
| Constructor and Description |
|---|
GridCacheLazyPlainVersionedEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean keepBinary) |
GridCacheLazyPlainVersionedEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean isStartVer,
boolean keepBinary) |
GridCacheRawVersionedEntry(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver)
Constructor used for local store load when key and value are available.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UserCacheObjectByteArrayImpl
Wraps value provided by user, must be copied before stored in cache.
|
class |
UserCacheObjectImpl
Wraps value provided by user, must be serialized before stored in cache.
|
class |
UserKeyCacheObjectImpl
Wraps key provided by user, must be serialized before stored in cache.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
UserKeyCacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
UserCacheObjectByteArrayImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
UserCacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
@Nullable CacheObject |
IgniteCacheObjectProcessor.prepareForCache(@Nullable CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
ByteBuffer buf) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
@Nullable CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
@Nullable Object obj,
boolean userObj) |
@Nullable CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
@Nullable Object obj,
boolean userObj,
boolean failIfUnregistered) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheObject |
IgniteCacheObjectProcessor.prepareForCache(@Nullable CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
| Modifier and Type | Field and Description |
|---|---|
protected CacheObject |
DataStreamerEntry.val |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
DataStreamerEntry.getValue() |
CacheObject |
DataStreamerEntry.setValue(CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
DataStreamerImpl.addDataInternal(KeyCacheObject key,
CacheObject val) |
CacheObject |
DataStreamerEntry.setValue(CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataStreamerImpl.IsolatedUpdater.receive(IgniteCache<KeyCacheObject,CacheObject> cache,
Collection<Map.Entry<KeyCacheObject,CacheObject>> entries)
Updates cache with batch of entries.
|
void |
DataStreamerImpl.IsolatedUpdater.receive(IgniteCache<KeyCacheObject,CacheObject> cache,
Collection<Map.Entry<KeyCacheObject,CacheObject>> entries)
Updates cache with batch of entries.
|
| Constructor and Description |
|---|
DataStreamerEntry(KeyCacheObject key,
CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteDrDataStreamerCacheUpdater.receive(IgniteCache<KeyCacheObject,CacheObject> cache0,
Collection<Map.Entry<KeyCacheObject,CacheObject>> col)
Updates cache with batch of entries.
|
void |
IgniteDrDataStreamerCacheUpdater.receive(IgniteCache<KeyCacheObject,CacheObject> cache0,
Collection<Map.Entry<KeyCacheObject,CacheObject>> col)
Updates cache with batch of entries.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridQueryProcessor.belongsToTable(GridCacheContext cctx,
String expCacheName,
String expTblName,
KeyCacheObject key,
CacheObject val)
Check whether provided key and value belongs to expected cache and table.
|
boolean |
QueryTypeDescriptorImpl.matchType(CacheObject val) |
boolean |
GridQueryTypeDescriptor.matchType(CacheObject val) |
@Nullable QueryTypeDescriptorImpl |
GridQueryProcessor.typeByValue(String cacheName,
CacheObjectContext coctx,
KeyCacheObject key,
CacheObject val,
boolean checkType) |
void |
GridQueryProcessor.validateKeyAndValue(CacheObjectContext coctx,
KeyCacheObject key,
CacheObject val)
Performs validation of provided key and value against configured constraints.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020