GridCacheAdapter (Ignite 1.8.0)

java.lang.Object
- org.apache.ignite.internal.processors.cache.GridCacheAdapter<K,V>

All Implemented Interfaces:

Externalizable, Serializable, Iterable<javax.cache.Cache.Entry<K,V>>, IgniteInternalCache<K,V>

Direct Known Subclasses:

GridDistributedCacheAdapter, GridLocalCache
```
public abstract class GridCacheAdapter<K,V>
extends Object
implements IgniteInternalCache<K,V>, Externalizable
```
Adapter for different cache implementations.

See Also:
Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`protected class`	`GridCacheAdapter.AsyncOp<T>` Cache operation.
`protected static class`	`GridCacheAdapter.CacheExpiryPolicy`
`protected static class`	`GridCacheAdapter.FutureHolder` Holder for last async operation future.
`protected static class`	`GridCacheAdapter.TopologyVersionAwareJob` Delayed callable class.
`protected static class`	`GridCacheAdapter.UpdateGetTimeStatClosure<T>`
`protected static class`	`GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T>`
`protected static class`	`GridCacheAdapter.UpdatePutTimeStatClosure<T>`
`protected static class`	`GridCacheAdapter.UpdateRemoveTimeStatClosure<T>`
`protected static class`	`GridCacheAdapter.UpdateTimeStatClosure<T>`

Field Summary

Fields
Modifier and Type	Field and Description
`protected CacheConfiguration`	`cacheCfg` Cache configuration.
`static int`	`CLEAR_ALL_SPLIT_THRESHOLD` clearLocally() split threshold.
`protected CacheMetricsMXBean`	`clusterMxBean` Cache mxBean.
`protected GridCacheContext<K,V>`	`ctx` Cache configuration.
`protected IgniteConfiguration`	`gridCfg` Grid configuration.
`protected boolean`	`keyCheck`
`protected ThreadLocal<GridCacheAdapter.FutureHolder>`	`lastFut` Last asynchronous future.
`static IgniteProductVersion`	`LOAD_CACHE_JOB_SINCE`
`static IgniteProductVersion`	`LOAD_CACHE_JOB_V2_SINCE`
`protected CacheMetricsMXBean`	`localMxBean` Cache localMxBean.
`protected UUID`	`locNodeId` Local node ID.
`protected IgniteLogger`	`log` Logger.
`protected GridCacheConcurrentMap`	`map` Local map.
`static int`	`MAX_RETRIES` Maximum number of retries when topology changes.
`protected CacheMetricsImpl`	`metrics` Cache metrics.
`protected static IgniteClosure`	`RET2NULL` `GridCacheReturn`-to-null conversion.
`protected IgniteLogger`	`txLockMsgLog` Logger.

Constructor Summary

Constructors
Modifier	Constructor and Description
`protected`	`GridCacheAdapter()` Empty constructor required by `Externalizable`.
`protected`	`GridCacheAdapter(GridCacheContext<K,V> ctx, GridCacheConcurrentMap map)`
`protected`	`GridCacheAdapter(GridCacheContext<K,V> ctx, int startSize)`

Method Summary

