GridCacheContext (Ignite 1.2.0-incubating)

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

All Implemented Interfaces:: Externalizable, Serializable

@GridToStringExclude
public class GridCacheContext<K,V>
extends Object
implements Externalizable

Cache context.

See Also:: Serialized Form

Constructor Summary

Constructors
Constructor and Description
`GridCacheContext()` Empty constructor required for `Externalizable`.
GridCacheContext(GridKernalContext ctx, GridCacheSharedContext sharedCtx, CacheConfiguration cacheCfg, CacheType cacheType, boolean affNode, boolean updatesAllowed, GridCacheEventManager evtMgr, GridCacheSwapManager swapMgr, CacheStoreManager storeMgr, GridCacheEvictionManager evictMgr, GridCacheQueryManager<K,V> qryMgr, CacheContinuousQueryManager contQryMgr, GridCacheAffinityManager affMgr, CacheDataStructuresManager dataStructuresMgr, GridCacheTtlManager ttlMgr, GridCacheDrManager drMgr, CacheJtaManagerAdapter jtaMgr, CacheConflictResolutionManager<K,V> rslvrMgr, CachePluginManager pluginMgr)

Method Summary

Methods
Modifier and Type	Method and Description
`<K1,V1> void`	`addResult(Map<K1,V1> map, KeyCacheObject key, CacheObject val, boolean skipVals, boolean keepCacheObjects, boolean deserializePortable, boolean cpy)`
`GridCacheAffinityManager`	`affinity()`
`boolean`	`affinityNode()`
`boolean`	`atomic()`
`void`	`awaitStarted()`
`GridCacheAdapter<K,V>`	`cache()`
`void`	`cache(GridCacheAdapter<K,V> cache)`
`int`	`cacheId()`
`Collection<KeyCacheObject>`	`cacheKeysView(Collection<?> keys)`
`CacheObjectContext`	`cacheObjectContext()`
`void`	`cacheObjectContext(CacheObjectContext cacheObjCtx)` Sets cache object context.
`IgniteCacheObjectProcessor`	`cacheObjects()`
`boolean`	`cancelRemove(IgniteBiTuple<Boolean,?> interceptorRes)`
`void`	`checkSecurity(SecurityPermission op)`
`void`	`cleanup()` Nulling references to potentially leak-prone objects.
`GridClosureProcessor`	`closures()`
`GridDhtColocatedCache<K,V>`	`colocated()`
`CacheConfiguration`	`config()`
`boolean`	`conflictNeedResolve()` Check whether conflict resolution is required.
`GridCacheVersionConflictContext<K,V>`	`conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry, GridCacheVersionedEntryEx<K,V> newEntry, boolean atomicVerComp)` Resolve DR conflict.
`CacheContinuousQueryManager`	`continuousQueries()`
`byte`	`dataCenterId()`
`CacheDataStructuresManager`	`dataStructures()`
`void`	`decrementPublicSize(GridCacheMapEntry e)`
`AffinityKeyMapper`	`defaultAffMapper()`
`boolean`	`deferredDelete()`
`GridCacheDeploymentManager<K,V>`	`deploy()`
`boolean`	`deploymentEnabled()`
`GridDhtCacheAdapter<K,V>`	`dht()`
`boolean`	`dhtMap(GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)`
`boolean`	`dhtMap(UUID nearNodeId, AffinityTopologyVersion topVer, GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)`
`GridDhtTransactionalCacheAdapter<K,V>`	`dhtTx()`
`GridDiscoveryManager`	`discovery()`
`GridCacheDrManager`	`dr()`
`IgniteUuid`	`dynamicDeploymentId()`
`GridCacheVersion[]`	`emptyVersion()`
`CacheEntryPredicate[]`	`equalsValArray(V val)`
`CacheEntryPredicate`	`equalsValue(V val)`
`GridCacheEventManager`	`events()`
`GridCacheEvictionManager`	`evicts()`
`javax.cache.expiry.ExpiryPolicy`	`expiry()`
`javax.cache.expiry.ExpiryPolicy`	`expiryForTxEntry(IgniteTxEntry txEntry)`
`CacheObject`	`fromOffheap(long valPtr, boolean tmp)`
`GridCacheGateway<K,V>`	`gate()`
`IgniteEx`	`grid()`
`IgniteConfiguration`	`gridConfig()`
`GridDeploymentManager`	`gridDeploy()`
`GridEventStorageManager`	`gridEvents()`
`GridIoManager`	`gridIO()`
`String`	`gridName()`
`GridSwapSpaceManager`	`gridSwap()`
`boolean`	`hasKey(Iterable<? extends K> keys, Collection<Integer> movingParts)` Checks if at least one of the given keys belongs to one of the given partitions.
`CacheEntryPredicate[]`	`hasValArray()`
`void`	`incrementPublicSize(GridCacheMapEntry e)`
`GridCacheIoManager`	`io()`
`GridIoPolicy`	`ioPolicy()`
`<E> boolean`	`isAll(E e, IgnitePredicate<? super E>[] p)` Same as `GridFunc.isAll(Object, IgnitePredicate[])`, but safely unwraps exceptions.
`boolean`	`isAll(GridCacheEntryEx e, CacheEntryPredicate[] p)`
`<K1,V1> boolean`	`isAll(GridCacheEntryEx e, IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)` Same as `GridFunc.isAll(Object, IgnitePredicate[])`, but safely unwraps exceptions.
`boolean`	`isAllLocked(GridCacheEntryEx e, CacheEntryPredicate[] p)`
`boolean`	`isColocated()`
`boolean`	`isDht()`
`boolean`	`isDhtAtomic()`
`boolean`	`isDrEnabled()`
`boolean`	`isInvalidate()`
`boolean`	`isLocal()`
`boolean`	`isLocalNode(ClusterNode n)`
`boolean`	`isLocalNode(UUID id)`
`boolean`	`isNear()`
`boolean`	`isOffHeapEnabled()`
`boolean`	`isReplicated()`
`boolean`	`isSwapOrOffheapEnabled()`
`CacheWeakQueryIteratorsHolder<Map.Entry<K,V>>`	`itHolder()`
`CacheJtaManagerAdapter`	`jta()`
`boolean`	`keepPortable()`
`GridKernalContext`	`kernalContext()`
`boolean`	`loadPreviousValue()`
`GridLocalCache<K,V>`	`local()`
`ClusterNode`	`localNode()`
`UUID`	`localNodeId()`
`IgniteLogger`	`logger(Class<?> cls)`
`IgniteLogger`	`logger(String ctgr)`
`List<GridCacheManager<K,V>>`	`managers()`
`Marshaller`	`marshaller()`
`GridCacheMvccManager`	`mvcc()`
`String`	`name()`
`String`	`namex()` Gets public name for cache.
`String`	`namexx()` Gets public cache name substituting null name by `'default'`.
`GridNearCacheAdapter<K,V>`	`near()`
`GridNearTransactionalCache<K,V>`	`nearTx()`
`ClusterNode`	`node(UUID nodeId)`
`UUID`	`nodeId()`
`CacheEntryPredicate[]`	`noValArray()`
`GridOffHeapProcessor`	`offheap()`
`boolean`	`offheapTiered()`
`void`	`onDeferredDelete(GridCacheEntryEx entry, GridCacheVersion ver)`
`void`	`onStarted()`
`CacheOperationContext`	`operationContextPerCall()` Gets thread local cache operation context.
`void`	`operationContextPerCall(CacheOperationContext opCtx)` Sets thread local cache operation context.
`CachePluginManager`	`plugin()`
`GridCachePreloader`	`preloader()`
`void`	`printMemoryStats()` Print memory statistics of all cache managers.
`<T> Callable<T>`	`projectSafe(Callable<T> r)` Creates callable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread.
`Runnable`	`projectSafe(Runnable r)` Creates Runnable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread.
`boolean`	`putIfAbsentFilter(CacheEntryPredicate[] p)`
`GridCacheQueryManager<K,V>`	`queries()`
`void`	`readExternal(ObjectInput in)`
`protected Object`	`readResolve()` Reconstructs object on unmarshalling.
`boolean`	`readThrough()`
`boolean`	`rebalanceEnabled()`
`GridCacheSharedContext<K,V>`	`shared()`
`boolean`	`skipStore()`
`boolean`	`started()`
`AffinityTopologyVersion`	`startTopologyVersion()`
`void`	`startTopologyVersion(AffinityTopologyVersion startTopVer)`
`CacheStoreManager`	`store()`
`UUID`	`subjectIdPerCall(UUID subjId)` Gets subject ID per call.
`UUID`	`subjectIdPerCall(UUID subjId, CacheOperationContext opCtx)` Gets subject ID per call.
`GridCacheSwapManager`	`swap()`
`boolean`	`syncCommit()`
`boolean`	`syncPrimary()`
`boolean`	`syncRollback()`
`boolean`	`systemTx()`
`GridTimeoutProcessor`	`time()`
`IgniteTxManager`	`tm()`
`KeyCacheObject`	`toCacheKeyObject(byte[] bytes)`
`KeyCacheObject`	`toCacheKeyObject(Object obj)`
`CacheObject`	`toCacheObject(Object obj)`
`GridDhtPartitionTopology`	`topology()`
`GridDhtTopologyFuture`	`topologyVersionFuture()`
`String`	`toString()`
`boolean`	`transactional()`
`GridCacheTtlManager`	`ttl()`
`IgniteTxKey`	`txKey(KeyCacheObject key)`
`GridUnsafeMemory`	`unsafeMemory()`
`CacheObject`	`unswapCacheObject(byte type, byte[] bytes, IgniteUuid clsLdrId)`
`Object`	`unwrapPortableIfNeeded(Object o, boolean keepPortable)` Unwraps object for portables.
`Collection<Object>`	`unwrapPortablesIfNeeded(Collection<Object> col, boolean keepPortable)` Unwraps collection.
`<T> T`	`unwrapTemporary(Object obj)` Converts temporary offheap object to heap-based.
`boolean`	`updatesAllowed()`
`boolean`	`useOffheapEntry()`
`boolean`	`userCache()`
`IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]`	`vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p)`
`GridCacheVersionManager`	`versions()`
`void`	`writeExternal(ObjectOutput out)`
`boolean`	`writeThrough()`
`boolean`	`writeToStoreFromDht()`

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

