| 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 |
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).
|
| 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 |
GridCacheContext.fromOffheap(long valPtr,
boolean tmp) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheUpdateAtomicResult.newValue() |
CacheObject |
GridCacheUpdateAtomicResult.oldValue() |
CacheObject |
GridCacheUpdateTxResult.oldValue() |
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
boolean swap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
boolean swap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
boolean swap,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
boolean swap,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peekVisibleValue()
Peeks value provided to public API entries and to entry filters.
|
CacheObject |
GridCacheEntryEx.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 |
CacheObject.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 |
CacheObjectImpl.prepareForCache(CacheObjectContext ctx)
Prepares cache object for cache (e.g. copies user-provided object if needed).
|
CacheObject |
GridCacheMapEntry.rawGet() |
CacheObject |
GridCacheEntryEx.rawGet() |
CacheObject |
GridCacheMapEntry.rawGetOrUnmarshal(boolean tmp) |
CacheObject |
GridCacheEntryEx.rawGetOrUnmarshal(boolean tmp) |
CacheObject |
GridCacheMapEntry.rawGetOrUnmarshalUnlocked(boolean tmp) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheSwapManager.readValue(KeyCacheObject key,
boolean readOffheap,
boolean readSwap) |
CacheObject |
CacheInvokeDirectResult.result() |
protected CacheObject |
GridCacheMapEntry.saveValueForIndexUnlocked()
This method will return current value only if clearIndex(V) will require previous value.
|
CacheObject |
GridCacheContext.toCacheObject(Object obj) |
CacheObject |
GridCacheSwapManager.unmarshalSwapEntryValue(byte[] bytes) |
CacheObject |
GridCacheMapEntry.unswap() |
CacheObject |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswaps an entry.
|
CacheObject |
GridCacheEntryEx.unswap(boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheContext.unswapCacheObject(byte type,
byte[] bytes,
IgniteUuid clsLdrId) |
CacheObject |
GridCacheEntryInfo.value() |
CacheObject |
GridCacheSwapEntryImpl.value() |
CacheObject |
GridCacheSwapEntry.value() |
CacheObject |
GridCacheFilterFailedException.value() |
CacheObject |
GridCacheOffheapSwapEntry.value() |
CacheObject |
GridCacheMapEntry.valueBytes() |
CacheObject |
GridCacheEntryEx.valueBytes() |
CacheObject |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
CacheObject |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
protected CacheObject |
GridCacheMapEntry.valueBytesUnlocked() |
| Modifier and Type | Method and Description |
|---|---|
T2<CacheObject,GridCacheVersion> |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
T2<CacheObject,GridCacheVersion> |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
| Modifier and Type | Method and Description |
|---|---|
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) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
GridCacheVersion ver) |
protected void |
GridCacheMapEntry.clearIndex(CacheObject prevVal)
Clears index.
|
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
CacheEntryPredicate |
CacheOperationFilter.createPredicate(CacheObject val)
Creare predicate from operation filter.
|
static CacheObject |
GridCacheUtils.failed(boolean err,
CacheObject val) |
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType)
Sets new value if current version is 0
|
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
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,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
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,
GridDhtAtomicUpdateFuture fut) |
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,
GridDhtAtomicUpdateFuture fut) |
protected void |
GridCacheMessage.prepareMarshalCacheObject(CacheObject obj,
GridCacheContext ctx) |
GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
CacheObject cacheObj,
boolean success,
boolean keepBinary) |
protected void |
GridCacheMapEntry.update(CacheObject val,
long expireTime,
long ttl,
GridCacheVersion ver,
boolean addTracked) |
protected void |
GridCacheMapEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject prevVal)
Updates cache index.
|
void |
GridCacheEntryInfo.value(CacheObject val) |
void |
GridCacheSwapEntryImpl.value(CacheObject val) |
protected void |
GridCacheMapEntry.value(CacheObject val)
Sets entry value.
|
void |
GridCacheSwapEntry.value(CacheObject val) |
void |
GridCacheOffheapSwapEntry.value(CacheObject val) |
static <T> T |
GridCacheUtils.value(CacheObject cacheObj,
GridCacheContext ctx,
boolean cpy) |
GridCacheReturn |
GridCacheReturn.value(GridCacheContext cctx,
CacheObject v,
boolean keepBinary) |
GridCacheVersion |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
GridCacheVersion |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
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) |
protected void |
GridCacheMessage.finishUnmarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(Collection<? extends CacheObject> col,
GridCacheContext ctx) |
protected void |
GridCacheMessage.prepareMarshalCacheObjects(List<? extends CacheObject> col,
GridCacheContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj) |
CacheObject |
CacheObjectBinaryProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
| 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) |
protected void |
GridDistributedCacheEntry.checkOwnerChanged(GridCacheMvccCandidate prev,
GridCacheMvccCandidate owner,
CacheObject val) |
| Constructor and Description |
|---|
GridDistributedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
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) |
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridDhtLocalPartition.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
| Constructor and Description |
|---|
GridDhtCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtOffHeapCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
GridDhtAtomicUpdateRequest.nearValue(int idx) |
CacheObject |
GridNearAtomicUpdateResponse.nearValue(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.previousValue(int idx) |
CacheObject |
GridNearAtomicUpdateRequest.value(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicUpdateRequest.writeValue(int idx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicUpdateResponse.addNearValue(int keyIdx,
CacheObject val,
long ttl,
long expireTime)
Adds value to be put in near cache on originating node.
|
void |
GridDhtAtomicUpdateFuture.addNearWriteEntries(Iterable<UUID> readers,
GridDhtCacheEntry entry,
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 |
GridDhtAtomicUpdateFuture.addWriteEntry(GridDhtCacheEntry entry,
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,
int partId,
CacheObject prevVal,
Long updateCntr) |
| Constructor and Description |
|---|
GridDhtAtomicCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtAtomicOffHeapCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
GridDhtDetachedCacheEntry.unswap(boolean needVal)
Unswaps an entry.
|
protected CacheObject |
GridDhtDetachedCacheEntry.valueBytesUnlocked() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridDhtDetachedCacheEntry.clearIndex(CacheObject val)
Clears index.
|
void |
GridDhtDetachedCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver)
Sets value to detached entry so it can be retrieved in transactional gets.
|
protected void |
GridDhtDetachedCacheEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject old)
Updates cache index.
|
protected void |
GridDhtDetachedCacheEntry.value(CacheObject val)
Sets entry value.
|
| Constructor and Description |
|---|
GridDhtColocatedCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtColocatedOffHeapCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtDetachedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| 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) |
protected void |
GridNearCacheEntry.clearIndex(CacheObject val)
Clears index.
|
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) |
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 void |
GridNearCacheEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject old)
Updates cache index.
|
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) |
GridNearCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val) |
GridNearOffHeapCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val) |
| 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.
|
| Constructor and Description |
|---|
GridLocalCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryManager.onSwap(CacheObject key)
Entry for given key unswapped.
|
void |
GridCacheQueryManager.onUnswap(CacheObject key,
CacheObject val)
Entry for given key unswapped.
|
void |
GridCacheQueryManager.remove(CacheObject key,
CacheObject val) |
void |
GridCacheQueryManager.store(CacheObject key,
CacheObject val,
GridCacheVersion ver,
long expirationTime)
Writes key-value pair to index.
|
| 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,
GridDhtAtomicUpdateFuture 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,
GridDhtAtomicUpdateFuture fut,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
IgniteTxEntry.applyEntryProcessors(CacheObject cacheVal) |
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) |
T2<GridCacheOperation,CacheObject> |
IgniteTxEntry.entryProcessorCalculatedValue() |
GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key) |
GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
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) |
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.readValue(CacheObject val)
Sets read value if this tx entry does not have write value yet.
|
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)
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 |
|---|
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 | 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).
|
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(GridCacheContext ctx,
long valPtr,
boolean tmp) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
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) |
| 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 |
|---|---|
void |
GridQueryIndexing.onSwap(String spaceName,
CacheObject key)
Will be called when entry with given key is swapped.
|
void |
GridQueryProcessor.onSwap(String spaceName,
CacheObject key)
Will be called when entry for key will be swapped.
|
void |
GridQueryIndexing.onUnswap(String spaceName,
CacheObject key,
CacheObject val)
Will be called when entry with given key is unswapped.
|
void |
GridQueryProcessor.onUnswap(String spaceName,
CacheObject key,
CacheObject val)
Will be called when entry for key will be unswapped.
|
void |
GridQueryIndexing.remove(String spaceName,
CacheObject key,
CacheObject val)
Removes index entry by key.
|
void |
GridQueryProcessor.remove(String space,
CacheObject key,
CacheObject val) |
void |
GridQueryProcessor.store(String space,
CacheObject key,
CacheObject val,
byte[] ver,
long expirationTime)
Writes key-value pair to index.
|
void |
GridQueryIndexing.store(String spaceName,
GridQueryTypeDescriptor type,
CacheObject key,
CacheObject val,
byte[] ver,
long expirationTime)
Updates index.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.6.0 Release Date : May 18 2016