Methods
Modifier and Type	Method and Description
`Affinity<K>`	`affinity()` Gets affinity service to provide information about data partitioning and distribution.
`Iterable<? extends GridCacheEntryEx>`	`allEntries()`
`protected <T> IgniteInternalFuture<T>`	`asyncOp(IgniteTxLocalAdapter tx, GridCacheAdapter.AsyncOp<T> op, CacheOperationContext opCtx)`
`protected <T> IgniteInternalFuture<T>`	`asyncOpAcquire()` Tries to acquire asynchronous operations permit, if limited.
`protected void`	`asyncOpRelease()` Releases asynchronous operations permit, if limited.
`void`	`awaitLastFut()` Awaits for previous async operation to be completed.
`<K1,V1> IgniteInternalCache<K1,V1>`	`cache()` Gets base cache for this projection.
`protected void`	`checkJta()` Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
`void`	`clear()` Clears cache on all nodes that store it's data.
`void`	`clear(K key)` Clears key on all nodes that store it's data.
`void`	`clearAll(Set<? extends K> keys)` Clears keys on all nodes that store it's data.
`IgniteInternalFuture<?>`	`clearAllAsync(Set<? extends K> keys)`
`IgniteInternalFuture<?>`	`clearAsync()`
`IgniteInternalFuture<?>`	`clearAsync(K key)`
`void`	`clearLocally(boolean srv, boolean near, boolean readers)` Clears all entries from this cache only if the entry is not currently locked or participating in a transaction.
`void`	`clearLocally(Collection<KeyCacheObject> keys, boolean readers)`
`boolean`	`clearLocally(K key)` Clears an entry from this cache and swap storage only if the entry is not currently locked, and is not participating in a transaction.
`void`	`clearLocallyAll(Set<? extends K> keys, boolean srv, boolean near, boolean readers)` Clears entries from this cache and swap storage only if the entry is not currently locked, and is not participating in a transaction.
`CacheMetrics`	`clusterMetrics()` Gets whole cluster metrics (statistics) for this cache.
`CacheMetrics`	`clusterMetrics(ClusterGroup grp)` Gets cluster group metrics (statistics) for this cache.
`CacheMetricsMXBean`	`clusterMxBean()` Gets whole cluster metrics (statistics) for this cache.
`IgniteInternalFuture<IgniteInternalTx>`	`commitTxAsync(IgniteInternalTx tx)` Asynchronously commits transaction after all previous asynchronous operations are completed.
`CacheConfiguration`	`configuration()` Gets configuration bean for this cache.
`boolean`	`containsKey(K key)`
`IgniteInternalFuture<Boolean>`	`containsKeyAsync(K key)`
`boolean`	`containsKeys(Collection<? extends K> keys)`
`IgniteInternalFuture<Boolean>`	`containsKeysAsync(Collection<? extends K> keys)`
`GridCacheContext<K,V>`	`context()`
`void`	`decrementSize(GridCacheMapEntry e)` Decrements map public size.
`Iterable<? extends GridCacheEntryEx>`	`entries()`
`GridCacheEntryEx`	`entryEx(KeyCacheObject key)`
`GridCacheEntryEx`	`entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)`
`GridCacheEntryEx`	`entryEx(KeyCacheObject key, boolean touch)`
`GridCacheEntryEx`	`entryEx(Object key)`
`protected GridCacheEntryEx`	`entryExSafe(KeyCacheObject key, AffinityTopologyVersion topVer)`
`protected abstract GridCacheMapEntryFactory`	`entryFactory()`
`Set<javax.cache.Cache.Entry<K,V>>`	`entrySet()` Gets set of all entries cached on this node.
`Set<javax.cache.Cache.Entry<K,V>>`	`entrySet(CacheEntryPredicate... filter)`
`Set<javax.cache.Cache.Entry<K,V>>`	`entrySet(int part)` Gets set containing cache entries that belong to provided partition or `null` if partition is not found locally.
`Set<javax.cache.Cache.Entry<K,V>>`	`entrySetx(CacheEntryPredicate... filter)` Gets entry set containing internal entries.
`boolean`	`evict(K key)` Evicts entry associated with given key from cache.
`void`	`evictAll(Collection<? extends K> keys)` Attempts to evict all entries associated with keys.
`javax.cache.expiry.ExpiryPolicy`	`expiry()`
`IgniteCacheExpiryPolicy`	`expiryPolicy(javax.cache.expiry.ExpiryPolicy plc)`
`void`	`forceKeyCheck()` For tests only.
`GridCacheProxyImpl<K,V>`	`forSubjectId(UUID subjId)` Creates projection for specified subject ID.
`V`	`get(K key)` Retrieves value mapped to the specified key from cache.
`V`	`get(K key, boolean deserializeBinary, boolean needVer)`
`protected V`	`get(K key, String taskName, boolean deserializeBinary, boolean needVer)`
`Map<K,V>`	`getAll(Collection<? extends K> keys)` Retrieves values mapped to the specified keys from cache.
`Map<K,V>`	`getAll(Collection<? extends K> keys, boolean deserializeBinary, boolean needVer)`
`IgniteInternalFuture<Map<K,V>>`	`getAllAsync(Collection<? extends K> keys)` Asynchronously retrieves values mapped to the specified keys from cache.
`IgniteInternalFuture<Map<K,V>>`	`getAllAsync(Collection<? extends K> keys, boolean deserializeBinary, boolean needVer)`
`protected IgniteInternalFuture<Map<K,V>>`	`getAllAsync(Collection<? extends K> keys, boolean forcePrimary, boolean skipTx, UUID subjId, String taskName, boolean deserializeBinary, boolean skipVals, boolean canRemap, boolean needVer)`
`IgniteInternalFuture<Map<K,V>>`	`getAllAsync(Collection<? extends K> keys, boolean readThrough, boolean checkTx, UUID subjId, String taskName, boolean deserializeBinary, boolean forcePrimary, IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean canRemap, boolean needVer)`
`<K1,V1> IgniteInternalFuture<Map<K1,V1>>`	`getAllAsync0(Collection<KeyCacheObject> keys, boolean readThrough, boolean checkTx, UUID subjId, String taskName, boolean deserializeBinary, IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean keepCacheObjects, boolean canRemap, boolean needVer)`
`Map<K,V>`	`getAllOutTx(Set<? extends K> keys)` Gets values from cache.
`IgniteInternalFuture<Map<K,V>>`	`getAllOutTxAsync(Set<? extends K> keys)` Gets values from cache.
`V`	`getAndPut(K key, V val)` Stores given key-value pair in cache.
`V`	`getAndPut(K key, V val, CacheEntryPredicate filter)`
`IgniteInternalFuture<V>`	`getAndPutAsync(K key, V val)` Asynchronously stores given key-value pair in cache.
`IgniteInternalFuture<V>`	`getAndPutAsync(K key, V val, CacheEntryPredicate filter)`
`IgniteInternalFuture<V>`	`getAndPutAsync0(K key, V val, CacheEntryPredicate filter)`
`V`	`getAndPutIfAbsent(K key, V val)` Stores given key-value pair in cache only if cache had no previous mapping for it.
`IgniteInternalFuture<V>`	`getAndPutIfAbsentAsync(K key, V val)` Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
`V`	`getAndRemove(K key)` Removes given key mapping from cache.
`IgniteInternalFuture<V>`	`getAndRemoveAsync(K key)` Asynchronously removes given key mapping from cache.
`V`	`getAndReplace(K key, V val)` Stores given key-value pair in cache only if there is a previous mapping for it.
`IgniteInternalFuture<V>`	`getAndReplaceAsync(K key, V val)` Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
`IgniteInternalFuture<V>`	`getAsync(K key)` Asynchronously retrieves value mapped to the specified key from cache.
`IgniteInternalFuture<V>`	`getAsync(K key, boolean deserializeBinary, boolean needVer)`
`protected IgniteInternalFuture<V>`	`getAsync(K key, boolean forcePrimary, boolean skipTx, UUID subjId, String taskName, boolean deserializeBinary, boolean skipVals, boolean canRemap, boolean needVer)`
`Collection<CacheEntry<K,V>>`	`getEntries(Collection<? extends K> keys)` Retrieves values mapped to the specified keys from cache.
`IgniteInternalFuture<Collection<CacheEntry<K,V>>>`	`getEntriesAsync(Collection<? extends K> keys)` Asynchronously retrieves values mapped to the specified keys from cache.
`CacheEntry<K,V>`	`getEntry(K key)` Retrieves value mapped to the specified key from cache.
`IgniteInternalFuture<CacheEntry<K,V>>`	`getEntryAsync(K key)` Asynchronously retrieves value mapped to the specified key from cache.
`V`	`getForcePrimary(K key)` Gets value from cache.
`IgniteInternalFuture<V>`	`getForcePrimaryAsync(K key)` Asynchronously gets value from cache.
`V`	`getTopologySafe(K key)` Gets value without waiting for toplogy changes.
`long`	`igfsDataSpaceMax()` Get maximum space available for IGFS.
`long`	`igfsDataSpaceUsed()` Get current amount of used IGFS space in bytes.
`Iterator<javax.cache.Cache.Entry<K,V>>`	`igniteIterator()`
`Iterator<javax.cache.Cache.Entry<K,V>>`	`igniteIterator(boolean keepBinary)`
`void`	`incrementSize(GridCacheMapEntry e)` Increments map public size.
`protected void`	`init()` Post constructor initialization for subclasses.
`<T> javax.cache.processor.EntryProcessorResult<T>`	`invoke(AffinityTopologyVersion topVer, K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)`
`<T> javax.cache.processor.EntryProcessorResult<T>`	`invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)`
`<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>`	`invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)`
`<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>`	`invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)`
`<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>`	`invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)`
`<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>>`	`invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)`
`<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>>`	`invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)`
`boolean`	`isColocated()`
`boolean`	`isDht()`
`boolean`	`isDhtAtomic()`
`boolean`	`isEmpty()` Returns `true` if this map contains no key-value mappings.
`boolean`	`isIgfsDataCache()` Checks whether this cache is IGFS data cache.
`boolean`	`isLocal()`
`boolean`	`isLocked(K key)` Checks if any node owns a lock for this key.
`boolean`	`isLockedByThread(K key)` Checks if current thread owns a lock on this key.
`boolean`	`isMongoDataCache()` Checks whether this cache is Mongo data cache.
`boolean`	`isMongoMetaCache()` Checks whether this cache is Mongo meta cache.
`boolean`	`isNear()`
`Iterator<javax.cache.Cache.Entry<K,V>>`	`iterator()`
`protected Iterator<javax.cache.Cache.Entry<K,V>>`	`iterator(Iterator<? extends GridCacheEntryEx> it, boolean deserializeBinary)`
`<K1,V1> GridCacheProxyImpl<K1,V1>`	`keepBinary()` Creates projection that will operate with binary objects.
`Set<K>`	`keySet()` Set of keys cached on this node.
`Set<K>`	`keySetx()`
`IgniteInternalFuture<?>`	`loadAll(Set<? extends K> keys, boolean replaceExisting)`
`Iterable<javax.cache.Cache.Entry<K,V>>`	`localEntries(CachePeekMode[] peekModes)`
`void`	`localLoad(Collection<? extends K> keys, javax.cache.expiry.ExpiryPolicy plc, boolean keepBinary)`
`void`	`localLoadCache(IgniteBiPredicate<K,V> p, Object[] args)` Delegates to `CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...)` method to load state from the underlying persistent storage.
`IgniteInternalFuture<?>`	`localLoadCacheAsync(IgniteBiPredicate<K,V> p, Object[] args)` Asynchronously delegates to `CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...)` method to reload state from the underlying persistent storage.
`CacheMetrics`	`localMetrics()` Gets local metrics (statistics) for this cache.
`CacheMetricsMXBean`	`localMxBean()` Gets local metrics (statistics) for this cache.
`V`	`localPeek(K key, CachePeekMode[] peekModes, IgniteCacheExpiryPolicy plc)`
`int`	`localSize(CachePeekMode[] peekModes)`
`long`	`localSizeLong(CachePeekMode[] peekModes)`
`long`	`localSizeLong(int part, CachePeekMode[] peekModes)`
`boolean`	`lock(K key, long timeout)` Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
`boolean`	`lockAll(Collection<? extends K> keys, long timeout)` All or nothing synchronous lock for passed in keys.
`IgniteInternalFuture<Boolean>`	`lockAsync(K key, long timeout)` Asynchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
`protected IgniteLogger`	`log()`
`GridCacheConcurrentMap`	`map()`
`CacheMetricsImpl`	`metrics0()`
`String`	`name()` Gets name of this cache (`null` for default cache).
`int`	`nearSize()` Gets size of near cache key set.
`long`	`offHeapAllocatedSize()` Gets memory size allocated in off-heap.
`long`	`offHeapEntriesCount()` Gets number of cache entries stored in off-heap memory.
`abstract void`	`onDeferredDelete(GridCacheEntryEx entry, GridCacheVersion ver)`
`void`	`onIgfsDataSizeChanged(long delta)` Callback invoked when data is added to IGFS cache.
`protected void`	`onKernalStart()` Kernal start callback.
`void`	`onKernalStop()` Kernal stop callback.
`void`	`onReconnected()`
`void`	`onUndeploy(ClassLoader ldr)` Undeploys and removes all entries for class loader.
`long`	`overflowSize()` Gets size (in bytes) of all entries swapped to disk.
`GridCacheEntryEx`	`peekEx(KeyCacheObject key)`
`GridCacheEntryEx`	`peekEx(Object key)`
`abstract GridCachePreloader`	`preloader()`
`Set<K>`	`primaryKeySet()` Set of keys for which this node is primary.
`int`	`primarySize()` Gets the number of all primary entries cached on this node.
`long`	`primarySizeLong()` Gets the number of all primary entries cached on this node as a long value.
`void`	`printMemoryStats()` Prints memory stats.
`V`	`promote(K key, boolean deserializeBinary)`
`void`	`promoteAll(Collection<? extends K> keys)` This method unswaps cache entries by given keys, if any, from swap storage into memory.
`boolean`	`put(K key, V val)` Stores given key-value pair in cache.
`boolean`	`put(K key, V val, CacheEntryPredicate filter)`
`void`	`putAll(Map<? extends K,? extends V> m)` Stores given key-value pairs in cache.
`IgniteInternalFuture<?>`	`putAllAsync(Map<? extends K,? extends V> m)` Asynchronously stores given key-value pairs in cache.
`void`	`putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)` Store DR data.
`IgniteInternalFuture<?>`	`putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)` Store DR data asynchronously.
`IgniteInternalFuture<Boolean>`	`putAsync(K key, V val)` Stores given key-value pair in cache.
`IgniteInternalFuture<Boolean>`	`putAsync(K key, V val, CacheEntryPredicate filter)`
`IgniteInternalFuture<Boolean>`	`putAsync0(K key, V val, CacheEntryPredicate filter)`
`boolean`	`putIfAbsent(K key, V val)` Stores given key-value pair in cache only if cache had no previous mapping for it.
`IgniteInternalFuture<Boolean>`	`putIfAbsentAsync(K key, V val)` Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
`javax.cache.Cache.Entry<K,V>`	`randomEntry()` Deprecated.
`void`	`readExternal(ObjectInput in)`
`protected Object`	`readResolve()` Reconstructs object on unmarshalling.
`IgniteInternalFuture<?>`	`rebalance()` Forces this cache node to re-balance its partitions.
`boolean`	`remove(K key)` Removes given key mapping from cache.
`boolean`	`remove(K key, V val)` Removes given key mapping from cache if one exists and value is equal to the passed in value.
`void`	`removeAll()` Removes mappings from cache.
`void`	`removeAll(Collection<? extends K> keys)` Removes given key mappings from cache.
`IgniteInternalFuture<?>`	`removeAllAsync(Collection<? extends K> keys)` Asynchronously removes given key mappings from cache for entries.
`void`	`removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)` Removes DR data.
`IgniteInternalFuture<?>`	`removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)` Removes DR data asynchronously.
`IgniteInternalFuture<Boolean>`	`removeAsync(K key)` Asynchronously removes given key mapping from cache.
`IgniteInternalFuture<Boolean>`	`removeAsync(K key, CacheEntryPredicate filter)`
`IgniteInternalFuture<Boolean>`	`removeAsync(K key, V val)` Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
`void`	`removeEntry(GridCacheEntryEx entry)`
`void`	`removeIfObsolete(KeyCacheObject key)`
`boolean`	`replace(K key, V val)` Stores given key-value pair in cache only if only if there is a previous mapping for it.
`boolean`	`replace(K key, V oldVal, V newVal)` Stores given key-value pair in cache only if only if the previous value is equal to the `'oldVal'` passed in.
`IgniteInternalFuture<Boolean>`	`replaceAsync(K key, V val)` Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
`IgniteInternalFuture<Boolean>`	`replaceAsync(K key, V oldVal, V newVal)` Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the `'oldVal'` passed in.
`protected void`	`saveFuture(GridCacheAdapter.FutureHolder holder, IgniteInternalFuture<?> fut)` Saves future in thread local holder and adds listener that will clear holder when future is finished.
`GridCacheProxyImpl<K,V>`	`setSkipStore(boolean skipStore)`
`int`	`size()` Gets the number of all entries cached on this node.
`int`	`size(CachePeekMode[] peekModes)`
`IgniteInternalFuture<Integer>`	`sizeAsync(CachePeekMode[] peekModes)`
`long`	`sizeLong()` Gets the number of all entries cached on this node as a long value.
`long`	`sizeLong(CachePeekMode[] peekModes)`
`long`	`sizeLong(int partition, CachePeekMode[] peekModes)`
`IgniteInternalFuture<Long>`	`sizeLongAsync(CachePeekMode[] peekModes)`
`IgniteInternalFuture<Long>`	`sizeLongAsync(int part, CachePeekMode[] peekModes)`
`boolean`	`skipStore()`
`List<GridCacheClearAllRunnable<K,V>>`	`splitClearLocally(boolean srv, boolean near, boolean readers)` Split clearLocally all task into multiple runnables.
`void`	`start()` Starts this cache.
`protected String`	`startInfo()` Startup info.
`void`	`stop()` Stops this cache.
`protected String`	`stopInfo()` Stop info.
`long`	`swapKeys()` Gets number of swap entries (keys).
`long`	`swapSize()` Gets size in bytes for swap space.
`String`	`toString()`
`V`	`tryGetAndPut(K key, V val)` Tries to get and put value in cache.
`Transaction`	`tx()` Gets transaction started by this thread or `null` if this thread does not have a transaction.
`abstract IgniteInternalFuture<Boolean>`	`txLockAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isRead, boolean retval, TransactionIsolation isolation, boolean invalidate, long accessTtl)`
`Transaction`	`txStart(TransactionConcurrency concurrency, TransactionIsolation isolation)` Starts new transaction with the specified concurrency and isolation.
`Transaction`	`txStart(TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize)` Starts transaction with specified isolation, concurrency, timeout, invalidation flag, and number of participating entries.
`IgniteInternalTx`	`txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)`
`void`	`unlock(K key)` Unlocks given key only if current thread owns the lock.
`protected void`	`validateCacheKey(Object key)` Validates that given cache key has overridden equals and hashCode methods and implements `Externalizable`.
`protected void`	`validateCacheKeys(Iterable<?> keys)` Validates that given cache keys have overridden equals and hashCode methods and implement `Externalizable`.
`Iterable<V>`	`values()` Collection of values cached on this node.
`Iterable<V>`	`values(CacheEntryPredicate... filter)` Collection of values cached on this node.
`GridCacheProxyImpl<K,V>`	`withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)`
`IgniteInternalCache<K,V>`	`withNoRetries()`
`void`	`writeExternal(ObjectOutput out)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.ignite.internal.processors.cache.IgniteInternalCache
lockAllAsync, removeAllAsync, unlockAll

- Field Detail
  - CLEAR_ALL_SPLIT_THRESHOLD
```
public static final int CLEAR_ALL_SPLIT_THRESHOLD
```
    clearLocally() split threshold.
    
    See Also:
    Constant Field Values
  - MAX_RETRIES
```
public static final int MAX_RETRIES
```
    Maximum number of retries when topology changes.
  - LOAD_CACHE_JOB_SINCE
```
public static final IgniteProductVersion LOAD_CACHE_JOB_SINCE
```
  - LOAD_CACHE_JOB_V2_SINCE
```
public static final IgniteProductVersion LOAD_CACHE_JOB_V2_SINCE
```
  - RET2NULL
```
protected static final IgniteClosure RET2NULL
```
    GridCacheReturn-to-null conversion.
  - keyCheck
```
protected boolean keyCheck
```
  - lastFut
```
protected ThreadLocal<GridCacheAdapter.FutureHolder> lastFut
```
    Last asynchronous future.
  - ctx
```
@GridToStringExclude
protected GridCacheContext<K,V> ctx
```
    Cache configuration.
  - map
```
@GridToStringExclude
protected GridCacheConcurrentMap map
```
    Local map.
  - locNodeId
```
@GridToStringExclude
protected UUID locNodeId
```
    Local node ID.
  - cacheCfg
```
@GridToStringExclude
protected CacheConfiguration cacheCfg
```
    Cache configuration.
  - gridCfg
```
@GridToStringExclude
protected IgniteConfiguration gridCfg
```
    Grid configuration.
  - metrics
```
protected CacheMetricsImpl metrics
```
    Cache metrics.
  - localMxBean
```
protected CacheMetricsMXBean localMxBean
```
    Cache localMxBean.
  - clusterMxBean
```
protected CacheMetricsMXBean clusterMxBean
```
    Cache mxBean.
  - log
```
protected IgniteLogger log
```
    Logger.
  - txLockMsgLog
```
protected IgniteLogger txLockMsgLog
```
    Logger.
- Constructor Detail
  - GridCacheAdapter
```
protected GridCacheAdapter()
```
    Empty constructor required by Externalizable.
  - GridCacheAdapter
```
protected GridCacheAdapter(GridCacheContext<K,V> ctx,
                int startSize)
