| 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 |
GridCacheEntryEx.innerGet(IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc) |
CacheObject |
GridCacheMapEntry.innerGet(IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc) |
CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheUpdateAtomicResult.newValue() |
CacheObject |
GridCacheUpdateTxResult.oldValue() |
CacheObject |
GridCacheUpdateAtomicResult.oldValue() |
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,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
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.peek(boolean heap,
boolean offheap,
boolean swap,
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 |
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 |
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 |
GridCacheEntryEx.rawGet() |
CacheObject |
GridCacheMapEntry.rawGet() |
CacheObject |
GridCacheEntryEx.rawGetOrUnmarshal(boolean tmp) |
CacheObject |
GridCacheMapEntry.rawGetOrUnmarshal(boolean tmp) |
CacheObject |
GridCacheMapEntry.rawGetOrUnmarshalUnlocked(boolean tmp) |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
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 |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap() |
CacheObject |
GridCacheEntryEx.unswap(boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswaps an entry.
|
CacheObject |
GridCacheContext.unswapCacheObject(byte type,
byte[] bytes,
IgniteUuid clsLdrId) |
CacheObject |
GridCacheSwapEntry.value() |
CacheObject |
GridCacheEntryInfo.value() |
CacheObject |
GridCacheSwapEntryImpl.value() |
CacheObject |
GridCacheFilterFailedException.value() |
CacheObject |
GridCacheOffheapSwapEntry.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.
|
protected CacheObject |
GridCacheMapEntry.valueBytesUnlocked() |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<KeyCacheObject,CacheObject>> |
GridCacheAdapter.reloadAllAsync0(Collection<KeyCacheObject> keys,
boolean ret,
boolean skipVals,
UUID subjId,
String taskName) |
| 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) |
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) |
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) |
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) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializePortable,
boolean cpy) |
protected void |
GridCacheMapEntry.clearIndex(CacheObject prevVal)
Clears index.
|
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
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)
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)
Sets new value if current version is 0
|
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntry(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val) |
GridTriple<GridCacheMapEntry> |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create) |
CacheObject |
GridCacheEntryEx.rawPut(CacheObject val,
long ttl) |
CacheObject |
GridCacheMapEntry.rawPut(CacheObject val,
long ttl) |
GridCacheReturn |
GridCacheReturn.set(GridCacheContext cctx,
CacheObject cacheObj,
boolean success) |
protected void |
GridCacheMapEntry.update(CacheObject val,
long expireTime,
long ttl,
GridCacheVersion ver) |
protected void |
GridCacheMapEntry.updateIndex(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheObject prevVal)
Updates cache index.
|
void |
GridCacheSwapEntry.value(CacheObject val) |
void |
GridCacheEntryInfo.value(CacheObject val) |
void |
GridCacheSwapEntryImpl.value(CacheObject val) |
void |
GridCacheOffheapSwapEntry.value(CacheObject val) |
protected void |
GridCacheMapEntry.value(CacheObject val)
Sets entry value.
|
static <T> T |
GridCacheUtils.value(CacheObject cacheObj,
GridCacheContext ctx,
boolean cpy) |
GridCacheReturn |
GridCacheReturn.value(GridCacheContext cctx,
CacheObject v) |
boolean |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
boolean |
GridCacheMapEntry.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) |
void |
GridCacheConcurrentMap.putAll(Map<KeyCacheObject,CacheObject> m)
Copies all of the mappings from the specified map to this map
These mappings will replace any mappings that
this map had for any of the keys currently in the specified map.
|
| 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,
CacheEntryPredicate[] filter) |
| 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,
GridCacheMapEntry next,
int hdrId) |
| 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) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntry(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val) |
GridTriple<GridCacheMapEntry> |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNoStorageCacheMap.putAll(Map<KeyCacheObject,CacheObject> m)
Copies all of the mappings from the specified map to this map
These mappings will replace any mappings that
this map had for any of the keys currently in the specified map.
|
| Constructor and Description |
|---|
GridDhtCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
GridDhtAtomicUpdateRequest.nearValue(int idx) |
CacheObject |
GridNearAtomicUpdateResponse.nearValue(int idx) |
CacheObject |
GridDhtAtomicUpdateRequest.value(int idx) |
CacheObject |
GridNearAtomicUpdateRequest.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) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
| Constructor and Description |
|---|
GridDhtAtomicCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| 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,
GridCacheMapEntry next,
int hdrId) |
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) |
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,
GridCacheVersion expVer,
long ttl,
long expireTime,
boolean evt,
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 |
|---|
GridNearCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| 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)
Performs replication.
|
void |
GridOsCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType)
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,
GridCacheMapEntry next,
int hdrId) |
| 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(GridCacheEntryEx e,
KeyCacheObject key,
CacheObject newVal,
CacheObject oldVal,
boolean preload) |
| 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) |
GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
| 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) |
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) |
| 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)
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)
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 |
IgniteCacheObjectProcessorImpl.prepareForCache(CacheObject obj,
GridCacheContext cctx)
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.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(CacheObjectContext ctx,
Object obj,
boolean userObj) |
CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
CacheObject |
IgniteCacheObjectProcessor.toCacheObject(GridCacheContext ctx,
long valPtr,
boolean tmp) |
protected CacheObject |
IgniteCacheObjectProcessorImpl.toCacheObject0(Object obj,
boolean userObj) |
| Modifier and Type | Method and Description |
|---|---|
CacheObject |
IgniteCacheObjectProcessorImpl.prepareForCache(CacheObject obj,
GridCacheContext cctx)
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).
|
| 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.1.0-incubating Release Date : May 20 2015