Constructor Detail

GridCacheContext
```
public GridCacheContext()
```
Empty constructor required for Externalizable.

GridCacheContext

public GridCacheContext(GridKernalContext ctx,
                GridCacheSharedContext sharedCtx,
                CacheConfiguration cacheCfg,
                CacheType cacheType,
                boolean affNode,
                boolean updatesAllowed,
                GridCacheEventManager evtMgr,
                GridCacheSwapManager swapMgr,
                CacheStoreManager storeMgr,
                GridCacheEvictionManager evictMgr,
                GridCacheQueryManager<K,V> qryMgr,
                CacheContinuousQueryManager contQryMgr,
                GridCacheAffinityManager affMgr,
                CacheDataStructuresManager dataStructuresMgr,
                GridCacheTtlManager ttlMgr,
                GridCacheDrManager drMgr,
                CacheJtaManagerAdapter jtaMgr,
                CacheConflictResolutionManager<K,V> rslvrMgr,
                CachePluginManager pluginMgr)

Parameters:: ctx - Kernal context.; sharedCtx - Cache shared context.; cacheCfg - Cache configuration.; cacheType - Cache type.; affNode - True if local node is affinity node.; updatesAllowed - Updates allowed flag.; evtMgr - Cache event manager.; swapMgr - Cache swap manager.; storeMgr - Store manager.; evictMgr - Cache eviction manager.; qryMgr - Cache query manager.; contQryMgr - Continuous query manager.; affMgr - Affinity manager.; dataStructuresMgr - Cache dataStructures manager.; ttlMgr - TTL manager.; drMgr - Data center replication manager.; jtaMgr - JTA manager.; rslvrMgr - Conflict resolution manager.; pluginMgr - Cache plugin manager.