```
    Parameters:
    ctx - Cache context.
    startSize - Start size.
  - GridCacheAdapter
```
protected GridCacheAdapter(GridCacheContext<K,V> ctx,
                @Nullable
                GridCacheConcurrentMap map)
```
    Parameters:
    ctx - Cache context.
    map - Concurrent map.
- Method Detail
  - name
```
public String name()
```
    Gets name of this cache (null for default cache).
    
    Specified by:
    
    name in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache name.
  - printMemoryStats
```
public void printMemoryStats()
```
    Prints memory stats.
  - map
```
public GridCacheConcurrentMap map()
```
    Returns:
    Base map.
  - incrementSize
```
public void incrementSize(GridCacheMapEntry e)
```
    Increments map public size.
    
    Parameters:
    e - Map entry.
  - decrementSize
```
public void decrementSize(GridCacheMapEntry e)
```
    Decrements map public size.
    
    Parameters:
    e - Map entry.
  - context
```
public GridCacheContext<K,V> context()
```
    Specified by:
    
    context in interface IgniteInternalCache<K,V>
    
    Returns:
    Context.
  - log
```
protected IgniteLogger log()
```
    Returns:
    Logger.
  - isNear
```
public boolean isNear()
```
    Returns:
    True if this is near cache.
  - isLocal
```
public boolean isLocal()
```
    Returns:
    True if cache is local.
  - isColocated
```
public boolean isColocated()
```
    Returns:
    True if cache is colocated.
  - isDhtAtomic
```
public boolean isDhtAtomic()
```
    Returns:
    True if cache is DHT Atomic.
  - isDht
```
public boolean isDht()
```
    Returns:
    True if cache is DHT.
  - preloader
```
public abstract GridCachePreloader preloader()
```
    Returns:
    Preloader.
  - affinity
```
public Affinity<K> affinity()
```
    Gets affinity service to provide information about data partitioning and distribution.
    
    Specified by:
    
    affinity in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache data affinity service.
  - cache
```
public <K1,V1> IgniteInternalCache<K1,V1> cache()
```
    Gets base cache for this projection.
    
    Specified by:
    
    cache in interface IgniteInternalCache<K,V>
    
    Type Parameters:
    K1 - Cache key type.
    V1 - Cache value type.
    
    Returns:
    Base cache for this projection.
  - forSubjectId
```
public GridCacheProxyImpl<K,V> forSubjectId(UUID subjId)
```
    Creates projection for specified subject ID.
    
    Specified by:
    
    forSubjectId in interface IgniteInternalCache<K,V>
    
    Parameters:
    subjId - Client ID.
    
    Returns:
    Internal projection.
  - skipStore
```
public boolean skipStore()
```
    Specified by:
    
    skipStore in interface IgniteInternalCache<K,V>
    
    Returns:
    Skip store.
  - setSkipStore
```
public GridCacheProxyImpl<K,V> setSkipStore(boolean skipStore)
```
    Specified by:
    
    setSkipStore in interface IgniteInternalCache<K,V>
    
    Parameters:
    skipStore - Skip store flag.
    
    Returns:
    New internal cache instance based on this one, but with skip store flag enabled.
  - keepBinary
```
public <K1,V1> GridCacheProxyImpl<K1,V1> keepBinary()
```
    Creates projection that will operate with binary objects.
    Projection returned by this method will force cache not to deserialize binary objects, so keys and values will be returned from cache API methods without changes. Therefore, signature of the projection can contain only following types:
    - org.gridgain.grid.binary.BinaryObject for binary classes
    - All primitives (byte, int, ...) and there boxed versions (Byte, Integer, ...)
    - Arrays of primitives (byte[], int[], ...)
    - String and array of Strings
    - UUID and array of UUIDs
    - Date and array of Dates
    - Timestamp and array of Timestamps
    - Enums and array of enums
    - Maps, collections and array of objects (but objects inside them will still be converted if they are binary)
    For example, if you use Integer as a key and Value class as a value (which will be stored in binary format), you should acquire following projection to avoid deserialization:
```
 IgniteInternalCache prj = cache.keepBinary();

 // Value is not deserialized and returned in binary format.
 GridBinaryObject po = prj.get(1);
 
```
    Note that this method makes sense only if cache is working in binary mode (org.apache.ignite.configuration.CacheConfiguration#isBinaryEnabled() returns true. If not, this method is no-op and will return current projection.
    Specified by:
    
    keepBinary in interface IgniteInternalCache<K,V>
    
    Returns:
    New internal cache instance for binary objects.
  - expiry
```
@Nullable
public javax.cache.expiry.ExpiryPolicy expiry()
```
    Specified by:
    
    expiry in interface IgniteInternalCache<K,V>
    
    Returns:
    ExpiryPolicy associated with this projection.
  - withExpiryPolicy
```
public GridCacheProxyImpl<K,V> withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)
```
    Specified by:
    
    withExpiryPolicy in interface IgniteInternalCache<K,V>
    
    Parameters:
    plc - ExpiryPolicy to associate with this projection.
    
    Returns:
    New projection based on this one, but with the specified expiry policy.
  - withNoRetries
```
public IgniteInternalCache<K,V> withNoRetries()
```
    Specified by:
    
    withNoRetries in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache with no-retries behavior enabled.
  - configuration
```
public CacheConfiguration configuration()
```
    Gets configuration bean for this cache.
    
    Specified by:
    
    configuration in interface IgniteInternalCache<K,V>
    
    Returns:
    Configuration bean for this cache.
  - txLockAsync
```
public abstract IgniteInternalFuture<Boolean> txLockAsync(Collection<KeyCacheObject> keys,
                                        long timeout,
                                        IgniteTxLocalEx tx,
                                        boolean isRead,
                                        boolean retval,
                                        TransactionIsolation isolation,
                                        boolean invalidate,
                                        long accessTtl)
```
    Parameters:
    keys - Keys to lock.
    timeout - Lock timeout.
    tx - Transaction.
    isRead - True for read operations.
    retval - Flag to return value.
    isolation - Transaction isolation.
    invalidate - Invalidate flag.
    accessTtl - TTL for read operation.
    
    Returns:
    Locks future.
  - init
```
protected void init()
```
    Post constructor initialization for subclasses.
  - entryFactory
```
protected abstract GridCacheMapEntryFactory entryFactory()
```
    Returns:
    Entry factory.
  - start
```
public void start()
           throws IgniteCheckedException
```
    Starts this cache. Child classes should override this method to provide custom start-up behavior.
    
    Throws:
    
    IgniteCheckedException - If start failed.
  - startInfo
```
protected final String startInfo()
```
    Startup info.
    
    Returns:
    Startup info.
  - stop
```
public void stop()
```
    Stops this cache. Child classes should override this method to provide custom stop behavior.
  - stopInfo
```
protected final String stopInfo()
```
    Stop info.
    
    Returns:
    Stop info.
  - onKernalStart
```
protected void onKernalStart()
                      throws IgniteCheckedException
```
    Kernal start callback.
    
    Throws:
    
    IgniteCheckedException - If callback failed.
  - onKernalStop
```
public void onKernalStop()
```
    Kernal stop callback.
  - isEmpty
```
public boolean isEmpty()
```
    Returns true if this map contains no key-value mappings.
    
    Specified by:
    
    isEmpty in interface IgniteInternalCache<K,V>
    
    Returns:
    true if this map contains no key-value mappings.
  - containsKey
```
public boolean containsKey(K key)
```
    Specified by:
    
    containsKey in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    
    Returns:
    True if cache contains mapping for a given key.
  - containsKeyAsync
```
public final IgniteInternalFuture<Boolean> containsKeyAsync(K key)
```
    Specified by:
    
    containsKeyAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    
    Returns:
    Future.
  - containsKeys
```
public boolean containsKeys(Collection<? extends K> keys)
```
    Specified by:
    
    containsKeys in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys,
    
    Returns:
    True if cache contains all keys.
  - containsKeysAsync
```
public IgniteInternalFuture<Boolean> containsKeysAsync(Collection<? extends K> keys)
```
    Specified by:
    
    containsKeysAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to check.
    
    Returns:
    Future.
  - localEntries
```
public Iterable<javax.cache.Cache.Entry<K,V>> localEntries(CachePeekMode[] peekModes)
                                                    throws IgniteCheckedException
```
    Specified by:
    
    localEntries in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Entries iterable.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - localPeek
```
@Nullable
public V localPeek(K key,
                   CachePeekMode[] peekModes,
                   @Nullable
                   IgniteCacheExpiryPolicy plc)
            throws IgniteCheckedException
```
    Specified by:
    
    localPeek in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    peekModes - Peek modes.
    plc - Expiry policy if TTL should be updated.
    
    Returns:
    Value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - onUndeploy
```
public void onUndeploy(ClassLoader ldr)
```
    Undeploys and removes all entries for class loader.
    
    Parameters:
    ldr - Class loader to undeploy.
  - peekEx
```
@Nullable
public GridCacheEntryEx peekEx(KeyCacheObject key)
```
    Parameters:
    key - Entry key.
    
    Returns:
    Entry or null.
  - peekEx
```
@Nullable
public GridCacheEntryEx peekEx(Object key)
```
    Parameters:
    key - Entry key.
    
    Returns:
    Entry or null.
  - entryEx
```
public GridCacheEntryEx entryEx(Object key)
```
    Parameters:
    key - Entry key.
    
    Returns:
    Entry (never null).
  - entryEx
```
public GridCacheEntryEx entryEx(KeyCacheObject key)
```
    Parameters:
    key - Entry key.
    
    Returns:
    Entry (never null).
  - entryEx
```
public GridCacheEntryEx entryEx(KeyCacheObject key,
                       boolean touch)
```
    Parameters:
    key - Entry key.
    touch - Whether created entry should be touched.
    
    Returns:
    Entry (never null).
  - entryEx
```
public GridCacheEntryEx entryEx(KeyCacheObject key,
                       AffinityTopologyVersion topVer)
