Uses of Interface
org.apache.ignite.internal.processors.cache.KeyCacheObject
-
-
Uses of KeyCacheObject in org.apache.ignite.internal
Method parameters in org.apache.ignite.internal with type arguments of type KeyCacheObject Modifier and Type Method Description voidIgniteDiagnosticPrepareContext. txKeyInfo(UUID nodeId, int cacheId, Collection<KeyCacheObject> keys, String msg) -
Uses of KeyCacheObject in org.apache.ignite.internal.binary
Classes in org.apache.ignite.internal.binary that implement KeyCacheObject Modifier and Type Class Description classBinaryObjectImplBinary object implementation.Methods in org.apache.ignite.internal.binary that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectBinaryObjectImpl. copy(int part) -
Uses of KeyCacheObject in org.apache.ignite.internal.pagemem.wal.record
Fields in org.apache.ignite.internal.pagemem.wal.record declared as KeyCacheObject Modifier and Type Field Description protected KeyCacheObjectDataEntry. keyCache object key.Methods in org.apache.ignite.internal.pagemem.wal.record that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectDataEntry. key()KeyCacheObjectLazyDataEntry. key()Methods in org.apache.ignite.internal.pagemem.wal.record with parameters of type KeyCacheObject Modifier and Type Method Description static ObjectUnwrapDataEntry. unwrapKey(KeyCacheObject key, boolean keepBinary, CacheObjectValueContext cacheObjValCtx)Constructors in org.apache.ignite.internal.pagemem.wal.record with parameters of type KeyCacheObject Constructor Description DataEntry(int cacheId, KeyCacheObject key, @Nullable CacheObject val, GridCacheOperation op, GridCacheVersion nearXidVer, GridCacheVersion writeVer, long expireTime, int partId, long partCnt, byte flags)UnwrapDataEntry(int cacheId, KeyCacheObject key, CacheObject val, GridCacheOperation op, GridCacheVersion nearXidVer, GridCacheVersion writeVer, long expireTime, int partId, long partCnt, CacheObjectValueContext cacheObjValCtx, boolean keepBinary, byte flags) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache
Classes in org.apache.ignite.internal.processors.cache that implement KeyCacheObject Modifier and Type Class Description protected static classIgniteCacheOffheapManagerImpl.ExpiredKeyCacheObjectThis entry key is used to indicate that an expired entry has already been deleted from PendingEntriesTree and doesn't need to participate in PendingEntriesTree cleanup again.classKeyCacheObjectImplFields in org.apache.ignite.internal.processors.cache declared as KeyCacheObject Modifier and Type Field Description protected KeyCacheObjectGridCacheMapEntry. keyKey.protected KeyCacheObjectCacheLazyEntry. keyObjKey cache object.Fields in org.apache.ignite.internal.processors.cache with type parameters of type KeyCacheObject Modifier and Type Field Description ConcurrentMap<KeyCacheObject,GridCacheMapEntry>GridCacheConcurrentMap.CacheMapHolder. mapMethods in org.apache.ignite.internal.processors.cache that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectKeyCacheObject. copy(int part)KeyCacheObjectKeyCacheObjectImpl. copy(int part)KeyCacheObjectCacheEvictionEntry. key()KeyCacheObjectCacheInvokeDirectResult. key()KeyCacheObjectGridCacheEntryEx. key()KeyCacheObjectGridCacheEntryInfo. key()KeyCacheObjectGridCacheMapEntry. key()KeyCacheObjectGridCacheContext. toCacheKeyObject(byte[] bytes)KeyCacheObjectGridCacheContext. toCacheKeyObject(Object obj)Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type KeyCacheObject Modifier and Type Method Description GridCloseableIterator<KeyCacheObject>IgniteCacheOffheapManager. cacheKeysIterator(int cacheId, int part)GridCloseableIterator<KeyCacheObject>IgniteCacheOffheapManagerImpl. cacheKeysIterator(int cacheId, int part)Collection<KeyCacheObject>GridCacheContext. cacheKeysView(Collection<?> keys)@Nullable Map<KeyCacheObject,GridCacheVersion>GridCacheAdapter.CacheExpiryPolicy. entries()@Nullable Map<KeyCacheObject,GridCacheVersion>IgniteCacheExpiryPolicy. entries()static IgniteClosure<GridCacheEntryEx,KeyCacheObject>GridCacheUtils. entry2Key()@Nullable Map<UUID,Collection<IgniteBiTuple<KeyCacheObject,GridCacheVersion>>>GridCacheAdapter.CacheExpiryPolicy. readers()@Nullable Map<UUID,Collection<IgniteBiTuple<KeyCacheObject,GridCacheVersion>>>IgniteCacheExpiryPolicy. readers()Methods in org.apache.ignite.internal.processors.cache with parameters of type KeyCacheObject Modifier and Type Method Description voidCacheGroupContext. addCacheEvent(int part, KeyCacheObject key, UUID evtNodeId, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, boolean keepBinary)voidGridCacheReturn. addEntryProcessResult(GridCacheContext cctx, KeyCacheObject key, @Nullable Object key0, @Nullable Object res, @Nullable Exception err, boolean keepBinary)voidGridCacheEventManager. addEvent(int part, KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable GridCacheMvccCandidate owner, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)voidGridCacheEventManager. addEvent(int part, KeyCacheObject key, UUID evtNodeId, @Nullable GridCacheMvccCandidate owner, int type, @Nullable CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)voidGridCacheEventManager. 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, @Nullable String cloClsName, @Nullable String taskName, boolean keepBinary)voidGridCacheEventManager. addEvent(int part, KeyCacheObject key, UUID nodeId, @Nullable IgniteInternalTx tx, GridCacheMvccCandidate owner, int type, CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)<K1,V1>
voidGridCacheContext. 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>
voidGridCacheContext. 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>
voidGridCacheContext. addResult(Map<K1,V1> map, KeyCacheObject key, EntryGetResult getRes, boolean skipVals, boolean keepCacheObjects, boolean deserializeBinary, boolean cpy, boolean needVer)GridCacheMapEntryGridCacheMapEntryFactory. create(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key)static @Nullable GridCacheUtils.BackupPostProcessingClosureGridCacheUtils. 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.CacheDataRowIgniteCacheOffheapManager.CacheDataStore. createRow(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, @Nullable CacheDataRow oldRow)CacheDataRowIgniteCacheOffheapManagerImpl.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>IgniteCacheOffheapManager.CacheDataStore. cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper, Object x)GridCursor<? extends CacheDataRow>IgniteCacheOffheapManagerImpl.CacheDataStoreImpl. cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper)GridCursor<? extends CacheDataRow>IgniteCacheOffheapManagerImpl.CacheDataStoreImpl. cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper, Object x)GridCacheEntryExGridCacheAdapter. entryEx(KeyCacheObject key)GridCacheEntryExGridCacheAdapter. entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)CacheDataRowIgniteCacheOffheapManager.CacheDataStore. find(GridCacheContext cctx, KeyCacheObject key)CacheDataRowIgniteCacheOffheapManagerImpl.CacheDataStoreImpl. find(GridCacheContext cctx, KeyCacheObject key)@Nullable GridCacheMapEntryGridCacheConcurrentMap. getEntry(GridCacheContext ctx, KeyCacheObject key)Returns the entry associated with the specified key in the HashMap.@Nullable GridCacheMapEntryGridCacheConcurrentMapImpl. getEntry(GridCacheContext ctx, KeyCacheObject key)Returns the entry associated with the specified key in the HashMap.@Nullable GridCacheMapEntryGridNoStorageCacheMap. getEntry(GridCacheContext ctx, KeyCacheObject key)Returns the entry associated with the specified key in the HashMap.voidIgniteCacheOffheapManager.CacheDataStore. invoke(GridCacheContext cctx, KeyCacheObject key, IgniteCacheOffheapManager.OffheapInvokeClosure c)voidIgniteCacheOffheapManager. invoke(GridCacheContext cctx, KeyCacheObject key, GridDhtLocalPartition part, IgniteCacheOffheapManager.OffheapInvokeClosure c)voidIgniteCacheOffheapManagerImpl.CacheDataStoreImpl. invoke(GridCacheContext cctx, KeyCacheObject key, IgniteCacheOffheapManager.OffheapInvokeClosure c)voidIgniteCacheOffheapManagerImpl. invoke(GridCacheContext cctx, KeyCacheObject key, GridDhtLocalPartition part, IgniteCacheOffheapManager.OffheapInvokeClosure c)voidGridCacheEntryInfo. key(KeyCacheObject key)protected booleanGridCacheClearAllRunnable. owns(KeyCacheObject key)Check whether this worker owns particular key.@Nullable GridCacheEntryExGridCacheAdapter. peekEx(KeyCacheObject key)GridCacheMapEntryGridCacheConcurrentMap. putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)protected GridCacheMapEntryGridCacheConcurrentMapImpl. putEntryIfObsoleteOrAbsent(@Nullable GridCacheConcurrentMap.CacheMapHolder hld, GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)GridCacheMapEntryGridCacheConcurrentMapImpl. putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)GridCacheMapEntryGridNoStorageCacheMap. putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)@Nullable CacheDataRowIgniteCacheOffheapManager. read(GridCacheContext cctx, KeyCacheObject key)@Nullable CacheDataRowIgniteCacheOffheapManagerImpl. read(GridCacheContext cctx, KeyCacheObject key)voidGridCacheEventManager. readEvent(KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable String txLbl, @Nullable CacheObject val, @Nullable String taskName, boolean keepBinary)protected @Nullable ObjectGridCacheMapEntry. readThrough(@Nullable IgniteInternalTx tx, KeyCacheObject key, boolean reload, String taskName)voidIgniteCacheOffheapManager.CacheDataStore. remove(GridCacheContext cctx, KeyCacheObject key, int partId)voidIgniteCacheOffheapManager. remove(GridCacheContext cctx, KeyCacheObject key, int partId, GridDhtLocalPartition part)voidIgniteCacheOffheapManagerImpl.CacheDataStoreImpl. remove(GridCacheContext cctx, KeyCacheObject key, int partId)voidIgniteCacheOffheapManagerImpl. remove(GridCacheContext cctx, KeyCacheObject key, int partId, GridDhtLocalPartition part)voidGridCacheAdapter. removeIfObsolete(KeyCacheObject key)voidGridCacheAdapter.CacheExpiryPolicy. ttlUpdated(KeyCacheObject key, GridCacheVersion ver, @Nullable Collection<UUID> rdrs)voidIgniteCacheExpiryPolicy. ttlUpdated(KeyCacheObject key, GridCacheVersion ver, @Nullable Collection<UUID> rdrs)Callback for ttl update on entry access.IgniteTxKeyGridCacheContext. txKey(KeyCacheObject key)voidIgniteCacheOffheapManager.CacheDataStore. update(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, @Nullable CacheDataRow oldRow)voidIgniteCacheOffheapManager. update(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, GridDhtLocalPartition part, @Nullable CacheDataRow oldRow)voidIgniteCacheOffheapManagerImpl.CacheDataStoreImpl. update(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, @Nullable CacheDataRow oldRow)voidIgniteCacheOffheapManagerImpl. update(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, GridDhtLocalPartition part, @Nullable CacheDataRow oldRow)voidGridCacheContext. validateKeyAndValue(KeyCacheObject key, CacheObject val)Performs validation of provided key and value against configured constraints.Method parameters in org.apache.ignite.internal.processors.cache with type arguments of type KeyCacheObject Modifier and Type Method Description voidGridCacheAdapter. clearLocally(Collection<KeyCacheObject> keys, boolean readers)IgniteInternalFuture<?>GridCacheMvccManager. finishKeys(Collection<KeyCacheObject> keys, int cacheId, AffinityTopologyVersion topVer)voidGridCacheAdapter. putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)Store DR data.voidGridCacheProxyImpl. putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)Store DR data.voidIgniteInternalCache. putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)Store DR data.IgniteInternalFuture<?>GridCacheAdapter. putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)Store DR data asynchronously.IgniteInternalFuture<?>GridCacheProxyImpl. putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)Store DR data asynchronously.IgniteInternalFuture<?>IgniteInternalCache. putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)Store DR data asynchronously.voidGridCacheAdapter. removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)Removes DR data.voidGridCacheProxyImpl. removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)Removes DR data.voidIgniteInternalCache. removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)Removes DR data.IgniteInternalFuture<?>GridCacheAdapter. removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)Removes DR data asynchronously.IgniteInternalFuture<?>GridCacheProxyImpl. removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)Removes DR data asynchronously.IgniteInternalFuture<?>IgniteInternalCache. removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)Removes DR data asynchronously.GridDhtFuture<Object>GridCachePreloader. request(GridCacheContext cctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer)Requests that preloader sends the request for the key.GridDhtFuture<Object>GridCachePreloaderAdapter. request(GridCacheContext ctx, 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 parameters in org.apache.ignite.internal.processors.cache with type arguments of type KeyCacheObject Constructor Description CacheMapHolder(GridCacheContext cctx, ConcurrentMap<KeyCacheObject,GridCacheMapEntry> map) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.binary
Methods in org.apache.ignite.internal.processors.cache.binary that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectCacheObjectBinaryProcessorImpl. toCacheKeyObject(CacheObjectContext ctx, @Nullable GridCacheContext cctx, Object obj, boolean userObj)protected KeyCacheObjectCacheObjectBinaryProcessorImpl. toCacheKeyObject0(CacheObjectContext ctx, @Nullable GridCacheContext cctx, Object obj, boolean userObj)KeyCacheObjectCacheObjectBinaryProcessorImpl. toKeyCacheObject(CacheObjectContext ctx, byte type, byte[] bytes) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed
Methods in org.apache.ignite.internal.processors.cache.distributed that return types with arguments of type KeyCacheObject Modifier and Type Method Description List<KeyCacheObject>GridCacheTtlUpdateRequest. keys()List<KeyCacheObject>GridDistributedLockRequest. keys()List<KeyCacheObject>GridDistributedUnlockRequest. keys()List<KeyCacheObject>GridCacheTtlUpdateRequest. nearKeys()Methods in org.apache.ignite.internal.processors.cache.distributed with parameters of type KeyCacheObject Modifier and Type Method Description voidGridCacheTtlUpdateRequest. addEntry(KeyCacheObject key, GridCacheVersion ver)voidGridDistributedUnlockRequest. addKey(KeyCacheObject key)voidGridDistributedLockRequest. addKeyBytes(KeyCacheObject key, boolean retVal)Adds a key.voidGridCacheTtlUpdateRequest. addNearEntry(KeyCacheObject key, GridCacheVersion ver)GridTuple<CacheObject>GridDistributedTxRemoteAdapter. peek(GridCacheContext cacheCtx, boolean failFast, KeyCacheObject key)voidGridDistributedCacheAdapter. removeVersionedEntry(KeyCacheObject key, GridCacheVersion ver)Method parameters in org.apache.ignite.internal.processors.cache.distributed with type arguments of type KeyCacheObject Modifier and Type Method 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)Constructors in org.apache.ignite.internal.processors.cache.distributed with parameters of type KeyCacheObject Constructor Description GridDistributedCacheEntry(GridCacheContext ctx, KeyCacheObject key) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.dht
Fields in org.apache.ignite.internal.processors.cache.distributed.dht with type parameters of type KeyCacheObject Modifier and Type Field Description protected LinkedHashMap<KeyCacheObject,Boolean>CacheDistributedGetFutureAdapter.AbstractMiniFuture. keysMapped keys.protected Collection<KeyCacheObject>CacheDistributedGetFutureAdapter. keysKeys.Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return types with arguments of type KeyCacheObject Modifier and Type Method Description Collection<KeyCacheObject>CacheDistributedGetFutureAdapter. keys()List<KeyCacheObject>GridDhtUnlockRequest. nearKeys()Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type KeyCacheObject Modifier and Type Method Description voidGridDhtLockRequest. addDhtKey(KeyCacheObject key, boolean invalidateEntry)Adds a DHT key.voidGridDhtUnlockRequest. addNearKey(KeyCacheObject key)Adds a Near key.protected booleanCacheDistributedGetFutureAdapter. checkRetryPermits(KeyCacheObject key, ClusterNode node, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> missedNodesToKeysMapping)protected GridDistributedCacheEntryGridDhtCacheAdapter. createEntry(KeyCacheObject key)GridCacheEntryExGridDhtCacheAdapter. entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)GridDhtCacheEntryGridDhtCacheAdapter. entryExx(KeyCacheObject key)GridDhtCacheEntryGridDhtCacheAdapter. entryExx(KeyCacheObject key, AffinityTopologyVersion topVer)@Nullable GridCacheMapEntryGridCachePartitionedConcurrentMap. getEntry(GridCacheContext ctx, KeyCacheObject key)Returns the entry associated with the specified key in the HashMap.@Nullable GridCacheVersionGridDhtLockRequest. owned(KeyCacheObject key)voidGridDhtLockRequest. owned(KeyCacheObject key, GridCacheVersion ownerMapped)Sets owner and its mapped version.@Nullable GridDhtCacheEntryGridDhtCacheAdapter. peekExx(KeyCacheObject key)GridCacheMapEntryGridCachePartitionedConcurrentMap. putEntryIfObsoleteOrAbsent(GridCacheContext ctx, AffinityTopologyVersion topVer, KeyCacheObject key, boolean create, boolean skipReserve)protected booleanGridDhtTxLocal. updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer)Checks whether near cache should be updated.protected booleanGridDhtTxRemote. updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer)Checks whether near cache should be updated.Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type KeyCacheObject Modifier and Type Method Description protected booleanCacheDistributedGetFutureAdapter. 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, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean recovery, @Nullable String txLbl)IgniteInternalFuture<Boolean>GridDhtTransactionalCacheAdapter. lockAllAsync(@Nullable Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long createTtl, long accessTtl)GridDhtFuture<Boolean>GridDhtTransactionalCacheAdapter. lockAllAsyncInternal(@Nullable Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary)Acquires locks in partitioned cache.protected abstract voidCacheDistributedGetFutureAdapter. map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)protected abstract voidCacheDistributedGetFutureAdapter. map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)protected voidGridPartitionedGetFuture. map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)protected voidGridPartitionedGetFuture. map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)voidGridDhtTransactionalCacheAdapter. removeLocks(UUID nodeId, GridCacheVersion ver, Iterable<KeyCacheObject> keys, boolean unmap)Constructors in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type KeyCacheObject Constructor 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, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, @Nullable String txLbl)GridPartitionedSingleGetFuture(GridCacheContext cctx, KeyCacheObject key, AffinityTopologyVersion topVer, boolean readThrough, boolean forcePrimary, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, boolean recovery, String txLbl)Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type KeyCacheObject Constructor Description AbstractMiniFuture(ClusterNode node, LinkedHashMap<KeyCacheObject,Boolean> keys, AffinityTopologyVersion topVer)CacheDistributedGetFutureAdapter(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, 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, int taskNameHash, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean recovery, boolean addReaders, @Nullable String txLbl)GridPartitionedGetFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, String taskName, boolean deserializeBinary, boolean recovery, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObjects, @Nullable String txLbl, ClusterNode affNode) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.dht.atomic
Fields in org.apache.ignite.internal.processors.cache.distributed.dht.atomic declared as KeyCacheObject Modifier and Type Field Description protected KeyCacheObjectGridDhtAtomicSingleUpdateRequest. keyKey to update.protected KeyCacheObjectGridNearAtomicSingleUpdateRequest. keyKey to update.Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that return KeyCacheObject Modifier and Type Method Description abstract KeyCacheObjectGridDhtAtomicAbstractUpdateRequest. key(int idx)KeyCacheObjectGridDhtAtomicSingleUpdateRequest. key(int idx)KeyCacheObjectGridDhtAtomicUpdateRequest. key(int idx)abstract KeyCacheObjectGridNearAtomicAbstractUpdateRequest. key(int idx)KeyCacheObjectGridNearAtomicFullUpdateRequest. key(int idx)KeyCacheObjectGridNearAtomicSingleUpdateRequest. key(int idx)abstract KeyCacheObjectGridDhtAtomicAbstractUpdateRequest. nearKey(int idx)KeyCacheObjectGridDhtAtomicSingleUpdateRequest. nearKey(int idx)KeyCacheObjectGridDhtAtomicUpdateRequest. nearKey(int idx)abstract KeyCacheObjectGridDhtAtomicAbstractUpdateRequest. obsoleteNearKey(int idx)KeyCacheObjectGridDhtAtomicSingleUpdateRequest. obsoleteNearKey(int idx)KeyCacheObjectGridDhtAtomicUpdateRequest. obsoleteNearKey(int idx)Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that return types with arguments of type KeyCacheObject Modifier and Type Method Description Collection<KeyCacheObject>GridNearAtomicUpdateResponse. failedKeys()Collection<KeyCacheObject>UpdateErrors. failedKeys()abstract List<KeyCacheObject>GridNearAtomicAbstractUpdateRequest. keys()List<KeyCacheObject>GridNearAtomicFullUpdateRequest. keys()List<KeyCacheObject>GridNearAtomicSingleUpdateRequest. keys()Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with parameters of type KeyCacheObject Modifier and Type Method Description protected abstract voidGridDhtAtomicAbstractUpdateFuture. addDhtKey(KeyCacheObject key, List<ClusterNode> dhtNodes)voidGridDhtAtomicNearResponse. addFailedKey(KeyCacheObject key, Throwable e)voidGridNearAtomicUpdateResponse. addFailedKey(KeyCacheObject key, Throwable e)Adds key to collection of failed keys.protected abstract voidGridDhtAtomicAbstractUpdateFuture. addNearKey(KeyCacheObject key, GridDhtCacheEntry.ReaderId[] readers)abstract voidGridDhtAtomicAbstractUpdateRequest. addNearWriteValue(KeyCacheObject key, @Nullable CacheObject val, javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor, long ttl, long expireTime)voidGridDhtAtomicSingleUpdateRequest. addNearWriteValue(KeyCacheObject key, @Nullable CacheObject val, javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor, long ttl, long expireTime)voidGridDhtAtomicUpdateRequest. addNearWriteValue(KeyCacheObject key, @Nullable CacheObject val, javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor, long ttl, long expireTime)voidGridNearAtomicFullUpdateRequest. addUpdateEntry(KeyCacheObject key, @Nullable Object val, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer)voidGridNearAtomicSingleUpdateInvokeRequest. addUpdateEntry(KeyCacheObject key, @Nullable Object val, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer)voidGridNearAtomicSingleUpdateRequest. addUpdateEntry(KeyCacheObject key, @Nullable Object val, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer)abstract voidGridDhtAtomicAbstractUpdateRequest. 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)voidGridDhtAtomicSingleUpdateRequest. 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)voidGridDhtAtomicUpdateRequest. 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 booleanGridDhtAtomicAbstractUpdateRequest. hasKey(KeyCacheObject key)booleanGridDhtAtomicSingleUpdateRequest. hasKey(KeyCacheObject key)booleanGridDhtAtomicUpdateRequest. hasKey(KeyCacheObject key)Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with type arguments of type KeyCacheObject Modifier and Type Method 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)voidGridDhtAtomicUpdateResponse. nearEvicted(List<KeyCacheObject> nearEvicted)voidGridDhtAtomicCache. putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)Store DR data.IgniteInternalFuture<?>GridDhtAtomicCache. putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> conflictMap)Store DR data asynchronously.voidGridDhtAtomicCache. removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap)Removes DR data.IgniteInternalFuture<?>GridDhtAtomicCache. removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> conflictMap)Removes DR data asynchronously. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.dht.colocated
Methods in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with parameters of type KeyCacheObject Modifier and Type Method Description GridDistributedCacheEntryGridDhtColocatedCache. 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, String taskName, boolean deserializeBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObj, boolean recovery, @Nullable String txLbl)Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with type arguments of type KeyCacheObject Modifier and Type Method Description IgniteInternalFuture<Map<K,V>>GridDhtColocatedCache. loadAsync(@Nullable Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, AffinityTopologyVersion topVer, String taskName, boolean deserializeBinary, boolean recovery, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean skipVals, boolean needVer, boolean keepCacheObj, @Nullable String txLbl)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.voidGridDhtColocatedCache. removeLocks(long threadId, GridCacheVersion ver, Collection<KeyCacheObject> keys)Removes locks regardless of whether they are owned or not for given version and keys.Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with parameters of type KeyCacheObject Constructor Description GridDhtDetachedCacheEntry(GridCacheContext ctx, KeyCacheObject key)Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with type arguments of type KeyCacheObject Constructor Description GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx, Collection<KeyCacheObject> keys, @Nullable GridNearTxLocal tx, boolean read, boolean retval, long timeout, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary, boolean recovery) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.dht.preloader
Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that return types with arguments of type KeyCacheObject Modifier and Type Method Description Collection<KeyCacheObject>GridDhtForceKeysRequest. keys()Collection<KeyCacheObject>GridDhtForceKeysResponse. missedKeys()Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type KeyCacheObject Modifier and Type Method Description voidGridDhtForceKeysResponse. addMissed(KeyCacheObject key)Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with type arguments of type KeyCacheObject Modifier and Type Method Description GridDhtFuture<Object>GridDhtPreloader. request(GridCacheContext cctx, Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer)Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with type arguments of type KeyCacheObject Constructor Description GridDhtForceKeysFuture(GridCacheContext<K,V> cctx, AffinityTopologyVersion topVer, Collection<KeyCacheObject> keys) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.dht.topology
Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology with parameters of type KeyCacheObject Modifier and Type Method Description voidGridDhtLocalPartition. onDeferredDelete(int cacheId, KeyCacheObject key, GridCacheVersion ver) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.near
Methods in org.apache.ignite.internal.processors.cache.distributed.near that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectGridNearSingleGetRequest. key()Methods in org.apache.ignite.internal.processors.cache.distributed.near that return types with arguments of type KeyCacheObject Modifier and Type Method Description Collection<KeyCacheObject>GridNearLockMapping. distributedKeys()LinkedHashMap<KeyCacheObject,Boolean>GridNearGetRequest. keys()Collection<KeyCacheObject>GridNearLockMapping. mappedKeys()@Nullable List<KeyCacheObject>GridNearAtomicCache. processDhtAtomicUpdateRequest(UUID nodeId, GridDhtAtomicAbstractUpdateRequest req, GridDhtAtomicNearResponse res)Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type KeyCacheObject Modifier and Type Method Description voidGridNearLockMapping. addKey(KeyCacheObject key)voidGridNearLockRequest. addKeyBytes(KeyCacheObject key, boolean retVal, @Nullable GridCacheVersion dhtVer)Adds a key.GridCacheMapEntryGridNearCacheAdapter. entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)GridNearCacheEntryGridNearCacheAdapter. entryExx(KeyCacheObject key, AffinityTopologyVersion topVer)@Nullable GridNearCacheEntryGridNearCacheAdapter. peekExx(KeyCacheObject key)protected ObjectGridNearCacheEntry. readThrough(IgniteInternalTx tx, KeyCacheObject key, boolean reload, String taskName)Method parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type KeyCacheObject Modifier and Type Method Description protected IgniteCacheExpiryPolicyGridNearTxLocal. accessPolicy(GridCacheContext cacheCtx, Collection<KeyCacheObject> keys)voidGridNearLockMapping. 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, ReadRepairStrategy readRepairStrategy, boolean needVer)IgniteInternalFuture<Map<K,V>>GridNearCacheAdapter. loadAsync(@Nullable IgniteInternalTx tx, @Nullable Collection<KeyCacheObject> keys, boolean forcePrimary, String taskName, boolean deserializeBinary, boolean recovery, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, boolean skipVal, boolean skipStore, 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 voidGridNearGetFuture. map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)protected voidGridNearGetFuture. map(Collection<KeyCacheObject> keys, Map<ClusterNode,LinkedHashMap<KeyCacheObject,Boolean>> mapped, AffinityTopologyVersion topVer)voidGridNearAtomicCache. 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)voidGridNearAtomicCache. 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)voidGridNearTransactionalCache. removeLocks(GridCacheVersion ver, Collection<KeyCacheObject> keys)Removes locks regardless of whether they are owned or not for given version and keys.Constructors in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type KeyCacheObject Constructor 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, int taskNameHash, long createTtl, long accessTtl, boolean skipVals, boolean addReader, boolean needVer, boolean addDepInfo, boolean recovery, @Nullable String txLbl)Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type KeyCacheObject Constructor Description GridNearGetFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, boolean readThrough, boolean forcePrimary, @Nullable IgniteTxLocalEx tx, 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, int taskNameHash, long createTtl, long accessTtl, boolean addReader, boolean skipVals, boolean addDepInfo, boolean recovery, @Nullable String txLbl)GridNearLockFuture(GridCacheContext<?,?> cctx, Collection<KeyCacheObject> keys, @Nullable GridNearTxLocal tx, boolean read, boolean retval, long timeout, long createTtl, long accessTtl, boolean skipStore, boolean keepBinary, boolean recovery) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.distributed.near.consistency
Fields in org.apache.ignite.internal.processors.cache.distributed.near.consistency with type parameters of type KeyCacheObject Modifier and Type Field Description protected Map<ClusterNode,GridPartitionedGetFuture<KeyCacheObject,EntryGetResult>>GridNearReadRepairAbstractFuture. futsAffinity node's get futures.protected Collection<KeyCacheObject>GridNearReadRepairAbstractFuture. keysContext.protected Map<KeyCacheObject,ClusterNode>GridNearReadRepairAbstractFuture. primariesPrimaries per key.Methods in org.apache.ignite.internal.processors.cache.distributed.near.consistency that return types with arguments of type KeyCacheObject Modifier and Type Method Description protected Map<KeyCacheObject,EntryGetResult>GridNearReadRepairAbstractFuture. check()Checks consistency.protected Map<KeyCacheObject,EntryGetResult>GridNearReadRepairAbstractFuture. correct(Set<KeyCacheObject> keys)Calculates correct values.Map<KeyCacheObject,EntryGetResult>GridNearReadRepairAbstractFuture.IgniteConsistencyRepairFailedException. correctedMap()Repairable keys.Map<KeyCacheObject,EntryGetResult>IgniteAtomicConsistencyViolationException. correctedMap()protected Map<KeyCacheObject,EntryGetResult>GridNearReadRepairAbstractFuture. correctWithPrimary(Collection<KeyCacheObject> inconsistentKeys)Set<KeyCacheObject>GridNearReadRepairAbstractFuture.IgniteConsistencyRepairFailedException. irreparableKeys()Irreparable keys.Set<KeyCacheObject>GridNearReadRepairAbstractFuture.IgniteConsistencyCheckFailedException. keys()Inconsistent entries keys.Set<KeyCacheObject>IgniteAtomicConsistencyViolationException. keys()Inconsistent entries keys.abstract Set<KeyCacheObject>IgniteConsistencyViolationException. keys()Inconsistent entries keys.Set<KeyCacheObject>IgniteTransactionalConsistencyViolationException. keys()Inconsistent entries keys.Map<KeyCacheObject,EntryGetResult>IgniteAtomicConsistencyViolationException. primaryMap()Methods in org.apache.ignite.internal.processors.cache.distributed.near.consistency with parameters of type KeyCacheObject Modifier and Type Method Description voidIgniteAtomicConsistencyViolationException. onRepaired(KeyCacheObject key)Method parameters in org.apache.ignite.internal.processors.cache.distributed.near.consistency with type arguments of type KeyCacheObject Modifier and Type Method Description protected Map<KeyCacheObject,EntryGetResult>GridNearReadRepairAbstractFuture. correct(Set<KeyCacheObject> keys)Calculates correct values.protected Map<KeyCacheObject,EntryGetResult>GridNearReadRepairAbstractFuture. correctWithPrimary(Collection<KeyCacheObject> inconsistentKeys)protected voidGridNearReadRepairCheckOnlyFuture. onDoneIrreparable(Set<KeyCacheObject> irreparableKeys)protected voidGridNearReadRepairCheckOnlyFuture. onDoneRepairRequired(Map<KeyCacheObject,EntryGetResult> correcredMap)protected voidGridNearReadRepairAbstractFuture. onResult(IgniteInternalFuture<Map<KeyCacheObject,EntryGetResult>> finished)Collects results of each 'get' future and prepares an overall result of the operation.protected voidGridNearReadRepairAbstractFuture. recordConsistencyViolation(Collection<KeyCacheObject> inconsistentKeys, Map<KeyCacheObject,EntryGetResult> repairedEntries)protected voidGridNearReadRepairAbstractFuture. recordConsistencyViolation(Collection<KeyCacheObject> inconsistentKeys, Map<KeyCacheObject,EntryGetResult> repairedEntries) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.dr
Methods in org.apache.ignite.internal.processors.cache.dr with parameters of type KeyCacheObject Modifier and Type Method Description voidGridCacheDrManager. replicate(KeyCacheObject key, @Nullable CacheObject val, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType, AffinityTopologyVersion topVer)Performs replication.voidGridOsCacheDrManager. replicate(KeyCacheObject key, @Nullable CacheObject val, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType, AffinityTopologyVersion topVer)Performs replication. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.persistence
Fields in org.apache.ignite.internal.processors.cache.persistence declared as KeyCacheObject Modifier and Type Field Description protected KeyCacheObjectCacheDataRowAdapter. keyMethods in org.apache.ignite.internal.processors.cache.persistence that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectCacheDataRowAdapter. key()KeyCacheObjectCacheSearchRow. key()Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type KeyCacheObject Modifier and Type Method Description CacheDataRowGridCacheOffheapManager.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)CacheDataRowGridCacheOffheapManager.GridCacheDataStore. find(GridCacheContext cctx, KeyCacheObject key)voidGridCacheOffheapManager.GridCacheDataStore. invoke(GridCacheContext cctx, KeyCacheObject key, IgniteCacheOffheapManager.OffheapInvokeClosure c)voidCacheDataRow. key(KeyCacheObject key)voidCacheDataRowAdapter. key(KeyCacheObject key)voidGridCacheOffheapManager.GridCacheDataStore. remove(GridCacheContext cctx, KeyCacheObject key, int partId)voidGridCacheOffheapManager.GridCacheDataStore. update(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, @Nullable CacheDataRow oldRow)Constructors in org.apache.ignite.internal.processors.cache.persistence with parameters of type KeyCacheObject Constructor 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) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.persistence.snapshot.dump
Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot.dump with parameters of type KeyCacheObject Modifier and Type Method Description voidCreateDumpFutureTask. beforeChange(GridCacheContext cctx, KeyCacheObject key, CacheObject val, long expireTime, GridCacheVersion ver)voidDumpEntryChangeListener. beforeChange(GridCacheContext cctx, KeyCacheObject key, @Nullable CacheObject val, long expireTime, GridCacheVersion ver)ByteBufferDumpEntrySerializer. writeToBuffer(int cache, long expireTime, KeyCacheObject key, CacheObject val, GridCacheVersion ver, CacheObjectContext coCtx) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.query
Methods in org.apache.ignite.internal.processors.cache.query that return types with arguments of type KeyCacheObject Modifier and Type Method Description Collection<KeyCacheObject>CacheQuery. skipKeys()Collection<KeyCacheObject>GridCacheQueryRequest. skipKeys()Methods in org.apache.ignite.internal.processors.cache.query with parameters of type KeyCacheObject Modifier and Type Method Description RAbstractScanQueryIterator. filterAndTransform(KeyCacheObject key, CacheObject val, long start)Perform filtering and transformation of key-value pair.voidGridCacheQueryManager. remove(KeyCacheObject key, @Nullable CacheDataRow prevRow)Method parameters in org.apache.ignite.internal.processors.cache.query with type arguments of type KeyCacheObject Modifier and Type Method Description <T,R>
CacheQuery<R>GridCacheQueryManager. createScanQuery(@Nullable IgniteBiPredicate<K,V> filter, @Nullable IgniteClosure<T,R> trans, @Nullable Integer part, boolean keepBinary, boolean forceLocal, Boolean dataPageScanEnabled, Set<KeyCacheObject> skipKeys)Creates user's predicate based scan query.Constructor parameters in org.apache.ignite.internal.processors.cache.query with type arguments of type KeyCacheObject Constructor Description CacheQuery(GridCacheContext<?,?> cctx, GridCacheQueryType type, @Nullable String clsName, @Nullable String clause, @Nullable IgniteBiPredicate<Object,Object> filter, @Nullable Integer part, boolean incMeta, boolean keepBinary, Boolean dataPageScanEnabled, IndexQueryDesc idxQryDesc, @Nullable Collection<KeyCacheObject> skipKeys)Cache query adapter for SET, SPI, TEXT queries.CacheQuery(GridCacheContext<?,?> cctx, GridCacheQueryType type, @Nullable IgniteBiPredicate<Object,Object> filter, @Nullable IgniteClosure<Map.Entry,Object> transform, @Nullable Integer part, boolean keepBinary, boolean forceLocal, Boolean dataPageScanEnabled, @Nullable Set<KeyCacheObject> skipKeys)Cache query adapter for SCAN query.CacheQuery(GridCacheContext<?,?> cctx, GridCacheQueryType type, IgniteLogger log, int pageSize, long timeout, boolean incBackups, boolean dedup, ClusterGroup prj, IgniteBiPredicate<Object,Object> filter, @Nullable Integer part, @Nullable String clsName, String clause, IndexQueryDesc idxQryDesc, int limit, boolean incMeta, boolean keepBinary, int taskHash, Boolean dataPageScanEnabled, @Nullable Collection<KeyCacheObject> skipKeys)Cache query adapter for local query processing. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.query.continuous
Methods in org.apache.ignite.internal.processors.cache.query.continuous with parameters of type KeyCacheObject Modifier and Type Method Description voidCacheContinuousQueryManager. onEntryExpired(GridCacheEntryEx e, KeyCacheObject key, CacheObject oldVal)voidCacheContinuousQueryManager. 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)voidCacheContinuousQueryManager. onEntryUpdated(KeyCacheObject key, CacheObject newVal, CacheObject oldVal, boolean internal, int partId, boolean primary, boolean preload, long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, AffinityTopologyVersion topVer) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.store
Methods in org.apache.ignite.internal.processors.cache.store with parameters of type KeyCacheObject Modifier and Type Method Description @Nullable ObjectCacheStoreManager. load(@Nullable IgniteInternalTx tx, KeyCacheObject key)Loads data from persistent store.@Nullable ObjectGridCacheStoreManagerAdapter. load(@Nullable IgniteInternalTx tx, KeyCacheObject key)Loads data from persistent store.booleanCacheStoreManager. put(@Nullable IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver)Puts key-value pair into storage.booleanGridCacheStoreManagerAdapter. put(@Nullable IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver)Puts key-value pair into storage.booleanCacheStoreManager. remove(@Nullable IgniteInternalTx tx, KeyCacheObject key)booleanGridCacheStoreManagerAdapter. remove(@Nullable IgniteInternalTx tx, KeyCacheObject key)Method parameters in org.apache.ignite.internal.processors.cache.store with type arguments of type KeyCacheObject Modifier and Type Method Description booleanCacheStoreManager. loadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, IgniteBiInClosure<KeyCacheObject,Object> vis)Loads data from persistent store.booleanCacheStoreManager. loadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, IgniteBiInClosure<KeyCacheObject,Object> vis)Loads data from persistent store.booleanCacheStoreManager. loadCache(GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis, Object[] args)Loads data from persistent store.voidCacheStoreManager. localStoreLoadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis)voidCacheStoreManager. localStoreLoadAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis)booleanCacheStoreManager. putAll(@Nullable IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)Puts key-value pair into storage.booleanGridCacheStoreManagerAdapter. putAll(@Nullable IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)Puts key-value pair into storage.booleanCacheStoreManager. removeAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)booleanGridCacheStoreManagerAdapter. removeAll(@Nullable IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.transactions
Methods in org.apache.ignite.internal.processors.cache.transactions that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectIgniteTxEntry. key()KeyCacheObjectIgniteTxKey. key()Methods in org.apache.ignite.internal.processors.cache.transactions that return types with arguments of type KeyCacheObject Modifier and Type Method Description Set<KeyCacheObject>TransactionChanges. changedKeys()Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type KeyCacheObject Modifier and Type Method Description @Nullable GridTuple<CacheObject>IgniteInternalTx. peek(GridCacheContext ctx, boolean failFast, KeyCacheObject key)@Nullable GridTuple<CacheObject>IgniteTxLocalAdapter. peek(GridCacheContext cacheCtx, boolean failFast, KeyCacheObject key)booleanTransactionChanges. remove(KeyCacheObject key)protected booleanIgniteTxAdapter. updateNearCache(GridCacheContext<?,?> cacheCtx, KeyCacheObject key, AffinityTopologyVersion topVer)Checks whether near cache should be updated.Method parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type KeyCacheObject Modifier and Type Method Description protected IgniteCacheExpiryPolicyIgniteTxLocalAdapter. accessPolicy(GridCacheContext cacheCtx, Collection<KeyCacheObject> keys)protected voidIgniteTxLocalAdapter. 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.Constructors in org.apache.ignite.internal.processors.cache.transactions with parameters of type KeyCacheObject Constructor Description IgniteTxKey(KeyCacheObject key, int cacheId)Constructor parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type KeyCacheObject Constructor Description TransactionChanges(Set<KeyCacheObject> changedKeys, List<E> newAndUpdatedEntries) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.tree
Fields in org.apache.ignite.internal.processors.cache.tree declared as KeyCacheObject Modifier and Type Field Description KeyCacheObjectPendingRow. keyMethods in org.apache.ignite.internal.processors.cache.tree that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectSearchRow. key()Methods in org.apache.ignite.internal.processors.cache.tree with parameters of type KeyCacheObject Modifier and Type Method Description voidDataRow. key(KeyCacheObject key)Constructors in org.apache.ignite.internal.processors.cache.tree with parameters of type KeyCacheObject Constructor Description DataRow(KeyCacheObject key, CacheObject val, GridCacheVersion ver, int part, long expireTime, int cacheId)SearchRow(int cacheId, KeyCacheObject key) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.verify
Methods in org.apache.ignite.internal.processors.cache.verify that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectPartitionEntryHashRecord. key()Methods in org.apache.ignite.internal.processors.cache.verify with parameters of type KeyCacheObject Modifier and Type Method Description voidIdleVerifyUtility.VerifyPartitionContext. update(KeyCacheObject key, CacheObject val, CacheEntryVersion ver)Constructors in org.apache.ignite.internal.processors.cache.verify with parameters of type KeyCacheObject Constructor 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) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cache.version
Methods in org.apache.ignite.internal.processors.cache.version with parameters of type KeyCacheObject Modifier and Type Method Description voidGridCacheRawVersionedEntry. key(KeyCacheObject key)Constructors in org.apache.ignite.internal.processors.cache.version with parameters of type KeyCacheObject Constructor 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. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.cacheobject
Classes in org.apache.ignite.internal.processors.cacheobject that implement KeyCacheObject Modifier and Type Class Description classUserKeyCacheObjectImplWraps key provided by user, must be serialized before stored in cache.Methods in org.apache.ignite.internal.processors.cacheobject that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectUserKeyCacheObjectImpl. copy(int part)KeyCacheObjectIgniteCacheObjectProcessor. toCacheKeyObject(CacheObjectContext ctx, @Nullable GridCacheContext cctx, Object obj, boolean userObj)KeyCacheObjectIgniteCacheObjectProcessor. toKeyCacheObject(CacheObjectContext ctx, byte type, byte[] bytes) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.datastreamer
Fields in org.apache.ignite.internal.processors.datastreamer declared as KeyCacheObject Modifier and Type Field Description protected KeyCacheObjectDataStreamerEntry. keyMethods in org.apache.ignite.internal.processors.datastreamer that return KeyCacheObject Modifier and Type Method Description KeyCacheObjectDataStreamerEntry. getKey()Methods in org.apache.ignite.internal.processors.datastreamer with parameters of type KeyCacheObject Modifier and Type Method Description IgniteFuture<?>DataStreamerImpl. addDataInternal(KeyCacheObject key, CacheObject val)IgniteFuture<?>DataStreamerImpl. removeDataInternal(KeyCacheObject key)Method parameters in org.apache.ignite.internal.processors.datastreamer with type arguments of type KeyCacheObject Modifier and Type Method Description voidDataStreamerImpl.IsolatedUpdater. receive(IgniteCache<KeyCacheObject,CacheObject> cache, Collection<Map.Entry<KeyCacheObject,CacheObject>> entries)Updates cache with batch of entries.voidDataStreamerImpl.IsolatedUpdater. receive(IgniteCache<KeyCacheObject,CacheObject> cache, Collection<Map.Entry<KeyCacheObject,CacheObject>> entries)Updates cache with batch of entries.Constructors in org.apache.ignite.internal.processors.datastreamer with parameters of type KeyCacheObject Constructor Description DataStreamerEntry(KeyCacheObject key, CacheObject val) -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.dr
Method parameters in org.apache.ignite.internal.processors.dr with type arguments of type KeyCacheObject Modifier and Type Method Description voidIgniteDrDataStreamerCacheUpdater. receive(IgniteCache<KeyCacheObject,CacheObject> cache0, Collection<Map.Entry<KeyCacheObject,CacheObject>> col)Updates cache with batch of entries.voidIgniteDrDataStreamerCacheUpdater. receive(IgniteCache<KeyCacheObject,CacheObject> cache0, Collection<Map.Entry<KeyCacheObject,CacheObject>> col)Updates cache with batch of entries. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.offheap
Methods in org.apache.ignite.internal.processors.offheap with parameters of type KeyCacheObject Modifier and Type Method Description booleanGridOffHeapProcessor. contains(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes)Checks if offheap space contains value for the given key.voidGridOffHeapProcessor. enableEviction(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes)Enables eviction for entry afterGridOffHeapProcessor.valuePointer(java.lang.String, int, org.apache.ignite.internal.processors.cache.KeyCacheObject, byte[])was called.@org.jetbrains.annotations.Nullable byte[]GridOffHeapProcessor. get(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes)Gets value bytes from offheap space for the given key.<T> TGridOffHeapProcessor. getValue(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes, @Nullable ClassLoader ldr)Gets value from offheap space for the given key.voidGridOffHeapProcessor. put(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes, byte[] valBytes)Puts the given value to offheap space for the given key.@org.jetbrains.annotations.Nullable byte[]GridOffHeapProcessor. remove(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes)Removes value from offheap space for the given key.booleanGridOffHeapProcessor. removex(@Nullable String spaceName, int part, KeyCacheObject key, byte[] keyBytes)Removes value from offheap space for the given key.booleanGridOffHeapProcessor. 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. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.platform.client.streamer
Methods in org.apache.ignite.internal.processors.platform.client.streamer that return types with arguments of type KeyCacheObject Modifier and Type Method Description IgniteDataStreamer<KeyCacheObject,CacheObject>ClientDataStreamerHandle. getStreamer()Gets the wrapped streamer.Constructor parameters in org.apache.ignite.internal.processors.platform.client.streamer with type arguments of type KeyCacheObject Constructor Description ClientDataStreamerHandle(IgniteDataStreamer<KeyCacheObject,CacheObject> streamer)Ctor. -
Uses of KeyCacheObject in org.apache.ignite.internal.processors.query
Methods in org.apache.ignite.internal.processors.query with parameters of type KeyCacheObject Modifier and Type Method Description booleanGridQueryProcessor. belongsToTable(GridCacheContext cctx, String expCacheName, String expTblName, KeyCacheObject key, CacheObject val)Check whether provided key and value belongs to expected cache and table.@Nullable QueryTypeDescriptorImplGridQueryProcessor. typeByValue(String cacheName, CacheObjectContext coctx, KeyCacheObject key, CacheObject val, boolean checkType)voidGridQueryProcessor. validateKeyAndValue(CacheObjectContext coctx, KeyCacheObject key, CacheObject val)Performs validation of provided key and value against configured constraints.
-
Data center replication processor.