| Modifier and Type | Method and Description |
|---|---|
void |
IgniteDiagnosticPrepareContext.txKeyInfo(UUID nodeId,
int cacheId,
Collection<KeyCacheObject> keys,
String msg) |
| 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
Cache object key.
|
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
DataEntry.key() |
KeyCacheObject |
LazyDataEntry.key() |
KeyCacheObject |
LazyMvccDataEntry.key() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
MvccDataEntry(int cacheId,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
UnwrapDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary) |
UnwrapMvccDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary) |
| Modifier and Type | 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 | Field and Description |
|---|---|
ConcurrentMap<KeyCacheObject,GridCacheMapEntry> |
GridCacheConcurrentMap.CacheMapHolder.map |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
KeyCacheObject.copy(int part) |
KeyCacheObject |
KeyCacheObjectImpl.copy(int part) |
KeyCacheObject |
GridCacheEntryEx.key() |
KeyCacheObject |
GridCacheMapEntry.key() |
KeyCacheObject |
GridCacheEntryInfo.key() |
KeyCacheObject |
CacheInvokeDirectResult.key() |
KeyCacheObject |
CacheEvictionEntry.key() |
KeyCacheObject |
GridCacheContext.toCacheKeyObject(byte[] bytes) |
KeyCacheObject |
GridCacheContext.toCacheKeyObject(Object obj) |
| Modifier and Type | Method and Description |
|---|---|
GridCloseableIterator<KeyCacheObject> |
IgniteCacheOffheapManager.cacheKeysIterator(int cacheId,
int part) |
GridCloseableIterator<KeyCacheObject> |
IgniteCacheOffheapManagerImpl.cacheKeysIterator(int cacheId,
int part) |
Collection<KeyCacheObject> |
GridCacheContext.cacheKeysView(Collection<?> keys) |
static IgniteClosure<GridCacheEntryEx,KeyCacheObject> |
GridCacheUtils.entry2Key() |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheGroupContext.addCacheEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
boolean keepBinary) |
void |
GridCacheReturn.addEntryProcessResult(GridCacheContext cctx,
KeyCacheObject key,
@Nullable Object key0,
@Nullable Object res,
@Nullable Exception err,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
@Nullable IgniteInternalTx tx,
@Nullable GridCacheMvccCandidate owner,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
String cloClsName,
String taskName,
boolean keepBinary) |
void |
GridCacheEventManager.addEvent(int part,
KeyCacheObject key,
UUID evtNodeId,
@Nullable GridCacheMvccCandidate owner,
int type,
@Nullable 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,
@Nullable 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,
@Nullable IgniteInternalTx tx,
@Nullable String txLbl,
@Nullable Object lockId,
int type,
@Nullable CacheObject newVal,
boolean hasNewVal,
@Nullable CacheObject oldVal,
boolean hasOldVal,
UUID subjId,
@Nullable String cloClsName,
@Nullable 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,
@Nullable EntryGetResult getRes,
GridCacheVersion ver,
long expireTime,
long ttl,
boolean needVer,
@Nullable ClassLoader ldr) |
<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,
@Nullable ClassLoader ldr) |
<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) |
static @Nullable GridCacheUtils.BackupPostProcessingClosure |
GridCacheUtils.createBackupPostProcessingClosure(AffinityTopologyVersion topVer,
IgniteLogger log,
GridCacheContext cctx,
@Nullable KeyCacheObject key,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean readThrough,
boolean skipVals)
Creates closure that saves initial value to backup partition.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot snapshot) |
GridCursor<? extends CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot snapshot) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key) |
GridCacheEntryEx |
GridCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.find(GridCacheContext cctx,
KeyCacheObject key) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.find(GridCacheContext cctx,
KeyCacheObject key) |
@Nullable GridCacheMapEntry |
GridCacheConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
@Nullable GridCacheMapEntry |
GridCacheConcurrentMapImpl.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
@Nullable GridCacheMapEntry |
GridNoStorageCacheMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
void |
IgniteCacheOffheapManager.invoke(GridCacheContext cctx,
KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.invoke(GridCacheContext cctx,
KeyCacheObject key,
GridDhtLocalPartition part,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManager.CacheDataStore.invoke(GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.invoke(GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
GridCacheEntryInfo.key(KeyCacheObject key) |
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManager.mvccAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManagerImpl.mvccAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManager.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManager.CacheDataStore.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManagerImpl.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
GridCursor<CacheDataRow> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyHistoryIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyHistoryIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
void |
IgniteCacheOffheapManager.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManager.CacheDataStore.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
List<IgniteBiTuple<Object,MvccVersion>> |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.mvccRead(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccRemoveAll(GridCacheContext cctx,
KeyCacheObject key) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemoveAll(GridCacheContext cctx,
KeyCacheObject key) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
protected boolean |
GridCacheClearAllRunnable.owns(KeyCacheObject key)
Check whether this worker owns particular key.
|
@Nullable GridCacheEntryEx |
GridCacheAdapter.peekEx(KeyCacheObject key) |
protected GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(@Nullable GridCacheConcurrentMap.CacheMapHolder hld,
GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
GridCacheMapEntry |
GridCacheConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
GridCacheMapEntry |
GridCacheConcurrentMapImpl.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
GridCacheMapEntry |
GridNoStorageCacheMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
@Nullable CacheDataRow |
IgniteCacheOffheapManager.read(GridCacheContext cctx,
KeyCacheObject key) |
@Nullable CacheDataRow |
IgniteCacheOffheapManagerImpl.read(GridCacheContext cctx,
KeyCacheObject key) |
void |
GridCacheEventManager.readEvent(KeyCacheObject key,
@Nullable IgniteInternalTx tx,
@Nullable String txLbl,
@Nullable CacheObject val,
@Nullable UUID subjId,
@Nullable String taskName,
boolean keepBinary) |
protected @Nullable Object |
GridCacheMapEntry.readThrough(@Nullable IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
void |
IgniteCacheOffheapManager.CacheDataStore.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId) |
void |
IgniteCacheOffheapManager.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
IgniteCacheOffheapManagerImpl.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId,
GridDhtLocalPartition part) |
void |
GridCacheAdapter.removeIfObsolete(KeyCacheObject key) |
void |
GridCacheAdapter.CacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
@Nullable Collection<UUID> rdrs) |
void |
IgniteCacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
@Nullable Collection<UUID> rdrs)
Callback for ttl update on entry access.
|
IgniteTxKey |
GridCacheContext.txKey(KeyCacheObject key) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
GridCacheContext.validateKeyAndValue(KeyCacheObject key,
CacheObject val)
Performs validation of provided key and value against configured constraints.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAdapter.clearLocally(Collection<KeyCacheObject> keys,
boolean readers) |
IgniteInternalFuture<?> |
GridCacheMvccManager.finishKeys(Collection<KeyCacheObject> keys,
int cacheId,
AffinityTopologyVersion topVer) |
void |
GridCacheAdapter.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
IgniteInternalCache.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
void |
GridCacheProxyImpl.putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
IgniteInternalCache.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
void |
GridCacheAdapter.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
IgniteInternalCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProxyImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
IgniteInternalCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridDhtFuture<Object> |
GridCachePreloaderAdapter.request(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer)
Requests that preloader sends the request for the key.
|
GridDhtFuture<Object> |
GridCachePreloader.request(GridCacheContext cctx,
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) |
| Constructor and Description |
|---|
CacheMapHolder(GridCacheContext cctx,
ConcurrentMap<KeyCacheObject,GridCacheMapEntry> map) |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toCacheKeyObject(CacheObjectContext ctx,
@Nullable GridCacheContext cctx,
Object obj,
boolean userObj) |
protected KeyCacheObject |
CacheObjectBinaryProcessorImpl.toCacheKeyObject0(CacheObjectContext ctx,
@Nullable GridCacheContext cctx,
Object obj,
boolean userObj) |
KeyCacheObject |
CacheObjectBinaryProcessorImpl.toKeyCacheObject(CacheObjectContext ctx,
byte type,
byte[] bytes) |
| Modifier and Type | Method and Description |
|---|---|
List<KeyCacheObject> |
GridCacheTtlUpdateRequest.keys() |
List<KeyCacheObject> |
GridDistributedLockRequest.keys() |
List<KeyCacheObject> |
GridDistributedUnlockRequest.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,
@Nullable IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
@Nullable 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) |
| Modifier and Type | Field and Description |
|---|---|
protected Collection<KeyCacheObject> |
CacheDistributedGetFutureAdapter.keys
Keys.
|
protected LinkedHashMap<KeyCacheObject,Boolean> |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.keys
Mapped keys.
|
| Modifier and Type | Method and Description |
|---|---|
List<KeyCacheObject> |
GridDhtTxQueryEnlistRequest.keys() |
Collection<KeyCacheObject> |
CacheDistributedGetFutureAdapter.AbstractMiniFuture.keys() |
List<KeyCacheObject> |
GridDhtLockRequest.nearKeys() |
List<KeyCacheObject> |
GridDhtUnlockRequest.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 boolean |
CacheDistributedGetFutureAdapter.checkRetryPermits(KeyCacheObject key,
ClusterNode node,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping) |
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) |
@Nullable GridCacheMapEntry |
GridCachePartitionedConcurrentMap.getEntry(GridCacheContext ctx,
KeyCacheObject key)
Returns the entry associated with the specified key in the
HashMap.
|
protected void |
GridDhtTxEnlistFuture.onEntryProcessed(KeyCacheObject key,
GridCacheUpdateTxResult txRes)
Entry processed callback.
|
protected void |
GridDhtTxQueryAbstractEnlistFuture.onEntryProcessed(KeyCacheObject key,
GridCacheUpdateTxResult res)
Entry processed callback.
|
protected abstract void |
GridDhtTxAbstractEnlistFuture.onEntryProcessed(KeyCacheObject key,
GridCacheUpdateTxResult res)
Entry processed callback.
|
@Nullable GridCacheVersion |
GridDhtLockRequest.owned(KeyCacheObject key) |
void |
GridDhtLockRequest.owned(KeyCacheObject key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
@Nullable GridDhtCacheEntry |
GridDhtCacheAdapter.peekExx(KeyCacheObject key) |
GridCacheMapEntry |
GridCachePartitionedConcurrentMap.putEntryIfObsoleteOrAbsent(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key,
boolean create,
boolean skipReserve) |
protected boolean |
GridDhtTxRemote.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
protected boolean |
GridDhtTxLocal.updateNearCache(GridCacheContext cacheCtx,
KeyCacheObject key,
AffinityTopologyVersion topVer)
Checks whether near cache should be updated.
|
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
CacheDistributedGetFutureAdapter.checkRetryPermits(KeyCacheObject key,
ClusterNode node,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping) |
GridDhtFuture<Collection<GridCacheEntryInfo>> |
GridDhtCacheAdapter.getDhtAsync(UUID reader,
long msgId,
Map<KeyCacheObject,Boolean> keys,
boolean addReaders,
boolean readThrough,
AffinityTopologyVersion topVer,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean recovery,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
protected void |
GridPartitionedGetFuture.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
protected void |
GridPartitionedGetFuture.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
protected abstract void |
CacheDistributedGetFutureAdapter.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
protected abstract void |
CacheDistributedGetFutureAdapter.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
void |
GridDhtTransactionalCacheAdapter.removeLocks(UUID nodeId,
GridCacheVersion ver,
Iterable<KeyCacheObject> keys,
boolean unmap) |
| Constructor and Description |
|---|
GridDhtCacheEntry(GridCacheContext ctx,
AffinityTopologyVersion topVer,
KeyCacheObject key) |
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
KeyCacheObject key,
boolean addRdr,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
GridPartitionedSingleGetFuture(GridCacheContext cctx,
KeyCacheObject key,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean forcePrimary,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery,
String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
| Constructor and Description |
|---|
AbstractMiniFuture(ClusterNode node,
LinkedHashMap<KeyCacheObject,Boolean> keys,
AffinityTopologyVersion topVer) |
CacheDistributedGetFutureAdapter(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
@Nullable UUID subjId,
int taskNameHash,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean recovery,
boolean addReaders,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
boolean recovery,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot,
ClusterNode affNode) |
| 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) |
KeyCacheObject |
GridNearAtomicSingleUpdateRequest.key(int idx) |
abstract KeyCacheObject |
GridNearAtomicAbstractUpdateRequest.key(int idx) |
KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.key(int idx) |
abstract KeyCacheObject |
GridDhtAtomicAbstractUpdateRequest.key(int idx) |
KeyCacheObject |
GridDhtAtomicUpdateRequest.nearKey(int idx) |
KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.nearKey(int idx) |
abstract KeyCacheObject |
GridDhtAtomicAbstractUpdateRequest.nearKey(int idx) |
KeyCacheObject |
GridDhtAtomicUpdateRequest.obsoleteNearKey(int idx) |
KeyCacheObject |
GridDhtAtomicSingleUpdateRequest.obsoleteNearKey(int idx) |
abstract KeyCacheObject |
GridDhtAtomicAbstractUpdateRequest.obsoleteNearKey(int idx) |
| Modifier and Type | Method and Description |
|---|---|
Collection<KeyCacheObject> |
GridNearAtomicUpdateResponse.failedKeys() |
Collection<KeyCacheObject> |
UpdateErrors.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 |
GridDhtAtomicNearResponse.addFailedKey(KeyCacheObject key,
Throwable e) |
void |
GridNearAtomicUpdateResponse.addFailedKey(KeyCacheObject key,
Throwable e)
Adds key to collection of failed keys.
|
protected abstract void |
GridDhtAtomicAbstractUpdateFuture.addNearKey(KeyCacheObject key,
GridDhtCacheEntry.ReaderId[] readers) |
void |
GridDhtAtomicUpdateRequest.addNearWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridDhtAtomicSingleUpdateRequest.addNearWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addNearWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long expireTime) |
void |
GridNearAtomicFullUpdateRequest.addUpdateEntry(KeyCacheObject key,
@Nullable Object val,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateRequest.addUpdateEntry(KeyCacheObject key,
@Nullable Object val,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateInvokeRequest.addUpdateEntry(KeyCacheObject key,
@Nullable Object val,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
boolean |
GridDhtAtomicUpdateRequest.hasKey(KeyCacheObject key) |
boolean |
GridDhtAtomicSingleUpdateRequest.hasKey(KeyCacheObject key) |
abstract boolean |
GridDhtAtomicAbstractUpdateRequest.hasKey(KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
@Nullable IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
@Nullable TransactionIsolation isolation,
long createTtl,
long accessTtl) |
void |
GridDhtAtomicUpdateResponse.nearEvicted(List<KeyCacheObject> nearEvicted) |
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.
|
| 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,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObj,
boolean recovery,
@Nullable MvccSnapshot mvccSnapshot,
@Nullable String txLbl) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
@Nullable IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
@Nullable 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 |
|---|
GridDhtDetachedCacheEntry(GridCacheContext ctx,
KeyCacheObject key) |
| Constructor and Description |
|---|
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
@Nullable 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(GridCacheContext cctx,
Collection<KeyCacheObject> keys,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
AffinityTopologyVersion topVer,
Collection<KeyCacheObject> keys) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLocalPartition.onDeferredDelete(int cacheId,
KeyCacheObject key,
GridCacheVersion ver) |
| 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() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearLockMapping.addKey(KeyCacheObject key) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
@Nullable GridCacheVersion dhtVer,
GridCacheContext ctx)
Adds a key.
|
GridCacheMapEntry |
GridNearCacheAdapter.entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridNearCacheEntry |
GridNearCacheAdapter.entryExx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
@Nullable 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,
@Nullable AffinityTopologyVersion entryTopVer,
Collection<KeyCacheObject> keys,
boolean deserializeBinary,
boolean skipVals,
boolean keepCacheObjects,
boolean skipStore,
boolean recovery,
boolean readRepair,
boolean needVer) |
protected IgniteInternalFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
@Nullable IgniteTxLocalEx tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
@Nullable 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) |
protected void |
GridNearGetFuture.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
protected void |
GridNearGetFuture.map(Collection<KeyCacheObject> keys,
Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped,
AffinityTopologyVersion topVer) |
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) |
GridNearLockMapping(ClusterNode node,
KeyCacheObject firstKey)
Creates near lock mapping for specified node and key.
|
GridNearSingleGetRequest(int cacheId,
long futId,
KeyCacheObject key,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipVals,
boolean addReader,
boolean needVer,
boolean addDepInfo,
boolean recovery,
@Nullable String txLbl,
MvccSnapshot mvccSnapshot) |
| Constructor and Description |
|---|
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
boolean forcePrimary,
@Nullable IgniteTxLocalEx tx,
@Nullable UUID subjId,
String taskName,
boolean deserializeBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
boolean recovery) |
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
@NotNull AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean addReader,
boolean skipVals,
boolean addDepInfo,
boolean recovery,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
GridNearLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
@Nullable GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary,
boolean recovery) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<KeyCacheObject,EntryGetResult> |
GridNearReadRepairAbstractFuture.ctx
Context.
|
protected Map<ClusterNode,GridPartitionedGetFuture<KeyCacheObject,EntryGetResult>> |
GridNearReadRepairAbstractFuture.futs
Affinity node's get futures.
|
protected Collection<KeyCacheObject> |
GridNearReadRepairAbstractFuture.keys
Context.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridNearReadRepairAbstractFuture.onResult(IgniteInternalFuture<Map<KeyCacheObject,EntryGetResult>> finished)
Collects results of each 'get' future and prepares an overall result of the operation.
|
| Constructor and Description |
|---|
GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer,
GridCacheContext<KeyCacheObject,EntryGetResult> ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairAbstractFuture.
|
GridNearReadRepairAbstractFuture(AffinityTopologyVersion topVer,
GridCacheContext<KeyCacheObject,EntryGetResult> ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairAbstractFuture.
|
GridNearReadRepairCheckOnlyFuture(GridCacheContext ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
boolean skipVals,
boolean needVer,
boolean keepCacheObjects,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairCheckOnlyFuture.
|
GridNearReadRepairFuture(AffinityTopologyVersion topVer,
GridCacheContext ctx,
Collection<KeyCacheObject> keys,
boolean readThrough,
String taskName,
boolean deserializeBinary,
boolean recovery,
IgniteCacheExpiryPolicy expiryPlc,
IgniteInternalTx tx)
Creates a new instance of GridNearReadRepairFuture.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.replicate(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridLocalLockFuture.addEntries(Collection<KeyCacheObject> keys) |
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
@Nullable 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 |
|---|---|
KeyCacheObject |
MvccTxEntry.key() |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
| Constructor and Description |
|---|
MvccTxEntry(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyCacheObject |
CacheDataRowAdapter.key |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
CacheSearchRow.key() |
KeyCacheObject |
CacheDataRowAdapter.key() |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x) |
GridCursor<? extends CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.cursor(int cacheId,
KeyCacheObject lower,
KeyCacheObject upper,
Object x,
MvccSnapshot mvccSnapshot) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.find(GridCacheContext cctx,
KeyCacheObject key) |
void |
GridCacheOffheapManager.GridCacheDataStore.invoke(GridCacheContext cctx,
KeyCacheObject key,
IgniteCacheOffheapManager.OffheapInvokeClosure c) |
void |
CacheDataRowAdapter.key(KeyCacheObject key) |
void |
CacheDataRow.key(KeyCacheObject key) |
GridCursor<CacheDataRow> |
GridCacheOffheapManager.GridCacheDataStore.mvccAllVersionsCursor(GridCacheContext cctx,
KeyCacheObject key,
Object x)
Returns iterator over the all row versions for the given key.
|
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyHistoryIfAbsent(GridCacheContext cctx,
KeyCacheObject key,
List<GridCacheMvccEntryInfo> hist)
Tries to apply entry history.
|
void |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.mvccFind(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot) |
List<IgniteBiTuple<Object,MvccVersion>> |
GridCacheOffheapManager.GridCacheDataStore.mvccFindAllVersions(GridCacheContext cctx,
KeyCacheObject key)
For testing only.
|
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccLock(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccSnapshot) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccRemove(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot mvccVer,
CacheEntryPredicate filter,
boolean primary,
boolean needHistory,
boolean needOldVal,
boolean retVal) |
void |
GridCacheOffheapManager.GridCacheDataStore.mvccRemoveAll(GridCacheContext cctx,
KeyCacheObject key) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccVer,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
void |
GridCacheOffheapManager.GridCacheDataStore.remove(GridCacheContext cctx,
KeyCacheObject key,
int partId) |
void |
GridCacheOffheapManager.GridCacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
| Constructor and Description |
|---|
CacheDataRowAdapter(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
DataRowCacheAware(KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
boolean storeCacheId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryManager.remove(KeyCacheObject key,
@Nullable CacheDataRow prevRow) |
| 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,
@Nullable 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,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable Object |
GridCacheStoreManagerAdapter.load(@Nullable IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
@Nullable Object |
CacheStoreManager.load(@Nullable IgniteInternalTx tx,
KeyCacheObject key)
Loads data from persistent store.
|
boolean |
GridCacheStoreManagerAdapter.put(@Nullable IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.put(@Nullable IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.remove(@Nullable IgniteInternalTx tx,
KeyCacheObject key) |
boolean |
CacheStoreManager.remove(@Nullable IgniteInternalTx tx,
KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.loadAll(@Nullable IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
IgniteBiInClosure<KeyCacheObject,Object> vis)
Loads data from persistent store.
|
boolean |
CacheStoreManager.loadAll(@Nullable 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(@Nullable IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
void |
CacheStoreManager.localStoreLoadAll(@Nullable IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
boolean |
GridCacheStoreManagerAdapter.putAll(@Nullable IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.putAll(@Nullable IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.removeAll(@Nullable IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys) |
boolean |
CacheStoreManager.removeAll(@Nullable IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys) |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
IgniteTxKey.key() |
KeyCacheObject |
IgniteTxEntry.key() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key) |
@Nullable 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) |
void |
IgniteTxHandler.mvccEnlistBatch(GridDhtTxRemote tx,
GridCacheContext ctx,
EnlistOperation op,
List<KeyCacheObject> keys,
List<Message> vals,
MvccSnapshot snapshot,
IgniteUuid futId,
int batchNum)
Writes updated values on the backup node.
|
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 | Field and Description |
|---|---|
KeyCacheObject |
PendingRow.key |
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
SearchRow.key() |
| Modifier and Type | Method and Description |
|---|---|
void |
DataRow.key(KeyCacheObject key) |
| Constructor and Description |
|---|
DataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId) |
SearchRow(int cacheId,
KeyCacheObject key) |
| Constructor and Description |
|---|
MvccDataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateDataRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
| Constructor and Description |
|---|
MvccLinkAwareSearchRow(int cacheId,
KeyCacheObject key,
long crdVer,
long mvccCntr,
int mvccOpCntr,
long link) |
MvccMaxSearchRow(int cacheId,
KeyCacheObject key) |
MvccMinSearchRow(int cacheId,
KeyCacheObject key) |
MvccSearchRow(int cacheId,
KeyCacheObject key,
long crdVer,
long cntr,
int opCntr) |
MvccSnapshotSearchRow(GridCacheContext cctx,
KeyCacheObject key,
MvccSnapshot snapshot)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
PartitionEntryHashRecord.key() |
| Constructor and Description |
|---|
PartitionEntryHashRecord(int cacheId,
String cacheName,
KeyCacheObject key,
String keyStr,
byte[] keyBytes,
GridCacheVersion ver,
int valHash) |
PartitionEntryHashRecord(int cacheId,
String cacheName,
KeyCacheObject key,
String keyStr,
byte[] keyBytes,
GridCacheVersion ver,
int valHash,
CacheObject val,
String valStr,
byte[] valBytes) |
| 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,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver)
Constructor used for local store load when key and value are available.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UserKeyCacheObjectImpl
Wraps key provided by user, must be serialized before stored in cache.
|
| Modifier and Type | Method and Description |
|---|---|
KeyCacheObject |
UserKeyCacheObjectImpl.copy(int part) |
KeyCacheObject |
IgniteCacheObjectProcessor.toCacheKeyObject(CacheObjectContext ctx,
@Nullable GridCacheContext cctx,
Object obj,
boolean userObj) |
KeyCacheObject |
IgniteCacheObjectProcessor.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(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Checks if offheap space contains value for the given key.
|
void |
GridOffHeapProcessor.enableEviction(@Nullable 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. |
@Nullable byte[] |
GridOffHeapProcessor.get(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Gets value bytes from offheap space for the given key.
|
<T> T |
GridOffHeapProcessor.getValue(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
@Nullable ClassLoader ldr)
Gets value from offheap space for the given key.
|
void |
GridOffHeapProcessor.put(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
byte[] valBytes)
Puts the given value to offheap space for the given key.
|
@Nullable byte[] |
GridOffHeapProcessor.remove(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Removes value from offheap space for the given key.
|
boolean |
GridOffHeapProcessor.removex(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from offheap space for the given key.
|
@Nullable IgniteBiTuple<Long,Integer> |
GridOffHeapProcessor.valuePointer(@Nullable String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes)
Gets value pointer from offheap space for the given key.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteDataStreamer<KeyCacheObject,CacheObject> |
ClientDataStreamerHandle.getStreamer()
Gets the wrapped streamer.
|
| Constructor and Description |
|---|
ClientDataStreamerHandle(IgniteDataStreamer<KeyCacheObject,CacheObject> streamer)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridQueryProcessor.belongsToTable(GridCacheContext cctx,
String expCacheName,
String expTblName,
KeyCacheObject key,
CacheObject val)
Check whether provided key and value belongs to expected cache and table.
|
@Nullable QueryTypeDescriptorImpl |
GridQueryProcessor.typeByValue(String cacheName,
CacheObjectContext coctx,
KeyCacheObject key,
CacheObject val,
boolean checkType) |
void |
GridQueryProcessor.validateKeyAndValue(CacheObjectContext coctx,
KeyCacheObject key,
CacheObject val)
Performs validation of provided key and value against configured constraints.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021