```
    Parameters:
    topVer - Topology version.
    key - Entry key.
    
    Returns:
    Entry (never null).
  - entries
```
public Iterable<? extends GridCacheEntryEx> entries()
```
    Returns:
    Set of internal cached entry representations.
  - allEntries
```
public Iterable<? extends GridCacheEntryEx> allEntries()
```
    Returns:
    Set of internal cached entry representations.
  - entrySet
```
public Set<javax.cache.Cache.Entry<K,V>> entrySet()
```
    Gets set of all entries cached on this node. You can remove elements from this set, but you cannot add elements to this set. All removal operation will be reflected on the cache itself.
    NOTE: this operation is not distributed and returns only the entries cached on this node.
    
    Specified by:
    
    entrySet in interface IgniteInternalCache<K,V>
    
    Returns:
    Entries that pass through key filter.
  - entrySetx
```
public Set<javax.cache.Cache.Entry<K,V>> entrySetx(CacheEntryPredicate... filter)
```
    Gets entry set containing internal entries.
    
    Specified by:
    
    entrySetx in interface IgniteInternalCache<K,V>
    
    Parameters:
    filter - Filter.
    
    Returns:
    Entry set.
  - entrySet
```
public Set<javax.cache.Cache.Entry<K,V>> entrySet(int part)
```
    Gets set containing cache entries that belong to provided partition or null if partition is not found locally.
    NOTE: this operation is not distributed and returns only the entries cached on this node.
    
    Specified by:
    
    entrySet in interface IgniteInternalCache<K,V>
    
    Parameters:
    part - Partition.
    
    Returns:
    Set containing partition's entries or null if partition is not found locally.
  - keySet
```
public Set<K> keySet()
```
    Set of keys cached on this node. You can remove elements from this set, but you cannot add elements to this set. All removal operation will be reflected on the cache itself.
    Iterator over this set will not fail if set was concurrently updated by another thread. This means that iterator may or may not return latest keys depending on whether they were added before or after current iterator position.
    NOTE: this operation is not distributed and returns only the keys cached on this node.
    
    Specified by:
    
    keySet in interface IgniteInternalCache<K,V>
    
    Returns:
    Key set for this cache projection.
  - keySetx
```
public Set<K> keySetx()
```
    Specified by:
    
    keySetx in interface IgniteInternalCache<K,V>
    
    Returns:
    Set of keys including internal keys.
  - primaryKeySet
```
public Set<K> primaryKeySet()
```
    Set of keys for which this node is primary. This set is dynamic and may change with grid topology changes. Note that this set will contain mappings for all keys, even if their values are null because they were invalidated. You can remove elements from this set, but you cannot add elements to this set. All removal operation will be reflected on the cache itself.
    Iterator over this set will not fail if set was concurrently updated by another thread. This means that iterator may or may not return latest keys depending on whether they were added before or after current iterator position.
    NOTE: this operation is not distributed and returns only the keys cached on this node.
    
    Specified by:
    
    primaryKeySet in interface IgniteInternalCache<K,V>
    
    Returns:
    Primary key set for the current node.
  - values
```
public Iterable<V> values()
```
    Collection of values cached on this node. You can remove elements from this collection, but you cannot add elements to this collection. All removal operation will be reflected on the cache itself.
    Iterator over this collection will not fail if collection was concurrently updated by another thread. This means that iterator may or may not return latest values depending on whether they were added before or after current iterator position.
    NOTE: this operation is not distributed and returns only the values cached on this node.
    
    Specified by:
    
    values in interface IgniteInternalCache<K,V>
    
    Returns:
    Collection of cached values.
  - values
```
public Iterable<V> values(CacheEntryPredicate... filter)
```
    Collection of values cached on this node. You cannot modify this collection.
    Iterator over this collection will not fail if collection was concurrently updated by another thread. This means that iterator may or may not return latest values depending on whether they were added before or after current iterator position.
    NOTE: this operation is not distributed and returns only the values cached on this node.
    
    Parameters:
    filter - Filters.
    
    Returns:
    Collection of cached values.
  - removeIfObsolete
```
public void removeIfObsolete(KeyCacheObject key)
```
    Parameters:
    key - Entry key.
  - splitClearLocally
```
public List<GridCacheClearAllRunnable<K,V>> splitClearLocally(boolean srv,
                                                     boolean near,
                                                     boolean readers)
```
    Split clearLocally all task into multiple runnables.
    
    Parameters:
    srv - Whether to clear server cache.
    near - Whether to clear near cache.
    readers - Whether to clear readers.
    
    Returns:
    Split runnables.
  - clearLocally
```
public boolean clearLocally(K key)
```
    Clears an entry from this cache and swap storage only if the entry is not currently locked, and is not participating in a transaction.
    If CacheConfiguration.isSwapEnabled() is set to true, the evicted entries will also be cleared from swap.
    Note that this operation is local as it merely clears an entry from local cache. It does not remove entries from remote caches or from underlying persistent storage.
    
    Specified by:
    
    clearLocally in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to clearLocally.
    
    Returns:
    True if entry was successfully cleared from cache, false if entry was in use at the time of this method invocation and could not be cleared.
  - clearLocallyAll
```
public void clearLocallyAll(Set<? extends K> keys,
                   boolean srv,
                   boolean near,
                   boolean readers)
```
    Clears entries from this cache and swap storage only if the entry is not currently locked, and is not participating in a transaction.
    If CacheConfiguration.isSwapEnabled() is set to true, the evicted entries will also be cleared from swap.
    Note that this operation is local as it merely clears an entry from local cache. It does not remove entries from remote caches or from underlying persistent storage.
    
    Specified by:
    
    clearLocallyAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to clearLocally.
    srv - Whether to clear server cache.
    near - Whether to clear near cache.
    readers - Whether to clear readers.
  - clearLocally
```
public void clearLocally(boolean srv,
                boolean near,
                boolean readers)
```
    Clears all entries from this cache only if the entry is not currently locked or participating in a transaction.
    If CacheConfiguration.isSwapEnabled() is set to true, the evicted entries will also be cleared from swap.
    Note that this operation is local as it merely clears entries from local cache. It does not remove entries from remote caches or from underlying persistent storage.
    
    Specified by:
    
    clearLocally in interface IgniteInternalCache<K,V>
    
    Parameters:
    srv - Whether to clear server cache.
    near - Whether to clear near cache.
    readers - Whether to clear readers.
  - clear
```
public void clear()
           throws IgniteCheckedException
```
    Clears cache on all nodes that store it's data. That is, caches are cleared on remote nodes and local node, as opposed to IgniteInternalCache.clearLocally(boolean, boolean, boolean) method which only clears local node's cache.
    Ignite will make the best attempt to clear caches on all nodes. If some caches could not be cleared, then exception will be thrown.
    
    Specified by:
    
    clear in interface IgniteInternalCache<K,V>
    
    Throws:
    
    IgniteCheckedException - In case of cache could not be cleared on any of the nodes.
  - clear
```
public void clear(K key)
           throws IgniteCheckedException
```
    Clears key on all nodes that store it's data. That is, caches are cleared on remote nodes and local node, as opposed to IgniteInternalCache.clearLocally(Object) method which only clears local node's cache.
    Ignite will make the best attempt to clear caches on all nodes. If some caches could not be cleared, then exception will be thrown.
    
    Specified by:
    
    clear in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to clear.
    
    Throws:
    
    IgniteCheckedException - In case of cache could not be cleared on any of the nodes.
  - clearAll
```
public void clearAll(Set<? extends K> keys)
              throws IgniteCheckedException
```
    Clears keys on all nodes that store it's data. That is, caches are cleared on remote nodes and local node, as opposed to IgniteInternalCache.clearLocallyAll(Set, boolean, boolean, boolean) method which only clears local node's cache.
    Ignite will make the best attempt to clear caches on all nodes. If some caches could not be cleared, then exception will be thrown.
    
    Specified by:
    
    clearAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to clear.
    
    Throws:
    
    IgniteCheckedException - In case of cache could not be cleared on any of the nodes.
  - clearAsync
```
public IgniteInternalFuture<?> clearAsync()
```
    Specified by:
    
    clearAsync in interface IgniteInternalCache<K,V>
    
    Returns:
    Clear future.
  - clearAsync
```
public IgniteInternalFuture<?> clearAsync(K key)
```
    Specified by:
    
    clearAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to clear.
    
    Returns:
    Clear future.
  - clearAllAsync
```
public IgniteInternalFuture<?> clearAllAsync(Set<? extends K> keys)
```
    Specified by:
    
    clearAllAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to clear.
    
    Returns:
    Clear future.
  - clearLocally
```
public void clearLocally(Collection<KeyCacheObject> keys,
                boolean readers)
```
    Parameters:
    keys - Keys.
    readers - Readers flag.
  - removeEntry
```
public void removeEntry(GridCacheEntryEx entry)
```
    Parameters:
    entry - Removes entry from cache if currently mapped value is the same as passed.
  - getForcePrimary
```
public V getForcePrimary(K key)
                  throws IgniteCheckedException
```
    Gets value from cache. Will go to primary node even if this is a backup.
    
    Specified by:
    
    getForcePrimary in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to get value for.
    
    Returns:
    Value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - getForcePrimaryAsync
```
public IgniteInternalFuture<V> getForcePrimaryAsync(K key)
```
    Asynchronously gets value from cache. Will go to primary node even if this is a backup.
    
    Specified by:
    
    getForcePrimaryAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to get value for.
    
    Returns:
    Future with result.
  - getTopologySafe
```
public V getTopologySafe(K key)
                  throws IgniteCheckedException
```
    Gets value without waiting for toplogy changes.
    
    Specified by:
    
    getTopologySafe in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    
    Returns:
    Value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - getAllOutTx
```
@Nullable
public Map<K,V> getAllOutTx(Set<? extends K> keys)
                     throws IgniteCheckedException
```
    Gets values from cache. Will bypass started transaction, if any, i.e. will not enlist entries and will not lock any keys if pessimistic transaction is started by thread.
    
    Specified by:
    
    getAllOutTx in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to get values for.
    
    Returns:
    Value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - getAllOutTxAsync
```
public IgniteInternalFuture<Map<K,V>> getAllOutTxAsync(Set<? extends K> keys)
```
    Gets values from cache. Will bypass started transaction, if any, i.e. will not enlist entries and will not lock any keys if pessimistic transaction is started by thread.
    
    Specified by:
    
    getAllOutTxAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to get values for.
    
    Returns:
    Future for getAllOutTx operation.
  - entryExSafe
```
@Nullable
protected GridCacheEntryEx entryExSafe(KeyCacheObject key,
                                    AffinityTopologyVersion topVer)
```
    Parameters:
    key - Key.
    topVer - Topology version.
    
    Returns:
    Entry.
  - get
```
@Nullable
public V get(K key)
      throws IgniteCheckedException
```
    Retrieves value mapped to the specified key from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. The return value of null means entry did not pass the provided filter or cache has no mapping for the key.
    If the value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disable, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#load(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    get in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to retrieve the value for.
    
    Returns:
    Value for the given key.
    
    Throws:
    
    IgniteCheckedException - If get operation failed.
  - getEntry
```
@Nullable
public CacheEntry<K,V> getEntry(K key)
                         throws IgniteCheckedException
```
    Retrieves value mapped to the specified key from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. The return value of null means entry did not pass the provided filter or cache has no mapping for the key.
    If the value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disable, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#load(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getEntry in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to retrieve the value for.
    
    Returns:
    Value for the given key.
    
    Throws:
    
    IgniteCheckedException - If get operation failed.
  - getAsync
```
public IgniteInternalFuture<V> getAsync(K key)
```
    Asynchronously retrieves value mapped to the specified key from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. The return value of null means entry did not pass the provided filter or cache has no mapping for the key.
    If the value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disabled, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#load(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key for the value to get.
    
    Returns:
    Future for the get operation.
  - getEntryAsync
```
public IgniteInternalFuture<CacheEntry<K,V>> getEntryAsync(K key)
```
    Asynchronously retrieves value mapped to the specified key from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. The return value of null means entry did not pass the provided filter or cache has no mapping for the key.
    If the value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disabled, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#load(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getEntryAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key for the value to get.
    
    Returns:
    Future for the get operation.
  - getAll
```
public Map<K,V> getAll(@Nullable
              Collection<? extends K> keys)
                throws IgniteCheckedException
```
    Retrieves values mapped to the specified keys from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. If requested key-value pair is not present in the returned map, then it means that its entry did not pass the provided filter or cache has no mapping for the key.
    If some value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disabled, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#loadAll(Transaction, Collection, org.apache.ignite.lang.IgniteBiInClosure) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to get.
    
    Returns:
    Map of key-value pairs.
    
    Throws:
    
    IgniteCheckedException - If get operation failed.
  - getEntries
```
public Collection<CacheEntry<K,V>> getEntries(@Nullable
                                     Collection<? extends K> keys)
                                       throws IgniteCheckedException
```
    Retrieves values mapped to the specified keys from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. If requested key-value pair is not present in the returned map, then it means that its entry did not pass the provided filter or cache has no mapping for the key.
    If some value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disabled, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#loadAll(Transaction, Collection, org.apache.ignite.lang.IgniteBiInClosure) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getEntries in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to get.
    
    Returns:
    Map of key-value pairs.
    
    Throws:
    
    IgniteCheckedException - If get operation failed.
  - getAllAsync
```
public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable
                                         Collection<? extends K> keys)
```
    Asynchronously retrieves values mapped to the specified keys from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. If requested key-value pair is not present in the returned map, then it means that its entry did not pass the provided filter or cache has no mapping for the key.
    If some value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disabled, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#loadAll(Transaction, Collection, org.apache.ignite.lang.IgniteBiInClosure) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAllAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Key for the value to get.
    
    Returns:
    Future for the get operation.
  - getEntriesAsync
```
public IgniteInternalFuture<Collection<CacheEntry<K,V>>> getEntriesAsync(@Nullable
                                                                Collection<? extends K> keys)