Method Detail
- dynamicDeploymentId
```
public IgniteUuid dynamicDeploymentId()
```
  Returns:
  Dynamic deployment ID.
- affinityNode
```
public boolean affinityNode()
```
  Returns:
  True if local node is affinity node.
- awaitStarted
```
public void awaitStarted()
                  throws IgniteCheckedException
```
  Throws:
  
  IgniteCheckedException - If failed to wait.
- started
```
public boolean started()
```
  Returns:
  Started flag.
- onStarted
```
public void onStarted()
```
- startTopologyVersion
```
public AffinityTopologyVersion startTopologyVersion()
```
  Returns:
  Start topology version.
- startTopologyVersion
```
public void startTopologyVersion(AffinityTopologyVersion startTopVer)
```
  Parameters:
  startTopVer - Start topology version.
- expiry
```
@Nullable
public javax.cache.expiry.ExpiryPolicy expiry()
```
  Returns:
  Cache default ExpiryPolicy.
- expiryForTxEntry
```
@Nullable
public javax.cache.expiry.ExpiryPolicy expiryForTxEntry(IgniteTxEntry txEntry)
```
  Parameters:
  txEntry - TX entry.
  
  Returns:
  Expiry policy for the given TX entry.
- managers
```
public List<GridCacheManager<K,V>> managers()
```
  Returns:
  Cache managers.
