| Modifier and Type | Class and Description |
|---|---|
class |
BinaryObjectImpl
Binary object implementation.
|
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
BinaryObjectImpl.copy(int part) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyCacheObject |
DataEntry.key |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
DataEntry.key() |
KeyCacheObject |
LazyDataEntry.key() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
| Modifier and Type | Class and Description |
|---|---|
class |
KeyCacheObjectImpl |
| Modifier and Type | Field and Description |
|---|---|
protected KeyCacheObject |
GridCacheMapEntry.key
Key.
|
protected KeyCacheObject |
CacheLazyEntry.keyObj
Key cache object.
|
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
KeyCacheObjectImpl.copy(int part) |
KeyCacheObject |
KeyCacheObject.copy(int part) |
KeyCacheObject |
GridCacheEntryEx.key() |
KeyCacheObject |
GridCacheEntryInfo.key() |
KeyCacheObject |
GridCacheMapEntry.key() |
KeyCacheObject |
CacheEvictionEntry.key() |
KeyCacheObject |
CacheInvokeDirectResult.key() |
KeyCacheObject |
GridCacheContext.toCacheKeyObject(byte[] bytes) |
KeyCacheObject |
GridCacheContext.toCacheKeyObject(Object obj) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheReturn.addEntryProcessResult(GridCacheContext cctx,
KeyCacheObject key,
Object key0,
Object res,
Exception err,
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) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
EntryGetResult getRes,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
boolean needVer) |
GridCacheMapEntry |
GridCacheMapEntryFactory.create(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(KeyCacheObject lower,
KeyCacheObject upper) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.find(KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.find(KeyCacheObject key) |
GridCacheMapEntry |
GridCacheConcurrentMap.getEntry(KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
GridCacheMapEntry |
GridCacheConcurrentMapImpl.getEntry(KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
GridCacheMapEntry |
GridNoStorageCacheMap.getEntry(KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
void |
IgniteCacheOffheapManager.invoke(KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.invoke(KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManager.CacheDataStore.invoke(KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.invoke(KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
GridCacheEntryInfo.key(KeyCacheObject key) |
protected boolean |
GridCacheClearAllRunnable.owns(KeyCacheObject key)
Check whether this worker owns particular key.
|
GridCacheEntryEx |
GridCacheAdapter.peekEx(KeyCacheObject key) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
protected Object |
GridCacheMapEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
void |
IgniteCacheOffheapManager.CacheDataStore.remove(KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.remove(KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManager.remove(KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
IgniteCacheOffheapManagerImpl.remove(KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
GridCacheAdapter.removeIfObsolete(KeyCacheObject key) |
void |
GridCacheAdapter.CacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
Collection<UUID> rdrs) |
void |
IgniteCacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
Collection<UUID> rdrs)
Callback for ttl update on entry access.
|
IgniteTxKey |
GridCacheContext.txKey(KeyCacheObject key) |
void |
IgniteCacheOffheapManager.update(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
int partId,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
int partId,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(KeyCacheObject key,
int part,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(KeyCacheObject key,
int p,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAdapter.clearLocally(Collection<KeyCacheObject> keys,
boolean readers) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishKeys(Collection<KeyCacheObject> keys,
int cacheId,
AffinityTopologyVersion topVer) |
protected <K1,V1> IgniteInternalFuture<Map<K1,V1>> |
GridCacheAdapter.getAllAsync0(Collection<KeyCacheObject> keys,
ReaderArguments readerArgs,
boolean readThrough,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean keepCacheObjects,
boolean recovery,
boolean canRemap,
boolean needVer) |
void |
GridCacheProxyImpl.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
IgniteInternalCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
GridCacheAdapter.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
IgniteInternalCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
void |
GridCacheProxyImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
IgniteInternalCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheAdapter.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
IgniteInternalCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<Object> |
GridCachePreloaderAdapter.request(Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
IgniteInternalFuture<Object> |
GridCachePreloader.request(Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
abstract IgniteInternalFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long createTtl,
long accessTtl) |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toCacheKeyObject(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toKeyCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyCacheObject |
CacheDataRowAdapter.key |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
CacheSearchRow.key() |
KeyCacheObject |
CacheDataRowAdapter.key() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheDataRowAdapter.key(KeyCacheObject key) |
void |
CacheDataRow.key(KeyCacheObject key) |
| Constructor and Description |
|---|
CacheDataRowAdapter(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheDataStructuresManager.onEntryUpdated(KeyCacheObject key,
boolean rmv,
boolean keepBinary)
Entry update callback.
|
| Modifier and Type | Method and Description |
|---|---|
List<KeyCacheObject> |
GridDistributedUnlockRequest.keys() |
List<KeyCacheObject> |
GridDistributedLockRequest.keys() |
List<KeyCacheObject> |
GridCacheTtlUpdateRequest.keys() |
List<KeyCacheObject> |
GridCacheTtlUpdateRequest.nearKeys() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheTtlUpdateRequest.addEntry(KeyCacheObject key,
GridCacheVersion ver) |
void |
GridDistributedUnlockRequest.addKey(KeyCacheObject key,
GridCacheContext ctx) |
void |
GridDistributedLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
GridCacheContext ctx)
Adds a key.
|
void |
GridCacheTtlUpdateRequest.addNearEntry(KeyCacheObject key,
GridCacheVersion ver) |
GridTuple<CacheObject> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
void |
GridDistributedCacheAdapter.removeVersionedEntry(KeyCacheObject key,
GridCacheVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl) |
IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean isInvalidate,
long createTtl,
long accessTtl) |
| Constructor and Description |
|---|
GridDistributedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val) |
| Modifier and Type | Field and Description |
|---|---|
protected Collection<KeyCacheObject> |
CacheDistributedGetFutureAdapter.keys
Keys.
|
| Modifier and Type | Method and Description |
|---|---|
Set<KeyCacheObject> |
GridCachePartitionedConcurrentMap.keySet(CacheEntryPredicate... filter) |
List<KeyCacheObject> |
GridDhtUnlockRequest.nearKeys() |
List<KeyCacheObject> |
GridDhtLockRequest.nearKeys() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(KeyCacheObject key,
boolean invalidateEntry,
GridCacheContext ctx)
Adds a DHT key.
|
void |
GridDhtUnlockRequest.addNearKey(KeyCacheObject key)
Adds a Near key.
|
void |
GridDhtLockRequest.addNearKey(KeyCacheObject key,
GridCacheSharedContext ctx)
Adds a Near key.
|
protected GridDistributedCacheEntry |
GridDhtCacheAdapter.createEntry(KeyCacheObject key) |
GridCacheEntryEx |
GridDhtCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridDhtCacheEntry |
GridDhtCacheAdapter.entryExx(KeyCacheObject key) |
GridDhtCacheEntry |
GridDhtCacheAdapter.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.getEntry(KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
void |
GridDhtLocalPartition.onDeferredDelete(KeyCacheObject key,
GridCacheVersion ver) |
void |
GridDhtLocalPartition.onEntryEvicted(KeyCacheObject key,
GridCacheVersion ver) |
GridCacheVersion |
GridDhtLockRequest.owned(KeyCacheObject key) |
void |
GridDhtLockRequest.owned(KeyCacheObject key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
GridDhtCacheEntry |
GridDhtCacheAdapter.peekExx(KeyCacheObject key) |
boolean |
GridDhtLocalPartition.preloadingPermitted(KeyCacheObject key,
GridCacheVersion ver)
Cache preloader should call this method within partition lock.
|
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
KeyCacheObject key,
CacheObject val,
boolean create,
boolean touch) |
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
| Modifier and Type | Method and Description |
|---|---|
GridDhtFuture<Collection<GridCacheEntryInfo>> |
GridDhtCacheAdapter.getDhtAsync(UUID reader,
long msgId,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean recovery) |
IgniteInternalFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl) |
GridDhtFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary)
Acquires locks in partitioned cache.
|
void |
GridDhtTransactionalCacheAdapter.removeLocks(UUID nodeId,
GridCacheVersion ver,
Iterable<KeyCacheObject> keys,
boolean unmap) |
| Constructor and Description |
|---|
GridDhtCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
Boolean addRdr,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
| Constructor and Description |
|---|
CacheDistributedGetFutureAdapter(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyCacheObject |
GridNearAtomicSingleUpdateRequest.key
Key to update.
|
protected KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.key
Key to update.
|
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
GridDhtAtomicUpdateRequest.key(int idx) |
KeyCacheObject |
GridNearAtomicFullUpdateRequest.key(int idx) |
abstract KeyCacheObject |
GridDhtAtomicAbstractUpdateRequest.key(int idx) |
KeyCacheObject |
GridNearAtomicSingleUpdateRequest.key(int idx) |
abstract KeyCacheObject |
GridNearAtomicAbstractUpdateRequest.key(int idx) |
KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.key(int idx) |
KeyCacheObject |
GridDhtAtomicUpdateRequest.nearKey(int idx) |
abstract KeyCacheObject |
GridDhtAtomicAbstractUpdateRequest.nearKey(int idx) |
KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.nearKey(int idx) |
KeyCacheObject |
GridDhtAtomicUpdateRequest.obsoleteNearKey(int idx) |
abstract KeyCacheObject |
GridDhtAtomicAbstractUpdateRequest.obsoleteNearKey(int idx) |
KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.obsoleteNearKey(int idx) |
| Modifier and Type | Method and Description |
|---|---|
Collection<KeyCacheObject> |
UpdateErrors.failedKeys() |
Collection<KeyCacheObject> |
GridNearAtomicUpdateResponse.failedKeys() |
List<KeyCacheObject> |
GridNearAtomicFullUpdateRequest.keys() |
List<KeyCacheObject> |
GridNearAtomicSingleUpdateRequest.keys() |
abstract List<KeyCacheObject> |
GridNearAtomicAbstractUpdateRequest.keys() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
GridDhtAtomicAbstractUpdateFuture.addDhtKey(KeyCacheObject key,
List<ClusterNode> dhtNodes) |
void |
GridNearAtomicUpdateResponse.addFailedKey(KeyCacheObject key,
Throwable e)
Adds key to collection of failed keys.
|
void |
GridDhtAtomicNearResponse.addFailedKey(KeyCacheObject key,
Throwable e) |
protected abstract void |
GridDhtAtomicAbstractUpdateFuture.addNearKey(KeyCacheObject key,
Collection<UUID> readers) |
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.addNearWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridNearAtomicFullUpdateRequest.addUpdateEntry(KeyCacheObject key,
Object val,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateInvokeRequest.addUpdateEntry(KeyCacheObject key,
Object val,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateRequest.addUpdateEntry(KeyCacheObject key,
Object val,
long conflictTtl,
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,
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) |
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) |
boolean |
GridDhtAtomicUpdateRequest.hasKey(KeyCacheObject key) |
abstract boolean |
GridDhtAtomicAbstractUpdateRequest.hasKey(KeyCacheObject key) |
boolean |
GridDhtAtomicSingleUpdateRequest.hasKey(KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl) |
void |
GridDhtAtomicCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)
Store DR data.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)
Store DR data asynchronously.
|
void |
GridDhtAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data asynchronously.
|
| Constructor and Description |
|---|
GridDhtAtomicCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
| Modifier and Type | Method and Description |
|---|---|
GridDistributedCacheEntry |
GridDhtColocatedCache.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean allowDetached)
Gets or creates entry for given key and given topology version.
|
IgniteInternalFuture<Object> |
GridDhtColocatedCache.loadAsync(KeyCacheObject key,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObj,
boolean recovery) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer) |
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
AffinityTopologyVersion topVer,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObj) |
IgniteInternalFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl)
This is an entry point to pessimistic locking within transaction.
|
void |
GridDhtColocatedCache.removeLocks(long threadId,
GridCacheVersion ver,
Collection<KeyCacheObject> keys)
Removes locks regardless of whether they are owned or not for given
version and keys.
|
| Constructor and Description |
|---|
GridDhtColocatedCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
int hash,
CacheObject val) |
GridDhtDetachedCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val,
GridCacheMapEntry next,
int hdrId) |
| Constructor and Description |
|---|
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary,
boolean recovery) |
| Modifier and Type | Method and Description |
|---|---|
Collection<KeyCacheObject> |
GridDhtForceKeysRequest.keys() |
Collection<KeyCacheObject> |
GridDhtForceKeysResponse.missedKeys() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtForceKeysResponse.addMissed(KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtFuture<Object> |
GridDhtPreloader.request(Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
AffinityTopologyVersion topVer,
Collection<KeyCacheObject> keys,
GridDhtPreloader preloader) |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
GridNearSingleGetRequest.key() |
| Modifier and Type | Method and Description |
|---|---|
Collection<KeyCacheObject> |
GridNearLockMapping.distributedKeys() |
LinkedHashMap<KeyCacheObject,Boolean> |
GridNearGetRequest.keys() |
Collection<KeyCacheObject> |
GridNearLockMapping.mappedKeys() |
List<KeyCacheObject> |
GridNearAtomicCache.processDhtAtomicUpdateRequest(UUID nodeId,
GridDhtAtomicAbstractUpdateRequest req,
GridDhtAtomicNearResponse res) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearLockMapping.addKey(KeyCacheObject key) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheContext ctx)
Adds a key.
|
GridCacheMapEntry |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridNearCacheEntry |
GridNearCacheAdapter.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridNearCacheEntry |
GridNearCacheAdapter.peekExx(KeyCacheObject key) |
protected Object |
GridNearCacheEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
void |
GridNearLockMapping.distributedKeys(Collection<KeyCacheObject> distributedKeys) |
<K,V> IgniteInternalFuture<Map<K,V>> |
GridNearTxLocal.getAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean recovery,
boolean needVer) |
IgniteInternalFuture<Map<K,V>> |
GridNearCacheAdapter.loadAsync(IgniteInternalTx tx,
Collection<KeyCacheObject> keys,
boolean forcePrimary,
UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean skipVal,
boolean skipStore,
boolean canRemap,
boolean needVer) |
IgniteInternalFuture<Void> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
boolean recovery,
javax.cache.expiry.ExpiryPolicy expiryPlc,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c) |
IgniteInternalFuture<Void> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
boolean recovery,
javax.cache.expiry.ExpiryPolicy expiryPlc,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c) |
protected IgniteInternalFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl) |
protected IgniteInternalFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long createTtl,
long accessTtl) |
void |
GridNearAtomicCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridNearTxLocal.putAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheDrInfo> drMap) |
void |
GridNearAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridNearTxLocal.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
void |
GridNearTransactionalCache.removeLocks(GridCacheVersion ver,
Collection<KeyCacheObject> keys)
Removes locks regardless of whether they are owned or not for given
version and keys.
|
| Constructor and Description |
|---|
GridNearCacheEntry(GridCacheContext ctx,
KeyCacheObject key,
int hash,
CacheObject val) |
GridNearLockMapping(ClusterNode node,
KeyCacheObject firstKey)
Creates near lock mapping for specified node and key.
|
GridNearSingleGetRequest(int cacheId,
long futId,
KeyCacheObject key,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipVals,
boolean addReader,
boolean needVer,
boolean addDepInfo,
boolean recovery) |
| Constructor and Description |
|---|
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
IgniteTxLocalEx tx,
UUID subjId,
String taskName,
boolean deserializeBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean canRemap,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipVals,
boolean addDepInfo,
boolean recovery) |
GridNearLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary,
boolean recovery) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long createTtl,
long accessTtl) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long createTtl,
long accessTtl) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryManager.remove(KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver) |
void |
GridCacheQueryManager.store(KeyCacheObject key,
int partId,
CacheObject prevVal,
GridCacheVersion prevVer,
CacheObject val,
GridCacheVersion ver,
long expirationTime,
long link)
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,
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) |
void |
CacheContinuousQueryManager.skipUpdateEvent(Map<UUID,CacheContinuousQueryListener> lsnrs,
KeyCacheObject key,
int partId,
long updCntr,
boolean primary,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
Object |
CacheStoreManager.load(IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
Object |
GridCacheStoreManagerAdapter.load(IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
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.
|
boolean |
CacheStoreManager.remove(IgniteInternalTx tx,
KeyCacheObject key) |
boolean |
GridCacheStoreManagerAdapter.remove(IgniteInternalTx tx,
KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.loadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
IgniteBiInClosure<KeyCacheObject,Object> vis)
Loads data from persistent store.
|
boolean |
CacheStoreManager.loadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
IgniteBiInClosure<KeyCacheObject,Object> vis)
Loads data from persistent store.
|
boolean |
CacheStoreManager.loadCache(GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis,
Object[] args)
Loads data from persistent store.
|
void |
CacheStoreManager.localStoreLoadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
void |
CacheStoreManager.localStoreLoadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
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.
|
boolean |
CacheStoreManager.removeAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys) |
boolean |
GridCacheStoreManagerAdapter.removeAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys) |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
IgniteTxEntry.key() |
KeyCacheObject |
IgniteTxKey.key() |
| Modifier and Type | Method and Description |
|---|---|
GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key) |
protected boolean |
IgniteTxAdapter.updateNearCache(GridCacheContext<?,?> cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext cacheCtx,
Collection<KeyCacheObject> keys) |
protected void |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx,
Iterable<KeyCacheObject> keys,
GridCacheReturn ret,
boolean rmv,
boolean retval,
boolean read,
long accessTtl,
CacheEntryPredicate[] filter,
boolean computeInvoke)
Post lock processing for put or remove.
|
| Constructor and Description |
|---|
IgniteTxKey(KeyCacheObject key,
int cacheId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheRawVersionedEntry.key(KeyCacheObject key) |
| 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 | Method and Description |
|---|---|
KeyCacheObject |
IgniteCacheObjectProcessor.toCacheKeyObject(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
KeyCacheObject |
IgniteCacheObjectProcessorImpl.toCacheKeyObject(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
protected KeyCacheObject |
IgniteCacheObjectProcessorImpl.toCacheKeyObject0(CacheObjectContext ctx,
GridCacheContext cctx,
Object obj,
boolean userObj) |
KeyCacheObject |
IgniteCacheObjectProcessor.toKeyCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
KeyCacheObject |
IgniteCacheObjectProcessorImpl.toKeyCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyCacheObject |
DataStreamerEntry.key |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
DataStreamerEntry.getKey() |
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
DataStreamerImpl.addDataInternal(KeyCacheObject key,
CacheObject val) |
IgniteFuture<?> |
DataStreamerImpl.removeDataInternal(KeyCacheObject key) |
| 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 |
GridOffHeapProcessor.contains(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Checks if offheap space contains value for the given key.
|
void |
GridOffHeapProcessor.enableEviction(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Enables eviction for entry after
GridOffHeapProcessor.valuePointer(java.lang.String, int, org.apache.ignite.internal.processors.cache.KeyCacheObject, byte[]) was called. |
byte[] |
GridOffHeapProcessor.get(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Gets value bytes from offheap space for the given key.
|
<T> T |
GridOffHeapProcessor.getValue(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
ClassLoader ldr)
Gets value from offheap space for the given key.
|
void |
GridOffHeapProcessor.put(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
byte[] valBytes)
Puts the given value to offheap space for the given key.
|
byte[] |
GridOffHeapProcessor.remove(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from offheap space for the given key.
|
IgniteBiTuple<Long,Integer> |
GridOffHeapProcessor.valuePointer(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Gets value pointer from offheap space for the given key.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridQueryProcessor.belongsToTable(GridCacheContext cctx,
String expSpace,
String expTblName,
KeyCacheObject key,
CacheObject val)
Check whether provided key and value belongs to expected space and table.
|
void |
GridQueryIndexing.remove(String spaceName,
GridQueryTypeDescriptor type,
KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver)
Removes index entry by key.
|
void |
GridQueryProcessor.remove(String space,
KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver) |
void |
GridQueryProcessor.store(String space,
KeyCacheObject key,
int partId,
CacheObject prevVal,
GridCacheVersion prevVer,
CacheObject val,
GridCacheVersion ver,
long expirationTime,
long link)
Writes key-value pair to index.
|
void |
GridQueryIndexing.store(String spaceName,
String typeName,
KeyCacheObject key,
int partId,
CacheObject val,
GridCacheVersion ver,
long expirationTime,
long link)
Updates index.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SchemaIndexCacheVisitorClosure.apply(KeyCacheObject key,
int part,
CacheObject val,
GridCacheVersion ver,
long expiration,
long link)
Apply closure.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.0.0 Release Date : April 30 2017