```
    Asynchronously retrieves values mapped to the specified keys from cache. Value will only be returned if its entry passed the optional filter provided. Filter check is atomic, and therefore the returned value is guaranteed to be consistent with the filter. If requested key-value pair is not present in the returned map, then it means that its entry did not pass the provided filter or cache has no mapping for the key.
    If some value is not present in cache, then it will be looked up from swap storage. If it's not present in swap, or if swap is disabled, and if read-through is allowed, value will be loaded from CacheStore persistent storage via CacheStore#loadAll(Transaction, Collection, org.apache.ignite.lang.IgniteBiInClosure) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getEntriesAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Key for the value to get.
    
    Returns:
    Future for the get operation.
  - getAsync
```
protected IgniteInternalFuture<V> getAsync(K key,
                               boolean forcePrimary,
                               boolean skipTx,
                               @Nullable
                               UUID subjId,
                               String taskName,
                               boolean deserializeBinary,
                               boolean skipVals,
                               boolean canRemap,
                               boolean needVer)
```
    Parameters:
    key - Key.
    forcePrimary - Force primary.
    skipTx - Skip tx.
    subjId - Subj Id.
    taskName - Task name.
    deserializeBinary - Deserialize binary.
    skipVals - Skip values.
    canRemap - Can remap flag.
    needVer - Need version.
    
    Returns:
    Future for the get operation.
  - getAllAsync
```
protected IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable
                                         Collection<? extends K> keys,
                                         boolean forcePrimary,
                                         boolean skipTx,
                                         @Nullable
                                         UUID subjId,
                                         String taskName,
                                         boolean deserializeBinary,
                                         boolean skipVals,
                                         boolean canRemap,
                                         boolean needVer)
```
    Parameters:
    keys - Keys.
    forcePrimary - Force primary.
    skipTx - Skip tx.
    subjId - Subj Id.
    taskName - Task name.
    deserializeBinary - Deserialize binary.
    skipVals - Skip values.
    canRemap - Can remap flag.
    needVer - Need version.
    
    Returns:
    Future for the get operation.
    See Also:
    getAllAsync(Collection)
  - getAllAsync
```
public final IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable
                                         Collection<? extends K> keys,
                                         boolean readThrough,
                                         boolean checkTx,
                                         @Nullable
                                         UUID subjId,
                                         String taskName,
                                         boolean deserializeBinary,
                                         boolean forcePrimary,
                                         @Nullable
                                         IgniteCacheExpiryPolicy expiry,
                                         boolean skipVals,
                                         boolean canRemap,
                                         boolean needVer)
```
    Parameters:
    keys - Keys.
    readThrough - Read through.
    checkTx - Check tx.
    subjId - Subj Id.
    taskName - Task name.
    deserializeBinary - Deserialize binary.
    forcePrimary - Froce primary.
    expiry - Expiry policy.
    skipVals - Skip values.
    canRemap - Can remap flag.
    needVer - Need version.
    
    Returns:
    Future for the get operation.
    See Also:
    getAllAsync(Collection)
  - getAllAsync0
```
public final <K1,V1> IgniteInternalFuture<Map<K1,V1>> getAllAsync0(@Nullable
                                                    Collection<KeyCacheObject> keys,
                                                    boolean readThrough,
                                                    boolean checkTx,
                                                    @Nullable
                                                    UUID subjId,
                                                    String taskName,
                                                    boolean deserializeBinary,
                                                    @Nullable
                                                    IgniteCacheExpiryPolicy expiry,
                                                    boolean skipVals,
                                                    boolean keepCacheObjects,
                                                    boolean canRemap,
                                                    boolean needVer)
```
    Parameters:
    keys - Keys.
    readThrough - Read-through flag.
    checkTx - Check local transaction flag.
    subjId - Subject ID.
    taskName - Task name/
    deserializeBinary - Deserialize binary flag.
    expiry - Expiry policy.
    skipVals - Skip values flag.
    keepCacheObjects - Keep cache objects.
    canRemap - Can remap flag.
    needVer - If true returns values as tuples containing value and version.
    
    Returns:
    Future.
  - getAndPut
```
public V getAndPut(K key,
          V val)
            throws IgniteCheckedException
```
    Stores given key-value pair in cache. If filters are provided, then entries will be stored in cache only if they pass the filter. Note that filter check is atomic, so value stored in cache is guaranteed to be consistent with the filters. If cache previously contained value for the given key, then this value is returned. In case of CacheMode.PARTITIONED or CacheMode.REPLICATED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method #putx(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndPut in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Previous value associated with specified key, or null if entry did not pass the filter, or if there was no mapping for the key in swap or in persistent storage.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - getAndPut
```
@Nullable
public V getAndPut(K key,
                   V val,
                   @Nullable
                   CacheEntryPredicate filter)
            throws IgniteCheckedException
```
    Parameters:
    key - Key.
    val - Value.
    filter - Optional filter.
    
    Returns:
    Previous value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - getAndPutAsync
```
public IgniteInternalFuture<V> getAndPutAsync(K key,
                                     V val)
```
    Asynchronously stores given key-value pair in cache. If filters are provided, then entries will be stored in cache only if they pass the filter. Note that filter check is atomic, so value stored in cache is guaranteed to be consistent with the filters. If cache previously contained value for the given key, then this value is returned. Otherwise, in case of CacheMode.REPLICATED caches, the value will be loaded from swap and, if it's not there, and read-through is allowed, from the underlying CacheStore storage. In case of CacheMode.PARTITIONED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap and read-through is allowed, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method #putx(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndPutAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Future for the put operation.
  - getAndPutAsync
```
public IgniteInternalFuture<V> getAndPutAsync(K key,
                                     V val,
                                     @Nullable
                                     CacheEntryPredicate filter)
```
    Parameters:
    key - Key.
    val - Value.
    filter - Filter.
    
    Returns:
    Put operation future.
  - getAndPutAsync0
```
public IgniteInternalFuture<V> getAndPutAsync0(K key,
                                      V val,
                                      @Nullable
                                      CacheEntryPredicate filter)
```
    Parameters:
    key - Key.
    val - Value.
    filter - Optional filter.
    
    Returns:
    Put operation future.
  - put
```
public boolean put(K key,
          V val)
            throws IgniteCheckedException
```
    Stores given key-value pair in cache. If filters are provided, then entries will be stored in cache only if they pass the filter. Note that filter check is atomic, so value stored in cache is guaranteed to be consistent with the filters.
    This method will return true if value is stored in cache and false otherwise. Unlike #put(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) method, it does not return previous value and, therefore, does not have any overhead associated with returning a value. It should be used whenever return value is not required.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    put in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    True if optional filter passed and value was stored in cache, false otherwise. Note that this method will return true if filter is not specified.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - put
```
public boolean put(K key,
          V val,
          CacheEntryPredicate filter)
            throws IgniteCheckedException
```
    Parameters:
    key - Key.
    val - Value.
    filter - Filter.
    
    Returns:
    True if optional filter passed and value was stored in cache, false otherwise. Note that this method will return true if filter is not specified.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - putAllConflict
```
public void putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
                    throws IgniteCheckedException
```
    Store DR data.
    
    Specified by:
    
    putAllConflict in interface IgniteInternalCache<K,V>
    
    Parameters:
    drMap - DR map.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - putAllConflictAsync
```
public IgniteInternalFuture<?> putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
                                            throws IgniteCheckedException
```
    Store DR data asynchronously.
    
    Specified by:
    
    putAllConflictAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    drMap - DR map.
    
    Returns:
    Future.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - invoke
```
@Nullable
public <T> javax.cache.processor.EntryProcessorResult<T> invoke(@Nullable
                                                                AffinityTopologyVersion topVer,
                                                                K key,
                                                                javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                Object... args)
                                                     throws IgniteCheckedException
```
    Specified by:
    
    invoke in interface IgniteInternalCache<K,V>
    
    Parameters:
    topVer - Locked topology version.
    key - Key.
    entryProcessor - Entry processor.
    args - Arguments.
    
    Returns:
    Invoke result.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - invoke
```
public <T> javax.cache.processor.EntryProcessorResult<T> invoke(K key,
                                                       javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                       Object... args)
                                                     throws IgniteCheckedException
```
    Specified by:
    
    invoke in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    entryProcessor - Entry processor.
    args - Arguments.
    
    Returns:
    Invoke result.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - invokeAll
```
public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Set<? extends K> keys,
                                                                 javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                 Object... args)
                                                               throws IgniteCheckedException
```
    Specified by:
    
    invokeAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys.
    entryProcessor - Entry processor.
    args - Arguments.
    
    Returns:
    Invoke results.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - invokeAsync
```
public <T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> invokeAsync(K key,
                                                                                  javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                                  Object... args)
                                                                                throws javax.cache.processor.EntryProcessorException
```
    Specified by:
    
    invokeAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    entryProcessor - Entry processor.
    args - Arguments.
    
    Returns:
    Future.
    
    Throws:
    
    javax.cache.processor.EntryProcessorException
  - invokeAllAsync
```
public <T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Set<? extends K> keys,
                                                                                            javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                                            Object... args)
```
    Specified by:
    
    invokeAllAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys.
    entryProcessor - Entry processor.
    args - Arguments.
    
    Returns:
    Future.
  - invokeAllAsync
```
public <T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
                                                                                            Object... args)
```
    Specified by:
    
    invokeAllAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    map - Map containing keys and entry processors to be applied to values.
    args - Arguments.
    
    Returns:
    Future.
  - invokeAll
```
public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
                                                                 Object... args)
                                                               throws IgniteCheckedException
```
    Specified by:
    
    invokeAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    map - Map containing keys and entry processors to be applied to values.
    args - Arguments.
    
    Returns:
    Invoke results.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - putAsync
```
public IgniteInternalFuture<Boolean> putAsync(K key,
                                     V val)
```
    Stores given key-value pair in cache. If filters are provided, then entries will be stored in cache only if they pass the filter. Note that filter check is atomic, so value stored in cache is guaranteed to be consistent with the filters.
    This method will return true if value is stored in cache and false otherwise. Unlike #put(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) method, it does not return previous value and, therefore, does not have any overhead associated with returning of a value. It should always be used whenever return value is not required.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    putAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Future for the put operation. Future will return true if optional filter passed and value was stored in cache, false otherwise. Note that future will return true if filter is not specified.
  - putAsync
```
public IgniteInternalFuture<Boolean> putAsync(K key,
                                     V val,
                                     @Nullable
                                     CacheEntryPredicate filter)
```
    Parameters:
    key - Key.
    val - Value.
    filter - Filter.
    
    Returns:
    Put future.
  - putAsync0
```
public IgniteInternalFuture<Boolean> putAsync0(K key,
                                      V val,
                                      @Nullable
                                      CacheEntryPredicate filter)
```
    Parameters:
    key - Key.
    val - Value.
    filter - Optional filter.
    
    Returns:
    Putx operation future.
  - tryGetAndPut
```
@Nullable
public V tryGetAndPut(K key,
                      V val)
               throws IgniteCheckedException
```
    Tries to get and put value in cache. Will fail with GridCacheTryPutFailedException if topology exchange is in progress.
    
    Specified by:
    
    tryGetAndPut in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key.
    val - value.
    
    Returns:
    Old value.
    
    Throws:
    
    IgniteCheckedException - In case of error.
  - getAndPutIfAbsent
```
@Nullable
public V getAndPutIfAbsent(K key,
                           V val)
                    throws IgniteCheckedException
```
    Stores given key-value pair in cache only if cache had no previous mapping for it. If cache previously contained value for the given key, then this value is returned. In case of CacheMode.PARTITIONED or CacheMode.REPLICATED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method IgniteInternalCache.putIfAbsent(Object, Object) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndPutIfAbsent in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Previously contained value regardless of whether put happened or not.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - getAndPutIfAbsentAsync
```
public IgniteInternalFuture<V> getAndPutIfAbsentAsync(K key,
                                             V val)
```
    Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it. If cache previously contained value for the given key, then this value is returned. In case of CacheMode.PARTITIONED or CacheMode.REPLICATED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method IgniteInternalCache.putIfAbsentAsync(Object, Object) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndPutIfAbsentAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Future of put operation which will provide previously contained value regardless of whether put happened or not.
  - putIfAbsent
```
public boolean putIfAbsent(K key,
                  V val)
                    throws IgniteCheckedException
```
    Stores given key-value pair in cache only if cache had no previous mapping for it.
    This method will return true if value is stored in cache and false otherwise. Unlike IgniteInternalCache.getAndPutIfAbsent(Object, Object) method, it does not return previous value and, therefore, does not have any overhead associated with returning of a value. It should always be used whenever return value is not required.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    putIfAbsent in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    true if value is stored in cache and false otherwise.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - putIfAbsentAsync
```
public IgniteInternalFuture<Boolean> putIfAbsentAsync(K key,
                                             V val)