- shared
```
public GridCacheSharedContext<K,V> shared()
```
  Returns:
  Shared cache context.
- cacheId
```
public int cacheId()
```
  Returns:
  Cache ID.
- systemTx
```
public boolean systemTx()
```
  Returns:
  True if should use system transactions which are isolated from user transactions.
- userCache
```
public boolean userCache()
```
  Returns:
  True if cache created by user.
- ioPolicy
```
public GridIoPolicy ioPolicy()
```
  Returns:
  IO policy for the given cache.
- cache
```
public void cache(GridCacheAdapter<K,V> cache)
```
  Parameters:
  cache - Cache.
- local
```
public GridLocalCache<K,V> local()
```
  Returns:
  Local cache.
- isDht
```
public boolean isDht()
```
  Returns:
  True if cache is DHT.
- isDhtAtomic
```
public boolean isDhtAtomic()
```
  Returns:
  True if cache is DHT atomic.
- isColocated
```
public boolean isColocated()
```
  Returns:
  True if cache is colocated (dht with near disabled).
- isNear
```
public boolean isNear()
```
  Returns:
  True if cache is near cache.
- isLocal
```
public boolean isLocal()
```
  Returns:
  True if cache is local.
- isReplicated
```
public boolean isReplicated()
```
  Returns:
  True if cache is replicated cache.
- isDrEnabled
```
public boolean isDrEnabled()
```
  Returns:
  True in case replication is enabled.
- deferredDelete
```
public boolean deferredDelete()
```
  Returns:
  True if entries should not be deleted from cache immediately.
- incrementPublicSize
```
public void incrementPublicSize(GridCacheMapEntry e)
```
  Parameters:
  e - Entry.
- decrementPublicSize
```
public void decrementPublicSize(GridCacheMapEntry e)
```
  Parameters:
  e - Entry.
- dht
```
public GridDhtCacheAdapter<K,V> dht()
```
  Returns:
  DHT cache.
- dhtTx
```
public GridDhtTransactionalCacheAdapter<K,V> dhtTx()
```
  Returns:
  Transactional DHT cache.
- colocated
```
public GridDhtColocatedCache<K,V> colocated()
```
  Returns:
  Colocated cache.
- near
```
public GridNearCacheAdapter<K,V> near()
```
  Returns:
  Near cache.
- nearTx
```
public GridNearTransactionalCache<K,V> nearTx()
```
  Returns:
  Near cache for transactional mode.
- gate
```
public GridCacheGateway<K,V> gate()
```
  Returns:
  Cache gateway.
- unsafeMemory
```
@Nullable
public GridUnsafeMemory unsafeMemory()
```
  Returns:
  Instance of GridUnsafeMemory object.
- kernalContext
```
public GridKernalContext kernalContext()
```
  Returns:
  Kernal context.
- grid
```
public IgniteEx grid()
```
  Returns:
  Grid instance.
- gridName
```
public String gridName()
```
  Returns:
  Grid name.
- name
```
public String name()
```
  Returns:
  Cache name.
- namex
```
public String namex()
```
  Gets public name for cache.
  
  Returns:
  Public name of the cache.
- namexx
```
public String namexx()
```
  Gets public cache name substituting null name by 'default'.
  
  Returns:
  Public cache name substituting null name by 'default'.
- txKey
```
public IgniteTxKey txKey(KeyCacheObject key)
```
  Parameters:
  key - Key to construct tx key for.
  
  Returns:
  Transaction key.
- checkSecurity
```
public void checkSecurity(SecurityPermission op)
                   throws SecurityException
```
  Parameters:
  op - Operation to check.
  
  Throws:
  
  SecurityException - If security check failed.
- preloader
```
public GridCachePreloader preloader()
```
  Returns:
  Preloader.
- nodeId
```
public UUID nodeId()
```
  Returns:
  Local node ID.
- rebalanceEnabled
```
public boolean rebalanceEnabled()
```
  Returns:
  True if rebalance is enabled.
- atomic
```
public boolean atomic()
```
  Returns:
  True if atomic.
- transactional
```
public boolean transactional()
```
  Returns:
  True if transactional.
- localNode
```
public ClusterNode localNode()
```
  Returns:
  Local node.
- localNodeId
```
public UUID localNodeId()
```
  Returns:
  Local node ID.
- isLocalNode
```
public boolean isLocalNode(ClusterNode n)
```
  Parameters:
  n - Node to check.
  
  Returns:
  True if node is local.
