| 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 |
BinaryObjectImpl.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 |
BinaryObjectOffheapImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
| Modifier and Type | Field and Description |
|---|---|
protected CacheObject |
DataEntry.val
Cache object value.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
LazyDataEntry.value() |
CacheObject |
DataEntry.value() |
CacheObject |
LazyMvccDataEntry.value() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
MvccDataEntry(int cacheId,
KeyCacheObject key,
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 CacheObject |
GridCacheUtils.failed(boolean err) |
static CacheObject |
GridCacheUtils.failed(boolean err,
CacheObject val) |
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary,
MvccSnapshot mvccVer) |
CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheUpdateAtomicResult.newValue() |
CacheObject |
GridCacheUpdateTxResult.newValue() |
CacheObject |
GridCacheUpdateAtomicResult.oldValue() |
CacheObject |
GridCacheUpdateTxResult.oldValue() |
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peekVisibleValue()
Peeks value provided to public API entries and to entry filters.
|
CacheObject |
GridCacheMapEntry.peekVisibleValue()
Peeks value provided to public API entries and to entry filters.
|
protected CacheObject |
CacheEntryPredicateAdapter.peekVisibleValue(GridCacheEntryEx entry) |
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).
|
CacheObject |
CacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
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() |
CacheObject |
GridCacheContext.toCacheObject(Object obj) |
CacheObject |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap() |
CacheObject |
GridCacheEntryEx.unswap(boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheEntryEx.unswap(CacheDataRow row) |
CacheObject |
GridCacheMapEntry.unswap(CacheDataRow row) |
CacheObject |
GridCacheFilterFailedException.value() |
CacheObject |
GridCacheEntryInfo.value() |
CacheObject |
GridCacheEntryEx.valueBytes() |
CacheObject |
GridCacheMapEntry.valueBytes() |
CacheObject |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
CacheObject |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheGroupContext.addCacheEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
int type,
CacheObject newVal,
boolean hasNewVal,
CacheObject oldVal,
boolean hasOldVal,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
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,
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 nodeId,
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,
IgniteUuid xid,
Object lockId,
int type,
CacheObject newVal,
boolean hasNewVal,
CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
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,
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(CacheLockCandidates prevOwners,
CacheLockCandidates owners,
CacheObject val) |
CacheEntryPredicate |
CacheOperationFilter.createPredicate(CacheObject val)
Creare predicate from operation filter.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
static 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
|
boolean |
GridCacheEntryEx.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)
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)
Sets new value if current version is 0
|
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr,
MvccSnapshot mvccVer) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
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,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
default boolean |
IgniteCacheOffheapManager.mvccInitialValue(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
boolean |
IgniteCacheOffheapManager.mvccInitialValue(GridCacheMapEntry entry,
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) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManager.mvccInitialValueIfAbsent(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
boolean |
IgniteCacheOffheapManagerImpl.mvccInitialValueIfAbsent(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHist,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
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) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManager.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal,
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,
CacheEntryPredicate filter,
boolean retVal,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
GridLongList |
IgniteCacheOffheapManager.mvccUpdateNative(boolean primary,
GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.mvccUpdateNative(boolean primary,
GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
GridLongList |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManager.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
boolean |
IgniteCacheOffheapManagerImpl.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
void |
GridCacheUpdateTxResult.newValue(CacheObject newVal) |
void |
GridCacheUpdateTxResult.oldValue(CacheObject oldVal) |
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
void |
GridCacheUpdateTxResult.prevValue(CacheObject prevVal) |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
void |
GridCacheEventManager.readEvent(KeyCacheObject key,
IgniteInternalTx tx,
CacheObject val,
UUID subjId,
String taskName,
boolean keepBinary) |
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
CacheObject cacheObj,
boolean success,
boolean keepBinary) |
protected boolean |
GridCacheMapEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver)
Stores value in offheap.
|
protected boolean |
GridCacheMapEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
IgnitePredicate<CacheDataRow> predicate)
Stores value in off-heap.
|
static Object |
CacheObjectUtils.unwrapBinaryIfNeeded(CacheObjectValueContext ctx,
CacheObject o,
boolean keepBinary,
boolean cpy) |
protected void |
GridCacheMapEntry.update(CacheObject val,
long expireTime,
long ttl,
GridCacheVersion ver,
boolean addTracked) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
GridCacheContext.validateKeyAndValue(KeyCacheObject key,
CacheObject val)
Performs validation of provided key and value against configured constraints.
|
protected void |
GridCacheMapEntry.value(CacheObject val)
Sets entry value.
|
void |
GridCacheEntryInfo.value(CacheObject val) |
static <T> T |
GridCacheUtils.value(CacheObject cacheObj,
GridCacheContext ctx,
boolean cpy) |
GridCacheReturn |
GridCacheReturn.value(GridCacheContext cctx,
CacheObject v,
boolean keepBinary) |
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
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,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
void |
GridCacheMessage.finishUnmarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx) |
void |
GridCacheMessage.prepareMarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx) |
| Constructor and Description |
|---|
CacheEntryPredicateContainsValue(CacheObject val) |
CacheInvokeDirectResult(KeyCacheObject key,
CacheObject res) |
CacheInvokeEntry(KeyCacheObject keyObj,
CacheObject valObj,
GridCacheVersion ver,
boolean keepBinary,
GridCacheEntryEx entry)
Constructor.
|
CacheInvokeEntry(KeyCacheObject keyObj,
K key,
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 |
|---|---|
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj,
boolean failIfUnregistered) |
| Modifier and Type | Method and Description |
|---|---|
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 |
|---|---|
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridDhtCacheEntry.versionedValue(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
CacheObject val,
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 |
GridDhtAtomicSingleUpdateRequest.val
Value to update.
|
protected CacheObject |
GridNearAtomicSingleUpdateRequest.val
Value to update.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
GridDhtAtomicSingleUpdateRequest.nearValue(int idx) |
CacheObject |
GridNearAtomicUpdateResponse.nearValue(int idx) |
abstract CacheObject |
GridDhtAtomicAbstractUpdateRequest.nearValue(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.nearValue(int idx) |
CacheObject |
GridDhtAtomicSingleUpdateRequest.previousValue(int idx) |
abstract CacheObject |
GridDhtAtomicAbstractUpdateRequest.previousValue(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.previousValue(int idx) |
CacheObject |
GridDhtAtomicSingleUpdateRequest.value(int idx) |
abstract CacheObject |
GridNearAtomicAbstractUpdateRequest.value(int idx) |
abstract CacheObject |
GridDhtAtomicAbstractUpdateRequest.value(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicFullUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateInvokeRequest.value(int idx) |
abstract CacheObject |
GridNearAtomicAbstractUpdateRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicSingleUpdateRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicFullUpdateRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicSingleUpdateInvokeRequest.writeValue(int idx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicSingleUpdateRequest.addNearWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addNearWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridDhtAtomicUpdateRequest.addNearWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean addPrevVal,
CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean addPrevVal,
CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean addPrevVal,
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(CacheObject val)
Sets entry value.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
CacheVersionedValue.value() |
| Modifier and Type | Method and Description |
|---|---|
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridNearCacheEntry.versionedValue() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
void |
GridNearTxPrepareResponse.addOwnedValue(IgniteTxKey key,
GridCacheVersion ver,
CacheObject val)
Adds owned value.
|
void |
GridNearLockResponse.addValueBytes(CacheObject val,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer) |
boolean |
GridNearCacheEntry.loadedValue(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,
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,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
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,
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,
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 |
CacheDataRowAdapter.value() |
CacheObject |
CacheDataRow.value() |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
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,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValueIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte txState,
byte newTxState) |
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) |
GridLongList |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateNative(GridCacheContext cctx,
boolean primary,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState) |
void |
GridCacheOffheapManager.GridCacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
| Constructor and Description |
|---|
CacheDataRowAdapter(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
| 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,
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,
GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.putAll(IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.putAll(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) |
CacheObject |
IgniteTxEntry.oldValue() |
CacheObject |
IgniteTxEntry.previousValue() |
CacheObject |
TxEntryValueHolder.value()
Gets stored value.
|
CacheObject |
IgniteTxEntry.value() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
GridCacheReturn ret) |
T2<GridCacheOperation,CacheObject> |
IgniteTxEntry.entryProcessorCalculatedValue() |
GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
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,
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(CacheObject val)
Sets read value if this tx entry does not have write value yet.
|
void |
IgniteTxEntry.setAndMarkValid(CacheObject val) |
void |
TxEntryValueHolder.value(CacheObject val) |
void |
IgniteTxEntry.value(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,
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,
CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
MvccUpdateDataRowNative(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
int part,
GridCacheContext cctx) |
| 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,
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 |
UserCacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
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 |
IgniteCacheObjectProcessor.prepareForCache(CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
IgniteCacheObjectProcessorImpl.prepareForCache(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 |
IgniteCacheObjectProcessorImpl.toCacheObject(CacheObjectContext ctx,
ByteBuffer buf) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj,
boolean failIfUnregistered) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj,
boolean failIfUnregistered) |
protected CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject0(Object obj,
boolean userObj) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
IgniteCacheObjectProcessor.prepareForCache(CacheObject obj,
GridCacheContext cctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
IgniteCacheObjectProcessorImpl.prepareForCache(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.
|
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.7.5 Release Date : June 4 2019