```
    Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
    This method will return true if value is stored in cache and false otherwise. Unlike IgniteInternalCache.getAndPutIfAbsent(Object, Object) method, it does not return previous value and, therefore, does not have any overhead associated with returning of a value. It should always be used whenever return value is not required.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    putIfAbsentAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Future for this put operation.
  - getAndReplace
```
@Nullable
public V getAndReplace(K key,
                       V val)
                throws IgniteCheckedException
```
    Stores given key-value pair in cache only if there is a previous mapping for it. In case of CacheMode.PARTITIONED or CacheMode.REPLICATED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method IgniteInternalCache.replace(Object, Object) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndReplace in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Previously contained value regardless of whether replace happened or not.
    
    Throws:
    
    IgniteCheckedException - If replace operation failed.
  - getAndReplaceAsync
```
public IgniteInternalFuture<V> getAndReplaceAsync(K key,
                                         V val)
```
    Asynchronously stores given key-value pair in cache only if there is a previous mapping for it. If cache previously contained value for the given key, then this value is returned.In case of CacheMode.PARTITIONED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method IgniteInternalCache.replace(Object, Object) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndReplaceAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Future for replace operation.
  - replace
```
public boolean replace(K key,
              V val)
                throws IgniteCheckedException
```
    Stores given key-value pair in cache only if only if there is a previous mapping for it.
    This method will return true if value is stored in cache and false otherwise. Unlike IgniteInternalCache.getAndReplace(Object, Object) method, it does not return previous value and, therefore, does not have any overhead associated with returning of a value. It should always be used whenever return value is not required.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    replace in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    True if replace happened, false otherwise.
    
    Throws:
    
    IgniteCheckedException - If replace operation failed.
  - replaceAsync
```
public IgniteInternalFuture<Boolean> replaceAsync(K key,
                                         V val)
```
    Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
    This method will return true if value is stored in cache and false otherwise. Unlike IgniteInternalCache.getAndReplaceAsync(Object, Object) method, it does not return previous value and, therefore, does not have any overhead associated with returning of a value. It should always be used whenever return value is not required.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    replaceAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    val - Value to be associated with the given key.
    
    Returns:
    Future for the replace operation.
  - replace
```
public boolean replace(K key,
              V oldVal,
              V newVal)
                throws IgniteCheckedException
```
    Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
    This method will return true if value is stored in cache and false otherwise.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    replace in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    oldVal - Old value to match.
    newVal - Value to be associated with the given key.
    
    Returns:
    True if replace happened, false otherwise.
    
    Throws:
    
    IgniteCheckedException - If replace operation failed.
  - replaceAsync
```
public IgniteInternalFuture<Boolean> replaceAsync(K key,
                                         V oldVal,
                                         V newVal)
```
    Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
    This method will return true if value is stored in cache and false otherwise.
    If write-through is enabled, the stored value will be persisted to CacheStore via CacheStore#put(Transaction, Object, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    replaceAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to store in cache.
    oldVal - Old value to match.
    newVal - Value to be associated with the given key.
    
    Returns:
    Future for the replace operation.
  - putAll
```
public void putAll(@Nullable
          Map<? extends K,? extends V> m)
            throws IgniteCheckedException
```
    Stores given key-value pairs in cache. If filters are provided, then entries will be stored in cache only if they pass the filter. Note that filter check is atomic, so value stored in cache is guaranteed to be consistent with the filters.
    If write-through is enabled, the stored values will be persisted to CacheStore via CacheStore#putAll(Transaction, Map) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    putAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    m - Key-value pairs to store in cache.
    
    Throws:
    
    IgniteCheckedException - If put operation failed.
  - putAllAsync
```
public IgniteInternalFuture<?> putAllAsync(Map<? extends K,? extends V> m)
```
    Asynchronously stores given key-value pairs in cache. If filters are provided, then entries will be stored in cache only if they pass the filter. Note that filter check is atomic, so value stored in cache is guaranteed to be consistent with the filters.
    If write-through is enabled, the stored values will be persisted to CacheStore via CacheStore#putAll(Transaction, Map) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    putAllAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    m - Key-value pairs to store in cache.
    
    Returns:
    Future for putAll operation.
  - getAndRemove
```
@Nullable
public V getAndRemove(K key)
               throws IgniteCheckedException
```
    Removes given key mapping from cache. If cache previously contained value for the given key, then this value is returned. In case of CacheMode.PARTITIONED or CacheMode.REPLICATED caches, the value will be loaded from the primary node, which in its turn may load the value from the disk-based swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method #removex(Object, org.apache.ignite.lang.IgnitePredicate[]) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the value will be removed from CacheStore via CacheStore#remove(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndRemove in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key whose mapping is to be removed from cache.
    
    Returns:
    Previous value associated with specified key, or null if there was no value for this key.
    
    Throws:
    
    IgniteCheckedException - If remove operation failed.
  - getAndRemoveAsync
```
public IgniteInternalFuture<V> getAndRemoveAsync(K key)
```
    Asynchronously removes given key mapping from cache. If cache previously contained value for the given key, then this value is returned. In case of CacheMode.PARTITIONED or CacheMode.REPLICATED caches, the value will be loaded from the primary node, which in its turn may load the value from the swap storage, and consecutively, if it's not in swap, from the underlying persistent storage. If value has to be loaded from persistent storage, CacheStore#load(Transaction, Object) method will be used.
    If the returned value is not needed, method #removex(Object, org.apache.ignite.lang.IgnitePredicate[]) should always be used instead of this one to avoid the overhead associated with returning of the previous value.
    If write-through is enabled, the value will be removed from CacheStore via CacheStore#remove(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    getAndRemoveAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key whose mapping is to be removed from cache.
    
    Returns:
    Future for the remove operation.
  - removeAll
```
public void removeAll()
               throws IgniteCheckedException
```
    Removes mappings from cache.
    USE WITH CARE - if your cache has many entries then transaction will quickly become very heavy and slow.
    If write-through is enabled, the values will be removed from CacheStore via IgniteDataStreamer.
    Transactions
    This method is not transactional.
    
    Specified by:
    
    removeAll in interface IgniteInternalCache<K,V>
    
    Throws:
    
    IgniteCheckedException - If remove failed.
  - removeAll
```
public void removeAll(Collection<? extends K> keys)
               throws IgniteCheckedException
```
    Removes given key mappings from cache.
    If write-through is enabled, the values will be removed from CacheStore via IgniteDataStreamer.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    removeAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys whose mappings are to be removed from cache.
    
    Throws:
    
    IgniteCheckedException - If remove failed.
  - removeAllAsync
```
public IgniteInternalFuture<?> removeAllAsync(@Nullable
                                     Collection<? extends K> keys)
```
    Asynchronously removes given key mappings from cache for entries.
    If write-through is enabled, the values will be removed from CacheStore via IgniteDataStreamer.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    removeAllAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys whose mappings are to be removed from cache.
    
    Returns:
    Future for the remove operation. The future will complete whenever remove operation completes.
  - remove
```
public boolean remove(K key)
               throws IgniteCheckedException
```
    Removes given key mapping from cache.
    This method will return true if remove did occur, which means that all optionally provided filters have passed and there was something to remove, false otherwise.
    If write-through is enabled, the value will be removed from CacheStore via CacheStore#remove(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    remove in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key whose mapping is to be removed from cache.
    
    Returns:
    True if filter passed validation and entry was removed, false otherwise. Note that if filter is not specified, this method will return true.
    
    Throws:
    
    IgniteCheckedException - If remove failed.
  - removeAsync
```
public IgniteInternalFuture<Boolean> removeAsync(K key)
```
    Asynchronously removes given key mapping from cache.
    This method will return true if remove did occur, which means that all optionally provided filters have passed and there was something to remove, false otherwise.
    If write-through is enabled, the value will be removed from CacheStore via CacheStore#remove(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    removeAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key whose mapping is to be removed from cache.
    
    Returns:
    Future for the remove operation. The future will return true if optional filters passed validation and remove did occur, false otherwise. Note that if filter is not specified, this method will return true.
  - removeAsync
```
public IgniteInternalFuture<Boolean> removeAsync(K key,
                                        @Nullable
                                        CacheEntryPredicate filter)
```
    Parameters:
    key - Key to remove.
    filter - Optional filter.
    
    Returns:
    Putx operation future.
  - removeAllConflict
```
public void removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
                       throws IgniteCheckedException
```
    Removes DR data.
    
    Specified by:
    
    removeAllConflict in interface IgniteInternalCache<K,V>
    
    Parameters:
    drMap - DR map.
    
    Throws:
    
    IgniteCheckedException - If remove failed.
  - removeAllConflictAsync
```
public IgniteInternalFuture<?> removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
                                               throws IgniteCheckedException
```
    Removes DR data asynchronously.
    
    Specified by:
    
    removeAllConflictAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    drMap - DR map.
    
    Returns:
    Future.
    
    Throws:
    
    IgniteCheckedException - If remove failed.
  - remove
```
public boolean remove(K key,
             V val)
               throws IgniteCheckedException
```
    Removes given key mapping from cache if one exists and value is equal to the passed in value.
    If write-through is enabled, the value will be removed from CacheStore via CacheStore#remove(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    remove in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key whose mapping is to be removed from cache.
    val - Value to match against currently cached value.
    
    Returns:
    True if entry was removed and passed in value matched the cached one, false otherwise.
    
    Throws:
    
    IgniteCheckedException - If remove failed.
  - removeAsync
```
public IgniteInternalFuture<Boolean> removeAsync(K key,
                                        V val)
```
    Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
    This method will return true if remove did occur, which means that all optionally provided filters have passed and there was something to remove, false otherwise.
    If write-through is enabled, the value will be removed from CacheStore via CacheStore#remove(Transaction, Object) method.
    Transactions
    This method is transactional and will enlist the entry into ongoing transaction if there is one.
    
    Specified by:
    
    removeAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key whose mapping is to be removed from cache.
    val - Value to match against currently cached value.
    
    Returns:
    Future for the remove operation. The future will return true if currently cached value will match the passed in one.
  - clusterMetrics
```
public CacheMetrics clusterMetrics()
```
    Gets whole cluster metrics (statistics) for this cache.
    
    Specified by:
    
    clusterMetrics in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache metrics.
  - clusterMetrics
```
public CacheMetrics clusterMetrics(ClusterGroup grp)
```
    Gets cluster group metrics (statistics) for this cache.
    
    Specified by:
    
    clusterMetrics in interface IgniteInternalCache<K,V>
    
    Parameters:
    grp - Cluster group.
    
    Returns:
    Cache metrics.
  - localMetrics
```
public CacheMetrics localMetrics()
```
    Gets local metrics (statistics) for this cache.
    
    Specified by:
    
    localMetrics in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache metrics.
  - localMxBean
```
public CacheMetricsMXBean localMxBean()
```
    Gets local metrics (statistics) for this cache.
    
    Specified by:
    
    localMxBean in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache metrics.
  - clusterMxBean
```
public CacheMetricsMXBean clusterMxBean()
```
    Gets whole cluster metrics (statistics) for this cache.
    
    Specified by:
    
    clusterMxBean in interface IgniteInternalCache<K,V>
    
    Returns:
    Cache metrics.
  - metrics0
```
public CacheMetricsImpl metrics0()
```
    Returns:
    Metrics.
  - tx
```
@Nullable
public Transaction tx()
```
    Gets transaction started by this thread or null if this thread does not have a transaction.
    
    Specified by:
    
    tx in interface IgniteInternalCache<K,V>
    
    Returns:
    Transaction started by this thread or null if this thread does not have a transaction.
  - lock
```
public boolean lock(K key,
           long timeout)
             throws IgniteCheckedException
```
    Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes. This method together with filter check will be executed as one atomic operation.
    Transactions
    Locks are not transactional and should not be used from within transactions. If you do need explicit locking within transaction, then you should use TransactionConcurrency.PESSIMISTIC concurrency control for transaction which will acquire explicit locks for relevant cache operations.
    
    Specified by:
    
    lock in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to lock.
    timeout - Timeout in milliseconds to wait for lock to be acquired ('0' for no expiration), -1 for immediate failure if lock cannot be acquired immediately).
    
    Returns:
    True if all filters passed and lock was acquired, false otherwise.
    
    Throws:
    
    IgniteCheckedException - If lock acquisition resulted in error.
  - lockAll
```
public boolean lockAll(@Nullable
              Collection<? extends K> keys,
              long timeout)
                throws IgniteCheckedException