- isLocalNode
```
public boolean isLocalNode(UUID id)
```
  Parameters:
  id - Node ID to check.
  
  Returns:
  True if node ID is local.
- node
```
@Nullable
public ClusterNode node(UUID nodeId)
```
  Parameters:
  nodeId - Node id.
  
  Returns:
  Node.
- topology
```
public GridDhtPartitionTopology topology()
```
  Returns:
  Partition topology.
- topologyVersionFuture
```
public GridDhtTopologyFuture topologyVersionFuture()
```
  Returns:
  Topology version future.
- marshaller
```
public Marshaller marshaller()
```
  Returns:
  Marshaller.
- logger
```
public IgniteLogger logger(String ctgr)
```
  Parameters:
  ctgr - Category to log.
  
  Returns:
  Logger.
- logger
```
public IgniteLogger logger(Class<?> cls)
```
  Parameters:
  cls - Class to log.
  
  Returns:
  Logger.
- gridConfig
```
public IgniteConfiguration gridConfig()
```
  Returns:
  Grid configuration.
- gridIO
```
public GridIoManager gridIO()
```
  Returns:
  Grid communication manager.
- time
```
public GridTimeoutProcessor time()
```
  Returns:
  Grid timeout processor.
- offheap
```
public GridOffHeapProcessor offheap()
```
  Returns:
  Grid off-heap processor.
- gridDeploy
```
public GridDeploymentManager gridDeploy()
```
  Returns:
  Grid deployment manager.
- gridSwap
```
public GridSwapSpaceManager gridSwap()
```
  Returns:
  Grid swap space manager.
- gridEvents
```
public GridEventStorageManager gridEvents()
```
  Returns:
  Grid event storage manager.
- closures
```
public GridClosureProcessor closures()
```
  Returns:
  Closures processor.
- discovery
```
public GridDiscoveryManager discovery()
```
  Returns:
  Grid discovery manager.
- cache
```
public GridCacheAdapter<K,V> cache()
```
  Returns:
  Cache instance.
- config
```
public CacheConfiguration config()
```
  Returns:
  Cache configuration for given cache instance.
- writeToStoreFromDht
```
public boolean writeToStoreFromDht()
```
  Returns:
  True If store writes should be performed from dht transactions. This happens if both writeBehindEnabled and writeBehindPreferPrimary cache configuration properties are set to true or the store is local.
- tm
```
public IgniteTxManager tm()
```
  Returns:
  Cache transaction manager.
- versions
```
public GridCacheVersionManager versions()
```
  Returns:
  Lock order manager.
- mvcc
```
public GridCacheMvccManager mvcc()
```
  Returns:
  Lock manager.
- events
```
public GridCacheEventManager events()
```
  Returns:
  Event manager.
- affinity
```
public GridCacheAffinityManager affinity()
```
  Returns:
  Cache affinity manager.
- queries
```
public GridCacheQueryManager<K,V> queries()
```
  Returns:
  Query manager, null if disabled.
- continuousQueries
```
public CacheContinuousQueryManager continuousQueries()
```
  Returns:
  Continuous query manager, null if disabled.
- itHolder
```
public CacheWeakQueryIteratorsHolder<Map.Entry<K,V>> itHolder()
```
  Returns:
  Iterators Holder.
- swap
```
public GridCacheSwapManager swap()
```
  Returns:
  Swap manager.
- store
```
public CacheStoreManager store()
```
  Returns:
  Store manager.
- deploy
```
public GridCacheDeploymentManager<K,V> deploy()
```
  Returns:
  Cache deployment manager.
- io
```
public GridCacheIoManager io()
```
  Returns:
  Cache communication manager.
- evicts
```
public GridCacheEvictionManager evicts()
```
  Returns:
  Eviction manager.
- dataStructures
```
public CacheDataStructuresManager dataStructures()
```
  Returns:
  Data structures manager.
- dr
```
public GridCacheDrManager dr()
```
  Returns:
  DR manager.
- ttl
```
public GridCacheTtlManager ttl()
```
  Returns:
  TTL manager.
- jta
```
public CacheJtaManagerAdapter jta()
```
  Returns:
  JTA manager.
- plugin
```
public CachePluginManager plugin()
```
  Returns:
  Cache plugin manager.
- putIfAbsentFilter
```
public boolean putIfAbsentFilter(@Nullable
                        CacheEntryPredicate[] p)
```
  Parameters:
  p - Predicate.
  
  Returns:
  True if given predicate is filter for putIfAbsent operation.
