| 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 |
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).
|
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 CacheObject |
DataEntry.val
Cache object value.
|
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
LazyDataEntry.value() |
CacheObject |
DataEntry.value() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
UnwrapDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
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) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheUpdateAtomicResult.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 |
CacheObjectImpl.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 |
KeyCacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
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 |
GridCacheEntryInfo.value() |
CacheObject |
GridCacheFilterFailedException.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) |
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 |
GridCacheMapEntry.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
|
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) |
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) |
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) |
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) |
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) |
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) |
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) |
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
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,
CacheDataRow oldRow)
Stores value in offheap.
|
protected boolean |
GridCacheMapEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow,
IgnitePredicate<CacheDataRow> predicate)
Stores value in offheap.
|
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) |
| 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) |
CacheObject |
GridDhtAtomicUpdateRequest.nearValue(int idx) |
abstract CacheObject |
GridDhtAtomicAbstractUpdateRequest.nearValue(int idx) |
CacheObject |
GridDhtAtomicSingleUpdateRequest.previousValue(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.previousValue(int idx) |
abstract CacheObject |
GridDhtAtomicAbstractUpdateRequest.previousValue(int idx) |
abstract CacheObject |
GridNearAtomicAbstractUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateInvokeRequest.value(int idx) |
CacheObject |
GridNearAtomicFullUpdateRequest.value(int idx) |
CacheObject |
GridDhtAtomicSingleUpdateRequest.value(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.value(int idx) |
abstract CacheObject |
GridDhtAtomicAbstractUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicSingleUpdateRequest.value(int idx) |
abstract CacheObject |
GridNearAtomicAbstractUpdateRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicSingleUpdateInvokeRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicFullUpdateRequest.writeValue(int idx) |
CacheObject |
GridNearAtomicSingleUpdateRequest.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) |
void |
GridDhtAtomicUpdateRequest.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 |
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) |
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) |
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) |
| 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,
CacheDataRow oldRow)
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,
CacheDataRow oldRow)
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 |
GridCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridOsCacheDrManager.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 | Field and Description |
|---|---|
protected CacheObject |
CacheDataRowAdapter.val |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
CacheDataRow.value() |
CacheObject |
CacheDataRowAdapter.value() |
| 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 |
GridCacheStoreManagerAdapter.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheStoreManagerAdapter.putAll(IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.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 |
|---|---|
protected IgniteTxEntry |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
CacheObject val,
javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx entry,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean skipStore,
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 |
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 |
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).
|
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) |
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 Fabric : ver. 2.6.0 Release Date : July 10 2018