```
    All or nothing synchronous lock for passed in keys. This method together with filter check will be executed as one atomic operation. If at least one filter validation failed, no locks will be acquired.
    Transactions
    Locks are not transactional and should not be used from within transactions. If you do need explicit locking within transaction, then you should use TransactionConcurrency.PESSIMISTIC concurrency control for transaction which will acquire explicit locks for relevant cache operations.
    
    Specified by:
    
    lockAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to lock.
    timeout - Timeout in milliseconds to wait for lock to be acquired ('0' for no expiration).
    
    Returns:
    True if all filters passed and locks were acquired before timeout has expired, false otherwise.
    
    Throws:
    
    IgniteCheckedException - If lock acquisition resulted in error.
  - lockAsync
```
public IgniteInternalFuture<Boolean> lockAsync(K key,
                                      long timeout)
```
    Asynchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes. This method together with filter check will be executed as one atomic operation.
    Transactions
    Locks are not transactional and should not be used from within transactions. If you do need explicit locking within transaction, then you should use TransactionConcurrency.PESSIMISTIC concurrency control for transaction which will acquire explicit locks for relevant cache operations.
    
    Specified by:
    
    lockAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to lock.
    timeout - Timeout in milliseconds to wait for lock to be acquired ('0' for no expiration, -1 for immediate failure if lock cannot be acquired immediately).
    
    Returns:
    Future for the lock operation. The future will return true whenever all filters pass and locks are acquired before timeout is expired, false otherwise.
  - unlock
```
public void unlock(K key)
            throws IgniteCheckedException
```
    Unlocks given key only if current thread owns the lock. If optional filter will not pass, then unlock will not happen. If the key being unlocked was never locked by current thread, then this method will do nothing.
    Transactions
    Locks are not transactional and should not be used from within transactions. If you do need explicit locking within transaction, then you should use TransactionConcurrency.PESSIMISTIC concurrency control for transaction which will acquire explicit locks for relevant cache operations.
    
    Specified by:
    
    unlock in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to unlock.
    
    Throws:
    
    IgniteCheckedException - If unlock execution resulted in error.
  - isLocked
```
public boolean isLocked(K key)
```
    Checks if any node owns a lock for this key.
    This is a local in-VM operation and does not involve any network trips or access to persistent storage in any way.
    
    Specified by:
    
    isLocked in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to check.
    
    Returns:
    True if lock is owned by some node.
  - isLockedByThread
```
public boolean isLockedByThread(K key)
```
    Checks if current thread owns a lock on this key.
    This is a local in-VM operation and does not involve any network trips or access to persistent storage in any way.
    
    Specified by:
    
    isLockedByThread in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to check.
    
    Returns:
    True if key is locked by current thread.
  - txStart
```
public Transaction txStart(TransactionConcurrency concurrency,
                  TransactionIsolation isolation)
```
    Starts new transaction with the specified concurrency and isolation.
    
    Specified by:
    
    txStart in interface IgniteInternalCache<K,V>
    
    Parameters:
    concurrency - Concurrency.
    isolation - Isolation.
    
    Returns:
    New transaction.
  - txStartEx
```
public IgniteInternalTx txStartEx(TransactionConcurrency concurrency,
                         TransactionIsolation isolation)
```
    Specified by:
    
    txStartEx in interface IgniteInternalCache<K,V>
    
    Parameters:
    concurrency - Concurrency.
    isolation - Isolation.
    
    Returns:
    New transaction.
  - txStart
```
public Transaction txStart(TransactionConcurrency concurrency,
                  TransactionIsolation isolation,
                  long timeout,
                  int txSize)
                    throws IllegalStateException
```
    Starts transaction with specified isolation, concurrency, timeout, invalidation flag, and number of participating entries.
    
    Specified by:
    
    txStart in interface IgniteInternalCache<K,V>
    
    Parameters:
    concurrency - Concurrency.
    isolation - Isolation.
    timeout - Timeout.
    txSize - Number of entries participating in transaction (may be approximate).
    
    Returns:
    New transaction.
    
    Throws:
    
    IllegalStateException - If transaction is already started by this thread.
  - overflowSize
```
public long overflowSize()
                  throws IgniteCheckedException
```
    Gets size (in bytes) of all entries swapped to disk.
    
    Specified by:
    
    overflowSize in interface IgniteInternalCache<K,V>
    
    Returns:
    Size (in bytes) of all entries swapped to disk.
    
    Throws:
    
    IgniteCheckedException - In case of error.
  - checkJta
```
protected void checkJta()
                 throws IgniteCheckedException
```
    Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
    
    Throws:
    
    IgniteCheckedException - In case of error.
  - localLoadCache
```
public void localLoadCache(IgniteBiPredicate<K,V> p,
                  Object[] args)
                    throws IgniteCheckedException
```
    Delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method to load state from the underlying persistent storage. The loaded values will then be given to the optionally passed in predicate, and, if the predicate returns true, will be stored in cache. If predicate is null, then all loaded values will be stored in cache.
    Note that this method does not receive keys as a parameter, so it is up to CacheStore implementation to provide all the data to be loaded.
    This method is not transactional and may end up loading a stale value into cache if another thread has updated the value immediately after it has been loaded. It is mostly useful when pre-loading the cache from underlying data store before start, or for read-only caches.
    
    Specified by:
    
    localLoadCache in interface IgniteInternalCache<K,V>
    
    Parameters:
    p - Optional predicate (may be null). If provided, will be used to filter values to be put into cache.
    args - Optional user arguments to be passed into CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method.
    
    Throws:
    
    IgniteCheckedException - If loading failed.
  - localLoadCacheAsync
```
public IgniteInternalFuture<?> localLoadCacheAsync(IgniteBiPredicate<K,V> p,
                                          Object[] args)
```
    Asynchronously delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method to reload state from the underlying persistent storage. The reloaded values will then be given to the optionally passed in predicate, and if the predicate returns true, will be stored in cache. If predicate is null, then all reloaded values will be stored in cache.
    Note that this method does not receive keys as a parameter, so it is up to CacheStore implementation to provide all the data to be loaded.
    This method is not transactional and may end up loading a stale value into cache if another thread has updated the value immediately after it has been loaded. It is mostly useful when pre-loading the cache from underlying data store before start, or for read-only caches.
    
    Specified by:
    
    localLoadCacheAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    p - Optional predicate (may be null). If provided, will be used to filter values to be put into cache.
    args - Optional user arguments to be passed into CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method.
    
    Returns:
    Future to be completed whenever loading completes.
  - loadAll
```
public IgniteInternalFuture<?> loadAll(Set<? extends K> keys,
                              boolean replaceExisting)
```
    Parameters:
    keys - Keys.
    replaceExisting - Replace existing values flag.
    
    Returns:
    Load future.
  - localLoad
```
public void localLoad(Collection<? extends K> keys,
             @Nullable
             javax.cache.expiry.ExpiryPolicy plc,
             boolean keepBinary)
               throws IgniteCheckedException
```
    Parameters:
    keys - Keys to load.
    plc - Optional expiry policy.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - randomEntry
```
@Deprecated
@Nullable
public javax.cache.Cache.Entry<K,V> randomEntry()
```
    Deprecated.
    
    Returns:
    Random cache entry.
  - size
```
public int size(CachePeekMode[] peekModes)
         throws IgniteCheckedException
```
    Specified by:
    
    size in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Global cache size.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - sizeLong
```
public long sizeLong(CachePeekMode[] peekModes)
              throws IgniteCheckedException
```
    Specified by:
    
    sizeLong in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Global cache size as a long value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - sizeLong
```
public long sizeLong(int partition,
            CachePeekMode[] peekModes)
              throws IgniteCheckedException
```
    Specified by:
    
    sizeLong in interface IgniteInternalCache<K,V>
    
    Parameters:
    partition - partition
    peekModes - Peek modes.
    
    Returns:
    Global cache size as a long value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - sizeAsync
```
public IgniteInternalFuture<Integer> sizeAsync(CachePeekMode[] peekModes)
```
    Specified by:
    
    sizeAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Future.
  - sizeLongAsync
```
public IgniteInternalFuture<Long> sizeLongAsync(CachePeekMode[] peekModes)
```
    Specified by:
    
    sizeLongAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Future.
  - sizeLongAsync
```
public IgniteInternalFuture<Long> sizeLongAsync(int part,
                                       CachePeekMode[] peekModes)
```
    Specified by:
    
    sizeLongAsync in interface IgniteInternalCache<K,V>
    
    Parameters:
    part - partiton
    peekModes - Peek modes.
    
    Returns:
    Future.
  - localSize
```
public int localSize(CachePeekMode[] peekModes)
              throws IgniteCheckedException
```
    Specified by:
    
    localSize in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Local cache size.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - localSizeLong
```
public long localSizeLong(CachePeekMode[] peekModes)
                   throws IgniteCheckedException
```
    Specified by:
    
    localSizeLong in interface IgniteInternalCache<K,V>
    
    Parameters:
    peekModes - Peek modes.
    
    Returns:
    Local cache size as a long value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - localSizeLong
```
public long localSizeLong(int part,
                 CachePeekMode[] peekModes)
                   throws IgniteCheckedException
```
    Specified by:
    
    localSizeLong in interface IgniteInternalCache<K,V>
    
    Parameters:
    part - partition.
    peekModes - Peek modes.
    
    Returns:
    Local cache size as a long value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - size
```
public int size()
```
    Gets the number of all entries cached on this node. This method will return the count of all cache entries and has O(1) complexity on base IgniteInternalCache. It is essentially the size of cache key set and is semantically identical to {Cache.keySet().size().
    NOTE: this operation is not distributed and returns only the number of entries cached on this node.
    
    Specified by:
    
    size in interface IgniteInternalCache<K,V>
    
    Returns:
    Size of cache on this node.
  - sizeLong
```
public long sizeLong()
```
    Gets the number of all entries cached on this node as a long value. This method will return the count of all cache entries and has O(1) complexity on base IgniteInternalCache. It is essentially the size of cache key set and is semantically identical to {Cache.keySet().size().
    NOTE: this operation is not distributed and returns only the number of entries cached on this node.
    
    Specified by:
    
    sizeLong in interface IgniteInternalCache<K,V>
    
    Returns:
    Size of cache on this node.
  - nearSize
```
public int nearSize()
```
    Gets size of near cache key set. This method will return count of all entries in near cache and has O(1) complexity on base cache projection.
    Note that for LOCAL non-distributed caches this method will always return 0
    
    Specified by:
    
    nearSize in interface IgniteInternalCache<K,V>
    
    Returns:
    Size of near cache key set or 0 if cache is not CacheMode.PARTITIONED.
  - primarySize
```
public int primarySize()
```
    Gets the number of all primary entries cached on this node. For CacheMode.LOCAL non-distributed cache mode, this method is identical to IgniteInternalCache.size().
    For CacheMode.PARTITIONED and CacheMode.REPLICATED modes, this method will return number of primary entries cached on this node (excluding any backups). The complexity of this method is O(P), where P is the total number of partitions.
    NOTE: this operation is not distributed and returns only the number of primary entries cached on this node.
    
    Specified by:
    
    primarySize in interface IgniteInternalCache<K,V>
    
    Returns:
    Number of primary entries in cache.
  - primarySizeLong
```
public long primarySizeLong()
```
    Gets the number of all primary entries cached on this node as a long value. For CacheMode.LOCAL non-distributed cache mode, this method is identical to IgniteInternalCache.size().
    For CacheMode.PARTITIONED and CacheMode.REPLICATED modes, this method will return number of primary entries cached on this node (excluding any backups). The complexity of this method is O(P), where P is the total number of partitions.
    NOTE: this operation is not distributed and returns only the number of primary entries cached on this node.
    
    Specified by:
    
    primarySizeLong in interface IgniteInternalCache<K,V>
    
    Returns:
    Number of primary entries in cache.
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - iterator
```
public Iterator<javax.cache.Cache.Entry<K,V>> iterator()
```
    Specified by:
    
    iterator in interface Iterable<javax.cache.Cache.Entry<K,V>>
  - igniteIterator
```
public Iterator<javax.cache.Cache.Entry<K,V>> igniteIterator()
                                                      throws IgniteCheckedException