- noValArray
```
public CacheEntryPredicate[] noValArray()
```
  Returns:
  No value filter.
- hasValArray
```
public CacheEntryPredicate[] hasValArray()
```
  Returns:
  Has value filter.
- equalsValArray
```
public CacheEntryPredicate[] equalsValArray(V val)
```
  Parameters:
  val - Value to check.
  
  Returns:
  Predicate array that checks for value.
- equalsValue
```
public CacheEntryPredicate equalsValue(V val)
```
  Parameters:
  val - Value to check.
  
  Returns:
  Predicate that checks for value.
- emptyVersion
```
public GridCacheVersion[] emptyVersion()
```
  Returns:
  Empty cache version array.
- defaultAffMapper
```
public AffinityKeyMapper defaultAffMapper()
```
  Returns:
  Default affinity key mapper.
- cacheObjectContext
```
public void cacheObjectContext(CacheObjectContext cacheObjCtx)
```
  Sets cache object context.
  
  Parameters:
  cacheObjCtx - Cache object context.
- vararg
```
public IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p)
```
  Parameters:
  p - Single predicate.
  
  Returns:
  Array containing single predicate.
- isAll
```
public <K1,V1> boolean isAll(GridCacheEntryEx e,
                    @Nullable
                    IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)
              throws IgniteCheckedException
```
  Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
  
  Parameters:
  e - Element.
  p - Predicates.
  
  Returns:
  True if predicates passed.
  
  Throws:
  
  IgniteCheckedException - If failed.
- isAll
```
public <E> boolean isAll(E e,
                @Nullable
                IgnitePredicate<? super E>[] p)
              throws IgniteCheckedException
```
  Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
  
  Type Parameters:
  E - Element type.
  Parameters:
  e - Element.
  p - Predicates.
  
  Returns:
  True if predicates passed.
  
  Throws:
  
  IgniteCheckedException - If failed.
- isAll
```
public boolean isAll(GridCacheEntryEx e,
            CacheEntryPredicate[] p)
              throws IgniteCheckedException
```
  Parameters:
  e - Entry.
  p - Predicates.
  
  Returns:
  True if predicates passed.
  
  Throws:
  
  IgniteCheckedException - If failed.
- isAllLocked
```
public boolean isAllLocked(GridCacheEntryEx e,
                  CacheEntryPredicate[] p)
                    throws IgniteCheckedException
```
  Parameters:
  e - Entry.
  p - Predicates.
  
  Returns:
  True if predicates passed.
  
  Throws:
  
  IgniteCheckedException - If failed.
- operationContextPerCall
```
public void operationContextPerCall(@Nullable
                           CacheOperationContext opCtx)
```
  Sets thread local cache operation context.
  
  Parameters:
  opCtx - Flags to set.
- operationContextPerCall
```
public CacheOperationContext operationContextPerCall()
```
  Gets thread local cache operation context.
  
  Returns:
  Operation context per call.
- subjectIdPerCall
```
public UUID subjectIdPerCall(@Nullable
                    UUID subjId)
```
  Gets subject ID per call.
  
  Parameters:
  subjId - Optional already existing subject ID.
  
  Returns:
  Subject ID per call.
- subjectIdPerCall
```
public UUID subjectIdPerCall(@Nullable
                    UUID subjId,
                    @Nullable
                    CacheOperationContext opCtx)
```
  Gets subject ID per call.
  
  Parameters:
  subjId - Optional already existing subject ID.
  opCtx - Optional thread local operation context.
  
  Returns:
  Subject ID per call.
- skipStore
```
public boolean skipStore()
```
  Returns:
  true if the skip store flag is set.
- projectSafe
```
public Runnable projectSafe(Runnable r)
```
  Creates Runnable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread. If no projection is set for current thread then there's no need to create new object and method simply returns given Runnable.
  
  Parameters:
  r - Runnable.
  
  Returns:
  Runnable that can be executed in a different thread with the same projection as for current thread.
- projectSafe
```
public <T> Callable<T> projectSafe(Callable<T> r)
```
  Creates callable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread. If no projection is set for current thread then there's no need to create new object and method simply returns given callable.
  
  Parameters:
  r - Callable.
  
  Returns:
  Callable that can be executed in a different thread with the same projection as for current thread.
- deploymentEnabled
```
public boolean deploymentEnabled()
```
  Returns:
  True if deployment enabled.
- isSwapOrOffheapEnabled
```
public boolean isSwapOrOffheapEnabled()
```
  Returns:
  True if swap store of off-heap cache are enabled.
- isOffHeapEnabled
```
public boolean isOffHeapEnabled()
```
  Returns:
  True if offheap storage is enabled.
- readThrough
```
public boolean readThrough()
```
  Returns:
  True if store read-through mode is enabled.
- loadPreviousValue
```
public boolean loadPreviousValue()
```
  Returns:
  True if store read-through mode is enabled.
- writeThrough
```
public boolean writeThrough()
```
  Returns:
  True if store write-through is enabled.
- isInvalidate
```
public boolean isInvalidate()
```
  Returns:
  True if invalidation is enabled.
- syncCommit
```
public boolean syncCommit()
```
  Returns:
  True if synchronous commit is enabled.
- syncRollback
```
public boolean syncRollback()
```
  Returns:
  True if synchronous rollback is enabled.
- syncPrimary
```
public boolean syncPrimary()
```
  Returns:
  True if only primary node should be updated synchronously.
- dhtMap
```
public boolean dhtMap(UUID nearNodeId,
             AffinityTopologyVersion topVer,
             GridDhtCacheEntry entry,
             GridCacheVersion explicitLockVer,
             IgniteLogger log,
             Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
             @Nullable
             Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
               throws GridCacheEntryRemovedException
```
  Parameters:
  nearNodeId - Near node ID.
  topVer - Topology version.
  entry - Entry.
  log - Log.
  dhtMap - Dht mappings.
  nearMap - Near mappings.
  
  Returns:
  True if mapped.
  
  Throws:
  
  GridCacheEntryRemovedException - If reader for entry is removed.
- dhtMap
```
public boolean dhtMap(GridDhtCacheEntry entry,
             GridCacheVersion explicitLockVer,
             IgniteLogger log,
             Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
             Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
               throws GridCacheEntryRemovedException
```
  Parameters:
  entry - Entry.
  log - Log.
  dhtMap - Dht mappings.
  nearMap - Near mappings.
  
  Returns:
  True if mapped.
  
  Throws:
  
  GridCacheEntryRemovedException - If reader for entry is removed.
- hasKey
```
public boolean hasKey(Iterable<? extends K> keys,
             Collection<Integer> movingParts)
```
  Checks if at least one of the given keys belongs to one of the given partitions.
  
  Parameters:
  keys - Collection of keys to check.
  movingParts - Collection of partitions to check against.
  
  Returns:
  True if there exist a key in collection keys that belongs to one of partitions in movingParts
- conflictNeedResolve
```
public boolean conflictNeedResolve()
```
  Check whether conflict resolution is required.
  
  Returns:
  True in case DR is required.
- conflictResolve
```
public GridCacheVersionConflictContext<K,V> conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry,
                                                   GridCacheVersionedEntryEx<K,V> newEntry,
                                                   boolean atomicVerComp)
                                                     throws IgniteCheckedException
```
  Resolve DR conflict.
  
  Parameters:
  oldEntry - Old entry.
  newEntry - New entry.
  atomicVerComp - Whether to use atomic version comparator.
  
  Returns:
  Conflict resolution result.
  
  Throws:
  
  IgniteCheckedException - In case of exception.
- dataCenterId
```
public byte dataCenterId()
```
  Returns:
  Data center ID.
- onDeferredDelete
```
public void onDeferredDelete(GridCacheEntryEx entry,
                    GridCacheVersion ver)
```
  Parameters:
  entry - Entry.
  ver - Version.
- cancelRemove
```
public boolean cancelRemove(@Nullable
                   IgniteBiTuple<Boolean,?> interceptorRes)
```
  Parameters:
  interceptorRes - Result of CacheInterceptor.onBeforeRemove(javax.cache.Cache.Entry<K, V>) callback.
  
  Returns:
  True if interceptor cancels remove.
- cacheObjects
```
public IgniteCacheObjectProcessor cacheObjects()
```
  Returns:
  Portable processor.
- keepPortable
```
public boolean keepPortable()
```
  Returns:
  Keep portable flag.
- offheapTiered
```
public boolean offheapTiered()
```
  Returns:
  True if OFFHEAP_TIERED memory mode is enabled.
- useOffheapEntry
```
public boolean useOffheapEntry()
```
  Returns:
  True if should use entry with offheap value pointer.
- unwrapTemporary
```
@Nullable
public <T> T unwrapTemporary(@Nullable
                             Object obj)
```
  Converts temporary offheap object to heap-based.
  
  Parameters:
  obj - Object.
  
  Returns:
  Heap-based object.