```
    Returns:
    Distributed ignite cache iterator.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - igniteIterator
```
public Iterator<javax.cache.Cache.Entry<K,V>> igniteIterator(boolean keepBinary)
                                                      throws IgniteCheckedException
```
    Parameters:
    keepBinary -
    
    Returns:
    Distributed ignite cache iterator.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - promote
```
@Nullable
public V promote(K key,
                 boolean deserializeBinary)
          throws IgniteCheckedException
```
    Parameters:
    key - Key.
    deserializeBinary - Deserialize binary flag.
    
    Returns:
    Value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - promoteAll
```
public void promoteAll(@Nullable
              Collection<? extends K> keys)
                throws IgniteCheckedException
```
    This method unswaps cache entries by given keys, if any, from swap storage into memory.
    Transactions
    This method is not transactional.
    
    Specified by:
    
    promoteAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to promote entries for.
    
    Throws:
    
    IgniteCheckedException - If promote failed.
  - offHeapEntriesCount
```
public long offHeapEntriesCount()
```
    Gets number of cache entries stored in off-heap memory.
    
    Specified by:
    
    offHeapEntriesCount in interface IgniteInternalCache<K,V>
    
    Returns:
    Number of cache entries stored in off-heap memory.
  - offHeapAllocatedSize
```
public long offHeapAllocatedSize()
```
    Gets memory size allocated in off-heap.
    
    Specified by:
    
    offHeapAllocatedSize in interface IgniteInternalCache<K,V>
    
    Returns:
    Allocated memory size.
  - swapSize
```
public long swapSize()
              throws IgniteCheckedException
```
    Gets size in bytes for swap space.
    
    Specified by:
    
    swapSize in interface IgniteInternalCache<K,V>
    
    Returns:
    Size in bytes.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - swapKeys
```
public long swapKeys()
              throws IgniteCheckedException
```
    Gets number of swap entries (keys).
    
    Specified by:
    
    swapKeys in interface IgniteInternalCache<K,V>
    
    Returns:
    Number of entries stored in swap.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - commitTxAsync
```
public IgniteInternalFuture<IgniteInternalTx> commitTxAsync(IgniteInternalTx tx)
```
    Asynchronously commits transaction after all previous asynchronous operations are completed.
    
    Parameters:
    tx - Transaction to commit.
    
    Returns:
    Transaction commit future.
  - awaitLastFut
```
public void awaitLastFut()
```
    Awaits for previous async operation to be completed.
  - asyncOp
```
protected <T> IgniteInternalFuture<T> asyncOp(IgniteTxLocalAdapter tx,
                                  GridCacheAdapter.AsyncOp<T> op,
                                  CacheOperationContext opCtx)
```
    Type Parameters:
    T - Return type.
    Parameters:
    tx - Transaction.
    op - Cache operation.
    
    Returns:
    Future.
  - saveFuture
```
protected void saveFuture(GridCacheAdapter.FutureHolder holder,
              IgniteInternalFuture<?> fut)
```
    Saves future in thread local holder and adds listener that will clear holder when future is finished.
    
    Parameters:
    holder - Future holder.
    fut - Future to save.
  - asyncOpAcquire
```
@Nullable
protected <T> IgniteInternalFuture<T> asyncOpAcquire()
```
    Tries to acquire asynchronous operations permit, if limited.
    
    Returns:
    Failed future if waiting was interrupted.
  - asyncOpRelease
```
protected void asyncOpRelease()
```
    Releases asynchronous operations permit, if limited.
  - writeExternal
```
public void writeExternal(ObjectOutput out)
                   throws IOException
```
    Specified by:
    
    writeExternal in interface Externalizable
    
    Throws:
    
    IOException
  - readExternal
```
public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException
```
    Specified by:
    
    readExternal in interface Externalizable
    
    Throws:
    
    IOException
    
    ClassNotFoundException
  - readResolve
```
protected Object readResolve()
                      throws ObjectStreamException
```
    Reconstructs object on unmarshalling.
    
    Returns:
    Reconstructed object.
    
    Throws:
    
    ObjectStreamException - Thrown in case of unmarshalling error.
  - rebalance
```
public IgniteInternalFuture<?> rebalance()
```
    Forces this cache node to re-balance its partitions. This method is usually used when CacheConfiguration.getRebalanceDelay() configuration parameter has non-zero value. When many nodes are started or stopped almost concurrently, it is more efficient to delay rebalancing until the node topology is stable to make sure that no redundant re-partitioning happens.
    In case ofCacheMode.PARTITIONED caches, for better efficiency user should usually make sure that new nodes get placed on the same place of consistent hash ring as the left nodes, and that nodes are restarted before rebalanceDelay expires. To place nodes on the same place in consistent hash ring, use IgniteConfiguration.setConsistentId(Serializable) to make sure that a node maps to the same hash ID if re-started.
    See CacheConfiguration.getRebalanceDelay() for more information on how to configure rebalance re-partition delay.
    
    Specified by:
    
    rebalance in interface IgniteInternalCache<K,V>
    
    Returns:
    Future that will be completed when rebalancing is finished.
  - isIgfsDataCache
```
public boolean isIgfsDataCache()
```
    Checks whether this cache is IGFS data cache.
    
    Specified by:
    
    isIgfsDataCache in interface IgniteInternalCache<K,V>
    
    Returns:
    True in case this cache is IGFS data cache.
  - igfsDataSpaceUsed
```
public long igfsDataSpaceUsed()
```
    Get current amount of used IGFS space in bytes.
    
    Specified by:
    
    igfsDataSpaceUsed in interface IgniteInternalCache<K,V>
    
    Returns:
    Amount of used IGFS space in bytes.
  - igfsDataSpaceMax
```
public long igfsDataSpaceMax()
```
    Get maximum space available for IGFS.
    
    Specified by:
    
    igfsDataSpaceMax in interface IgniteInternalCache<K,V>
    
    Returns:
    Amount of space available for IGFS in bytes.
  - isMongoDataCache
```
public boolean isMongoDataCache()
```
    Checks whether this cache is Mongo data cache.
    
    Specified by:
    
    isMongoDataCache in interface IgniteInternalCache<K,V>
    
    Returns:
    True if this cache is mongo data cache.
  - isMongoMetaCache
```
public boolean isMongoMetaCache()
```
    Checks whether this cache is Mongo meta cache.
    
    Specified by:
    
    isMongoMetaCache in interface IgniteInternalCache<K,V>
    
    Returns:
    True if this cache is mongo meta cache.
  - onIgfsDataSizeChanged
```
public void onIgfsDataSizeChanged(long delta)
```
    Callback invoked when data is added to IGFS cache.
    
    Parameters:
    delta - Size delta.
  - evict
```
public boolean evict(K key)
```
    Evicts entry associated with given key from cache. Note, that entry will be evicted only if it's not used (not participating in any locks or transactions).
    If CacheConfiguration.isSwapEnabled() is set to true, the evicted entry will be swapped to offheap, and then to disk.
    
    Specified by:
    
    evict in interface IgniteInternalCache<K,V>
    
    Parameters:
    key - Key to evict from cache.
    
    Returns:
    True if entry could be evicted, false otherwise.
  - evictAll
```
public void evictAll(Collection<? extends K> keys)
```
    Attempts to evict all entries associated with keys. Note, that entry will be evicted only if it's not used (not participating in any locks or transactions).
    If CacheConfiguration.isSwapEnabled() is set to true, the evicted entry will be swapped to offheap, and then to disk.
    
    Specified by:
    
    evictAll in interface IgniteInternalCache<K,V>
    
    Parameters:
    keys - Keys to evict.
  - entrySet
```
public Set<javax.cache.Cache.Entry<K,V>> entrySet(@Nullable
                                         CacheEntryPredicate... filter)
```
    Parameters:
    filter - Filters to evaluate.
    
    Returns:
    Entry set.
  - get
```
@Nullable
public V get(K key,
             boolean deserializeBinary,
             boolean needVer)
      throws IgniteCheckedException
```
    Parameters:
    key - Key.
    deserializeBinary - Deserialize binary flag.
    needVer - Need version.
    
    Returns:
    Cached value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - get
```
protected V get(K key,
    String taskName,
    boolean deserializeBinary,
    boolean needVer)
         throws IgniteCheckedException
```
    Parameters:
    key - Key.
    taskName - Task name.
    deserializeBinary - Deserialize binary flag.
    needVer - Need version.
    
    Returns:
    Cached value.
    
    Throws:
    
    IgniteCheckedException - If failed.
  - getAsync
```
public final IgniteInternalFuture<V> getAsync(K key,
                               boolean deserializeBinary,
                               boolean needVer)
```
    Parameters:
    key - Key.
    deserializeBinary - Deserialize binary flag.
    needVer - Need version.
    
    Returns:
    Read operation future.
  - getAll
```
public Map<K,V> getAll(Collection<? extends K> keys,
              boolean deserializeBinary,
              boolean needVer)
                throws IgniteCheckedException
```
    Parameters:
    keys - Keys.
    deserializeBinary - Deserialize binary flag.
    needVer - Need version.
    
    Returns:
    Map of cached values.
    
    Throws:
    
    IgniteCheckedException - If read failed.
  - getAllAsync
```
public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable
                                         Collection<? extends K> keys,
                                         boolean deserializeBinary,
                                         boolean needVer)
```
    Parameters:
    keys - Keys.
    deserializeBinary - Deserialize binary flag.
    needVer - Need version.
    
    Returns:
    Read future.
  - onDeferredDelete
```
public abstract void onDeferredDelete(GridCacheEntryEx entry,
                    GridCacheVersion ver)
```
    Parameters:
    entry - Entry.
    ver - Version.
  - onReconnected
```
public void onReconnected()
```
  - forceKeyCheck
```
public void forceKeyCheck()
```
    For tests only.
  - validateCacheKey
```
protected void validateCacheKey(Object key)
```
    Validates that given cache key has overridden equals and hashCode methods and implements Externalizable.
    
    Parameters:
    key - Cache key.
    
    Throws:
    
    IllegalArgumentException - If validation fails.
  - validateCacheKeys
```
protected void validateCacheKeys(Iterable<?> keys)
```
    Validates that given cache keys have overridden equals and hashCode methods and implement Externalizable.
    
    Parameters:
    keys - Cache keys.
    
    Throws:
    
    IgniteException - If validation fails.
  - iterator
```
protected Iterator<javax.cache.Cache.Entry<K,V>> iterator(Iterator<? extends GridCacheEntryEx> it,
                                              boolean deserializeBinary)
```
    Parameters:
    it - Internal entry iterator.
    deserializeBinary - Deserialize binary flag.
    
    Returns:
    Public API iterator.
  - expiryPolicy
```
@Nullable
public IgniteCacheExpiryPolicy expiryPolicy(@Nullable
                                            javax.cache.expiry.ExpiryPolicy plc)
```
    Parameters:
    plc - Explicitly specified expiry policy for cache operation.
    
    Returns:
    Expiry policy wrapper.

Class GridCacheAdapter<K,V>

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.ignite.internal.processors.cache.IgniteInternalCache

Field Detail

CLEAR_ALL_SPLIT_THRESHOLD

MAX_RETRIES

LOAD_CACHE_JOB_SINCE

LOAD_CACHE_JOB_V2_SINCE

RET2NULL

keyCheck

lastFut

ctx

map

locNodeId

cacheCfg

gridCfg

metrics

localMxBean

clusterMxBean

log

txLockMsgLog

Constructor Detail

GridCacheAdapter

GridCacheAdapter

GridCacheAdapter

Method Detail

name

printMemoryStats

map

incrementSize

decrementSize

context

log

isNear

isLocal

isColocated

isDhtAtomic

isDht

preloader

affinity

cache

forSubjectId

skipStore

setSkipStore

keepBinary

expiry

withExpiryPolicy

withNoRetries

configuration

txLockAsync

init

entryFactory

start

startInfo

stop

stopInfo

onKernalStart

onKernalStop

isEmpty

containsKey

containsKeyAsync

containsKeys

containsKeysAsync

localEntries

localPeek

onUndeploy

peekEx

peekEx

entryEx

entryEx

entryEx

entryEx

entries

allEntries

entrySet

entrySetx