- unwrapPortablesIfNeeded
```
public Collection<Object> unwrapPortablesIfNeeded(Collection<Object> col,
                                         boolean keepPortable)
```
  Unwraps collection.
  
  Parameters:
  col - Collection to unwrap.
  keepPortable - Keep portable flag.
  
  Returns:
  Unwrapped collection.
- unwrapPortableIfNeeded
```
public Object unwrapPortableIfNeeded(Object o,
                            boolean keepPortable)
```
  Unwraps object for portables.
  
  Parameters:
  o - Object to unwrap.
  keepPortable - Keep portable flag.
  
  Returns:
  Unwrapped object.
- cacheObjectContext
```
public CacheObjectContext cacheObjectContext()
```
  Returns:
  Cache object context.
- toCacheObject
```
@Nullable
public CacheObject toCacheObject(@Nullable
                                 Object obj)
```
  Parameters:
  obj - Object.
  
  Returns:
  Cache object.
- toCacheKeyObject
```
public KeyCacheObject toCacheKeyObject(Object obj)
```
  Parameters:
  obj - Object.
  
  Returns:
  Cache key object.
- toCacheKeyObject
```
public KeyCacheObject toCacheKeyObject(byte[] bytes)
                                throws IgniteCheckedException
```
  Parameters:
  bytes - Bytes.
  
  Returns:
  Cache key object.
  
  Throws:
  
  IgniteCheckedException - If failed.
- unswapCacheObject
```
@Nullable
public CacheObject unswapCacheObject(byte type,
                                     byte[] bytes,
                                     @Nullable
                                     IgniteUuid clsLdrId)
                              throws IgniteCheckedException
```
  Parameters:
  type - Type.
  bytes - Bytes.
  clsLdrId - Class loader ID.
  
  Returns:
  Cache object.
  
  Throws:
  
  IgniteCheckedException - If failed.
- fromOffheap
```
public CacheObject fromOffheap(long valPtr,
                      boolean tmp)
                        throws IgniteCheckedException
```
  Parameters:
  valPtr - Value pointer.
  tmp - If true can return temporary instance which is valid while entry lock is held.
  
  Returns:
  Cache object.
  
  Throws:
  
  IgniteCheckedException - If failed.
- addResult
```
public <K1,V1> void addResult(Map<K1,V1> map,
                     KeyCacheObject key,
                     CacheObject val,
                     boolean skipVals,
                     boolean keepCacheObjects,
                     boolean deserializePortable,
                     boolean cpy)
```
  Parameters:
  map - Map.
  key - Key.
  val - Value.
  skipVals - Skip values flag.
  keepCacheObjects - Keep cache objects flag.
  deserializePortable - Deserialize portable flag.
  cpy - Copy flag.
- updatesAllowed
```
public boolean updatesAllowed()
```
  Returns:
  Updates allowed.
- cleanup
```
public void cleanup()
```
  Nulling references to potentially leak-prone objects.
- printMemoryStats
```
public void printMemoryStats()
```
  Print memory statistics of all cache managers. NOTE: this method is for testing and profiling purposes only.
- cacheKeysView
```
public Collection<KeyCacheObject> cacheKeysView(Collection<?> keys)
```
  Parameters:
  keys - Keys.
  
  Returns:
  Co
- 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.
- toString
```
public String toString()
```
  Overrides:
  
  toString in class Object

Class GridCacheContext<K,V>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

GridCacheContext

GridCacheContext

Method Detail

dynamicDeploymentId

affinityNode

awaitStarted

started

onStarted

startTopologyVersion

startTopologyVersion

expiry

expiryForTxEntry

managers

shared

cacheId

systemTx

userCache

ioPolicy

cache

local

isDht

isDhtAtomic

isColocated

isNear

isLocal

isReplicated

isDrEnabled

deferredDelete

incrementPublicSize

decrementPublicSize

dht

dhtTx

colocated

near

nearTx

gate

unsafeMemory

kernalContext

grid

gridName

name

namex

namexx

txKey

checkSecurity

preloader

nodeId

rebalanceEnabled

atomic

transactional

localNode

localNodeId

isLocalNode

isLocalNode

node

topology

topologyVersionFuture

marshaller

logger

logger

gridConfig

gridIO

time

offheap

gridDeploy

gridSwap

gridEvents

closures

discovery

cache

config

writeToStoreFromDht

tm

versions

mvcc