Uses of Interface
org.apache.ignite.internal.processors.cache.CacheEntryPredicate

Packages that use CacheEntryPredicate

Package	Description
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.atomic
org.apache.ignite.internal.processors.cache.distributed.dht.colocated
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.local
org.apache.ignite.internal.processors.cache.local.atomic
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.util	System-wide utility routine and helper classes.

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache

Classes in org.apache.ignite.internal.processors.cache that implement CacheEntryPredicate

Modifier and Type	Class and Description
class	CacheEntryPredicateAdapter
class	CacheEntryPredicateContainsValue
class	CacheEntryPredicateHasValue
class	CacheEntryPredicateNoValue
class	CacheEntrySerializablePredicate

Fields in org.apache.ignite.internal.processors.cache declared as CacheEntryPredicate

Modifier and Type	Field and Description
static CacheEntryPredicate[]	GridCacheConcurrentMap.NON_INTERNAL_ARR Non-internal predicate array.

Methods in org.apache.ignite.internal.processors.cache that return CacheEntryPredicate

Modifier and Type	Method and Description
static CacheEntryPredicate	GridCacheUtils.alwaysFalse0()
static CacheEntryPredicate[]	GridCacheUtils.alwaysFalse0Arr()
static CacheEntryPredicate	GridCacheUtils.alwaysTrue0()
static CacheEntryPredicate	GridCacheUtils.cachePrimary(Affinity aff, ClusterNode n)
static CacheEntryPredicate[]	GridCacheUtils.empty0()
CacheEntryPredicate[]	GridCacheContext.equalsValArray(V val)
CacheEntryPredicate	GridCacheContext.equalsValue(V val)
CacheEntryPredicate[]	GridCacheContext.hasValArray()
CacheEntryPredicate[]	GridCacheContext.noValArray()
CacheEntryPredicate	GridCacheProxyImpl.predicate() Gets predicate on which this projection is based on or null if predicate is not defined.
CacheEntryPredicate	GridCacheProjectionEx.predicate() Gets predicate on which this projection is based on or null if predicate is not defined.
CacheEntryPredicate	GridCacheProjectionImpl.predicate() Gets predicate on which this projection is based on or null if predicate is not defined.
CacheEntryPredicate	CacheEntrySerializablePredicate.predicate()
CacheEntryPredicate	GridCacheAdapter.predicate() Gets predicate on which this projection is based on or null if predicate is not defined.
static <K,V> CacheEntryPredicate[]	GridCacheUtils.readEntryFilterArray(ObjectInput in) Reads array from input stream.
static CacheEntryPredicate	GridCacheUtils.typeFilter0(Class<?> keyType, Class<?> valType)

Methods in org.apache.ignite.internal.processors.cache with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
<K,V> Collection<V>	GridCacheConcurrentMap.allValues(CacheEntryPredicate[] filter) Collection of all (possibly null) values.
boolean	GridCacheEntryEx.clear(GridCacheVersion ver, boolean readers, CacheEntryPredicate[] filter) Marks entry as obsolete and, if possible or required, removes it from swap storage.
boolean	GridCacheMapEntry.clear(GridCacheVersion ver, boolean readers, CacheEntryPredicate[] filter) Marks entry as obsolete and, if possible or required, removes it from swap storage.
void	GridCacheAdapter.clearLocally0(Collection<? extends K> keys, CacheEntryPredicate... filter)
boolean	GridCacheAdapter.clearLocally0(K key, CacheEntryPredicate... filter)
<K,V> Set<javax.cache.Cache.Entry<K,V>>	GridCacheConcurrentMap.entries(CacheEntryPredicate... filter)
<K,V> Set<javax.cache.Cache.Entry<K,V>>	GridCacheConcurrentMap.entriesx(CacheEntryPredicate... filter) Returns entry set containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheAdapter.entrySet(CacheEntryPredicate... filter)
Set<javax.cache.Cache.Entry<K,V>>	GridCacheProxyImpl.entrySetx(CacheEntryPredicate... filter) Gets entry set containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	IgniteCacheProxy.entrySetx(CacheEntryPredicate... filter) Gets entry set containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheProjectionEx.entrySetx(CacheEntryPredicate... filter) Gets entry set containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheProjectionImpl.entrySetx(CacheEntryPredicate... filter) Gets entry set containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheAdapter.entrySetx(CacheEntryPredicate... filter) Gets entry set containing internal entries.
boolean	GridCacheEvictionManager.evict(GridCacheEntryEx entry, GridCacheVersion obsoleteVer, boolean explicit, CacheEntryPredicate[] filter)
boolean	GridCacheAdapter.evict(K key, CacheEntryPredicate... filter)
void	GridCacheAdapter.evictAll(Collection<? extends K> keys, CacheEntryPredicate... filter)
boolean	GridCacheEntryEx.evictInternal(boolean swap, GridCacheVersion obsoleteVer, CacheEntryPredicate[] filter)
boolean	GridCacheMapEntry.evictInternal(boolean swap, GridCacheVersion obsoleteVer, CacheEntryPredicate[] filter)
V	GridCacheProxyImpl.get(K key, GridCacheEntryEx entry, boolean deserializePortable, CacheEntryPredicate... filter)
V	GridCacheProjectionEx.get(K key, GridCacheEntryEx entry, boolean deserializePortable, CacheEntryPredicate... filter)
V	GridCacheProjectionImpl.get(K key, GridCacheEntryEx entry, boolean deserializePortable, CacheEntryPredicate... filter)
V	GridCacheAdapter.get(K key, GridCacheEntryEx entry, boolean deserializePortable, CacheEntryPredicate... filter)
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateAtomicResult	GridCacheEntryEx.innerUpdate(GridCacheVersion ver, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object val, Object[] invokeArgs, boolean writeThrough, boolean retval, IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean checkVer, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long conflictTtl, long conflictExpireTime, GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, UUID subjId, String taskName)
GridCacheUpdateAtomicResult	GridCacheMapEntry.innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean retval, IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean verCheck, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long explicitTtl, long explicitExpireTime, GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, UUID subjId, String taskName)
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>>	GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean retval, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean evt, boolean metrics, CacheEntryPredicate[] filter, boolean intercept, UUID subjId, String taskName) Update method for local cache in atomic mode.
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>>	GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean retval, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean evt, boolean metrics, CacheEntryPredicate[] filter, boolean intercept, UUID subjId, String taskName) Update method for local cache in atomic mode.
boolean	GridCacheEntryEx.invalidate(CacheEntryPredicate[] filter) Invalidates this entry if it passes given filter.
boolean	GridCacheMapEntry.invalidate(CacheEntryPredicate[] filter) Invalidates this entry if it passes given filter.
boolean	GridCacheContext.isAll(GridCacheEntryEx e, CacheEntryPredicate[] p)
boolean	GridCacheContext.isAllLocked(GridCacheEntryEx e, CacheEntryPredicate[] p)
static boolean	GridCacheUtils.isAlwaysFalse0(CacheEntryPredicate[] p)
static boolean	GridCacheUtils.isAlwaysTrue0(CacheEntryPredicate[] p)
Set<K>	GridCacheProxyImpl.keySet(CacheEntryPredicate... filter) Set of keys cached on this node.
Set<K>	CacheProjection.keySet(CacheEntryPredicate... filter) Set of keys cached on this node.
Set<K>	GridCacheProjectionImpl.keySet(CacheEntryPredicate... filter) Set of keys cached on this node.
Set<K>	GridCacheAdapter.keySet(CacheEntryPredicate... filter)
<K,V> Set<K>	GridCacheConcurrentMap.keySet(CacheEntryPredicate... filter) Key set.
IgniteInternalFuture<?>	GridCacheAdapter.localRemoveAll(CacheEntryPredicate filter)
boolean	CacheProjection.lock(K key, long timeout, CacheEntryPredicate... filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	GridCacheProjectionImpl.lock(K key, long timeout, CacheEntryPredicate... filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	GridCacheAdapter.lock(K key, long timeout, CacheEntryPredicate... filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	GridCacheProxyImpl.lock(K key, long timeout, CacheEntryPredicate[] filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	CacheProjection.lockAll(Collection<? extends K> keys, long timeout, CacheEntryPredicate... filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheAdapter.lockAll(Collection<? extends K> keys, long timeout, CacheEntryPredicate... filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheProxyImpl.lockAll(Collection<? extends K> keys, long timeout, CacheEntryPredicate[] filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheProjectionImpl.lockAll(Collection<? extends K> keys, long timeout, CacheEntryPredicate[] filter) All or nothing synchronous lock for passed in keys.
IgniteInternalFuture<Boolean>	CacheProjection.lockAllAsync(Collection<? extends K> keys, long timeout, CacheEntryPredicate... filter) All or nothing synchronous lock for passed in keys.
IgniteInternalFuture<Boolean>	GridCacheProxyImpl.lockAllAsync(Collection<? extends K> keys, long timeout, CacheEntryPredicate[] filter) All or nothing synchronous lock for passed in keys.
IgniteInternalFuture<Boolean>	GridCacheProjectionImpl.lockAllAsync(Collection<? extends K> keys, long timeout, CacheEntryPredicate[] filter) All or nothing synchronous lock for passed in keys.
IgniteInternalFuture<Boolean>	CacheProjection.lockAsync(K key, long timeout, CacheEntryPredicate... filter) Asynchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
IgniteInternalFuture<Boolean>	GridCacheAdapter.lockAsync(K key, long timeout, CacheEntryPredicate... filter) Asynchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
IgniteInternalFuture<Boolean>	GridCacheProxyImpl.lockAsync(K key, long timeout, CacheEntryPredicate[] filter) Asynchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
IgniteInternalFuture<Boolean>	GridCacheProjectionImpl.lockAsync(K key, long timeout, CacheEntryPredicate[] filter) Asynchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
CacheObject	GridCacheEntryEx.peek(Collection<GridCachePeekMode> modes, CacheEntryPredicate... filter) Peeks into entry without loading value or updating statistics.
CacheObject	GridCacheMapEntry.peek(Collection<GridCachePeekMode> modes, CacheEntryPredicate[] filter) Peeks into entry without loading value or updating statistics.
CacheObject	GridCacheEntryEx.peek(GridCachePeekMode mode, CacheEntryPredicate... filter) Peeks into entry without loading value or updating statistics.
CacheObject	GridCacheMapEntry.peek(GridCachePeekMode mode, CacheEntryPredicate[] filter) Peeks into entry without loading value or updating statistics.
V	GridCacheAdapter.peek(K key, CacheEntryPredicate filter)
GridTuple<CacheObject>	GridCacheEntryEx.peek0(boolean failFast, GridCachePeekMode mode, CacheEntryPredicate[] filter, IgniteInternalTx tx)
GridTuple<CacheObject>	GridCacheMapEntry.peek0(boolean failFast, GridCachePeekMode mode, CacheEntryPredicate[] filter, IgniteInternalTx tx)
protected GridTuple<V>	GridCacheAdapter.peek0(boolean failFast, K key, GridCachePeekMode mode, CacheEntryPredicate... filter)
Set<javax.cache.Cache.Entry<K,V>>	GridCacheAdapter.primaryEntrySet(CacheEntryPredicate... filter)
Set<javax.cache.Cache.Entry<K,V>>	GridCacheProxyImpl.primaryEntrySetx(CacheEntryPredicate... filter) Gets set of primary entries containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheProjectionEx.primaryEntrySetx(CacheEntryPredicate... filter) Gets set of primary entries containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheProjectionImpl.primaryEntrySetx(CacheEntryPredicate... filter) Gets set of primary entries containing internal entries.
Set<javax.cache.Cache.Entry<K,V>>	GridCacheAdapter.primaryEntrySetx(CacheEntryPredicate... filter) Gets set of primary entries containing internal entries.
Set<K>	GridCacheAdapter.primaryKeySet(CacheEntryPredicate... filter)
Collection<V>	GridCacheAdapter.primaryValues(CacheEntryPredicate... filter)
CacheProjection<K,V>	GridCacheProxyImpl.projection(CacheEntryPredicate filter) Gets cache projection based on given entry filter.
CacheProjection<K,V>	CacheProjection.projection(CacheEntryPredicate filter) Gets cache projection based on given entry filter.
CacheProjection<K,V>	GridCacheProjectionImpl.projection(CacheEntryPredicate filter) Gets cache projection based on given entry filter.
CacheProjection<K,V>	GridCacheAdapter.projection(CacheEntryPredicate filter) Gets cache projection based on given entry filter.
V	CacheProjection.put(K key, V val, CacheEntryPredicate... filter) Stores given key-value pair in cache.
V	GridCacheAdapter.put(K key, V val, CacheEntryPredicate... filter) Stores given key-value pair in cache.
V	GridCacheProxyImpl.put(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
V	GridCacheProjectionImpl.put(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
V	GridCacheProxyImpl.put(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridCacheProjectionEx.put(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridCacheProjectionImpl.put(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridCacheAdapter.put(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate[] filter) Internal method that is called from CacheEntryImpl.
void	CacheProjection.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate... filter) Stores given key-value pairs in cache.
void	GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Stores given key-value pairs in cache.
void	GridCacheProjectionImpl.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Stores given key-value pairs in cache.
void	GridCacheAdapter.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Stores given key-value pairs in cache.
IgniteInternalFuture<?>	CacheProjection.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate... filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<?>	GridCacheAdapter.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate... filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<?>	GridCacheProxyImpl.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<?>	GridCacheProjectionImpl.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<V>	CacheProjection.putAsync(K key, V val, CacheEntryPredicate... filter) Asynchronously stores given key-value pair in cache.
IgniteInternalFuture<V>	GridCacheProxyImpl.putAsync(K key, V val, CacheEntryPredicate[] filter) Asynchronously stores given key-value pair in cache.
IgniteInternalFuture<V>	GridCacheProjectionImpl.putAsync(K key, V val, CacheEntryPredicate[] filter) Asynchronously stores given key-value pair in cache.
IgniteInternalFuture<V>	GridCacheAdapter.putAsync(K key, V val, CacheEntryPredicate[] filter) Asynchronously stores given key-value pair in cache.
IgniteInternalFuture<V>	GridCacheProxyImpl.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<V>	GridCacheProjectionEx.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<V>	GridCacheAdapter.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<V>	GridCacheProjectionImpl.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate[] filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheContext.putIfAbsentFilter(CacheEntryPredicate[] p)
boolean	CacheProjection.putx(K key, V val, CacheEntryPredicate... filter) Stores given key-value pair in cache.
boolean	GridCacheProxyImpl.putx(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
boolean	GridCacheProjectionImpl.putx(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
boolean	GridCacheAdapter.putx(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
boolean	GridCacheProxyImpl.putx(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheProjectionEx.putx(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheProjectionImpl.putx(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheAdapter.putx(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	CacheProjection.putxAsync(K key, V val, CacheEntryPredicate... filter) Stores given key-value pair in cache.
IgniteInternalFuture<Boolean>	GridCacheAdapter.putxAsync(K key, V val, CacheEntryPredicate... filter) Stores given key-value pair in cache.
IgniteInternalFuture<Boolean>	GridCacheProxyImpl.putxAsync(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
IgniteInternalFuture<Boolean>	GridCacheProjectionImpl.putxAsync(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
IgniteInternalFuture<Boolean>	GridCacheProxyImpl.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridCacheProjectionEx.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridCacheAdapter.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridCacheProjectionImpl.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate[] filter) Internal method that is called from CacheEntryImpl.
V	CacheProjection.remove(K key, CacheEntryPredicate... filter) Removes given key mapping from cache.
V	GridCacheProxyImpl.remove(K key, CacheEntryPredicate[] filter) Removes given key mapping from cache.
V	GridCacheProjectionImpl.remove(K key, CacheEntryPredicate[] filter) Removes given key mapping from cache.
V	GridCacheAdapter.remove(K key, CacheEntryPredicate[] filter) Removes given key mapping from cache.
V	GridCacheProxyImpl.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridCacheProjectionEx.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridCacheProjectionImpl.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridCacheAdapter.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
void	CacheProjection.removeAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheProjectionImpl.removeAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheAdapter.removeAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheProxyImpl.removeAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	CacheProjection.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate... filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	GridCacheAdapter.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate... filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	GridCacheProxyImpl.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate[] filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	GridCacheProjectionImpl.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate[] filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<V>	CacheProjection.removeAsync(K key, CacheEntryPredicate... filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<V>	GridCacheAdapter.removeAsync(K key, CacheEntryPredicate... filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<V>	GridCacheProxyImpl.removeAsync(K key, CacheEntryPredicate[] filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<V>	GridCacheProjectionImpl.removeAsync(K key, CacheEntryPredicate[] filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<V>	GridCacheProxyImpl.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<V>	GridCacheProjectionEx.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<V>	GridCacheProjectionImpl.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<V>	GridCacheAdapter.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	CacheProjection.removex(K key, CacheEntryPredicate... filter) Removes given key mapping from cache.
boolean	GridCacheAdapter.removex(K key, CacheEntryPredicate... filter) Removes given key mapping from cache.
boolean	GridCacheProxyImpl.removex(K key, CacheEntryPredicate[] filter) Removes given key mapping from cache.
boolean	GridCacheProjectionImpl.removex(K key, CacheEntryPredicate[] filter) Removes given key mapping from cache.
boolean	GridCacheProxyImpl.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheProjectionEx.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheProjectionImpl.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridCacheAdapter.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	CacheProjection.removexAsync(K key, CacheEntryPredicate... filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<Boolean>	GridCacheAdapter.removexAsync(K key, CacheEntryPredicate... filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<Boolean>	GridCacheProxyImpl.removexAsync(K key, CacheEntryPredicate[] filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<Boolean>	GridCacheProjectionImpl.removexAsync(K key, CacheEntryPredicate[] filter) Asynchronously removes given key mapping from cache.
IgniteInternalFuture<Boolean>	GridCacheProxyImpl.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridCacheProjectionEx.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridCacheProjectionImpl.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridCacheAdapter.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
abstract IgniteInternalFuture<Boolean>	GridCacheAdapter.txLockAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isRead, boolean retval, TransactionIsolation isolation, boolean invalidate, long accessTtl, CacheEntryPredicate[] filter)
void	CacheProjection.unlock(K key, CacheEntryPredicate... filter) Unlocks given key only if current thread owns the lock.
void	GridCacheAdapter.unlock(K key, CacheEntryPredicate... filter) Unlocks given key only if current thread owns the lock.
void	GridCacheProxyImpl.unlock(K key, CacheEntryPredicate[] filter) Unlocks given key only if current thread owns the lock.
void	GridCacheProjectionImpl.unlock(K key, CacheEntryPredicate[] filter) Unlocks given key only if current thread owns the lock.
void	CacheProjection.unlockAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Unlocks given keys only if current thread owns the locks.
void	GridCacheProxyImpl.unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.
void	GridCacheProjectionImpl.unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.
Collection<V>	GridCacheAdapter.values(CacheEntryPredicate... filter) Collection of values cached on this node.
<K,V> Collection<V>	GridCacheConcurrentMap.values(CacheEntryPredicate... filter) Collection of non-null values.
boolean	GridCacheMapEntry.visitable(CacheEntryPredicate[] filter)

Constructors in org.apache.ignite.internal.processors.cache with parameters of type CacheEntryPredicate

Constructor and Description
CacheEntrySerializablePredicate(CacheEntryPredicate p)
GridCacheProjectionImpl(CacheProjection<K,V> parent, GridCacheContext<K,V> cctx, CacheEntryPredicate entryFilter, Set<CacheFlag> flags, UUID subjId, boolean keepPortable, javax.cache.expiry.ExpiryPolicy expiryPlc)

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.distributed

Methods in org.apache.ignite.internal.processors.cache.distributed with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys, long timeout, CacheEntryPredicate... filter) All or nothing synchronous lock for passed in keys.
protected abstract IgniteInternalFuture<Boolean>	GridDistributedCacheAdapter.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter)
<K,V> GridTuple<CacheObject>	GridDistributedTxRemoteAdapter.peek(GridCacheContext cacheCtx, boolean failFast, KeyCacheObject key, CacheEntryPredicate[] filter)
IgniteInternalFuture<Boolean>	GridDistributedCacheAdapter.txLockAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isRead, boolean retval, TransactionIsolation isolation, boolean isInvalidate, long accessTtl, CacheEntryPredicate[] filter)

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.distributed.dht

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter)
IgniteInternalFuture<GridNearLockResponse>	GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<K,V> cacheCtx, ClusterNode nearNode, GridNearLockRequest req, CacheEntryPredicate[] filter0)
GridDhtFuture<Boolean>	GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter) Acquires locks in partitioned cache.
void	GridDhtCacheAdapter.unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type CacheEntryPredicate

Constructor and Description
GridDhtLockFuture(GridCacheContext<K,V> cctx, UUID nearNodeId, GridCacheVersion nearLockVer, AffinityTopologyVersion topVer, int cnt, boolean read, boolean needReturnValue, long timeout, GridDhtTxLocalAdapter tx, long threadId, long accessTtl, CacheEntryPredicate[] filter)

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that return CacheEntryPredicate

Modifier and Type	Method and Description
CacheEntryPredicate[]	GridNearAtomicUpdateRequest.filter()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
IgniteInternalFuture<?>	GridDhtAtomicCache.localRemoveAll(CacheEntryPredicate filter)
protected IgniteInternalFuture<Boolean>	GridDhtAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter)
V	GridDhtAtomicCache.put(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate[] filter) Internal method that is called from CacheEntryImpl.
void	GridDhtAtomicCache.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Stores given key-value pairs in cache.
IgniteInternalFuture<?>	GridDhtAtomicCache.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<V>	GridDhtAtomicCache.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridDhtAtomicCache.putx(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
boolean	GridDhtAtomicCache.putx(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridDhtAtomicCache.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridDhtAtomicCache.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
void	GridDhtAtomicCache.removeAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	GridDhtAtomicCache.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate[] filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<V>	GridDhtAtomicCache.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridDhtAtomicCache.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridDhtAtomicCache.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.atomic with parameters of type CacheEntryPredicate

Constructor and Description
GridNearAtomicUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, Collection<?> keys, Collection<?> vals, Object[] invokeArgs, Collection<GridCacheDrInfo> conflictPutVals, Collection<GridCacheVersion> conflictRmvVals, boolean retval, boolean rawRetval, javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, UUID subjId, int taskNameHash)
GridNearAtomicUpdateRequest(int cacheId, UUID nodeId, GridCacheVersion futVer, boolean fastMap, GridCacheVersion updateVer, AffinityTopologyVersion topVer, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, boolean retval, boolean forceTransformBackups, javax.cache.expiry.ExpiryPolicy expiryPlc, Object[] invokeArgs, CacheEntryPredicate[] filter, UUID subjId, int taskNameHash) Constructor.

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.distributed.dht.colocated

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	GridDhtColocatedCache.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter) This is an entry point to pessimistic locking within transaction.
void	GridDhtColocatedCache.unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht.colocated with parameters of type CacheEntryPredicate

Constructor and Description
GridDhtColocatedLockFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, GridNearTxLocal tx, boolean read, boolean retval, long timeout, long accessTtl, CacheEntryPredicate[] filter)

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return CacheEntryPredicate

Modifier and Type	Method and Description
CacheEntryPredicate[]	GridNearLockRequest.filter()

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
void	GridNearCacheAdapter.clearLocally0(Collection<? extends K> keys, CacheEntryPredicate[] filter)
boolean	GridNearCacheAdapter.clearLocally0(K key, CacheEntryPredicate[] filter)
Set<javax.cache.Cache.Entry<K,V>>	GridNearCacheAdapter.entrySet(CacheEntryPredicate... filter)
boolean	GridNearCacheAdapter.evict(K key, CacheEntryPredicate[] filter)
void	GridNearCacheAdapter.evictAll(Collection<? extends K> keys, CacheEntryPredicate[] filter)
boolean	GridNearCacheAdapter.evictNearOnly(K key, CacheEntryPredicate[] filter)
void	GridNearLockRequest.filter(CacheEntryPredicate[] filter, GridCacheContext ctx)
Set<K>	GridNearCacheAdapter.keySet(CacheEntryPredicate[] filter) Set of keys cached on this node.
IgniteInternalFuture<?>	GridNearAtomicCache.localRemoveAll(CacheEntryPredicate filter)
protected IgniteInternalFuture<Boolean>	GridNearTransactionalCache.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter)
protected IgniteInternalFuture<Boolean>	GridNearAtomicCache.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long accessTtl, CacheEntryPredicate[] filter)
Set<K>	GridNearCacheAdapter.nearKeySet(CacheEntryPredicate filter)
V	GridNearCacheAdapter.peek(K key, CacheEntryPredicate filter)
Set<javax.cache.Cache.Entry<K,V>>	GridNearCacheAdapter.primaryEntrySet(CacheEntryPredicate... filter)
Set<K>	GridNearCacheAdapter.primaryKeySet(CacheEntryPredicate... filter)
Collection<V>	GridNearCacheAdapter.primaryValues(CacheEntryPredicate... filter)
V	GridNearAtomicCache.put(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate[] filter) Internal method that is called from CacheEntryImpl.
void	GridNearAtomicCache.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Stores given key-value pairs in cache.
IgniteInternalFuture<?>	GridNearAtomicCache.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<V>	GridNearAtomicCache.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridNearAtomicCache.putx(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
boolean	GridNearAtomicCache.putx(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridNearAtomicCache.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridNearAtomicCache.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
void	GridNearAtomicCache.removeAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	GridNearAtomicCache.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate[] filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<V>	GridNearAtomicCache.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridNearAtomicCache.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridNearAtomicCache.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
void	GridNearAtomicCache.unlockAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Unlocks given keys only if current thread owns the locks.
void	GridNearTransactionalCache.unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.
Collection<V>	GridNearCacheAdapter.values(CacheEntryPredicate... filter) Collection of values cached on this node.

Constructors in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type CacheEntryPredicate

Constructor and Description
GridNearLockFuture(GridCacheContext<K,V> cctx, Collection<KeyCacheObject> keys, GridNearTxLocal tx, boolean read, boolean retval, long timeout, long accessTtl, CacheEntryPredicate[] filter)

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.local

Methods in org.apache.ignite.internal.processors.cache.local with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	GridLocalCache.lockAllAsync(Collection<? extends K> keys, long timeout, CacheEntryPredicate[] filter) All or nothing synchronous lock for passed in keys.
IgniteInternalFuture<Boolean>	GridLocalCache.lockAllAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, CacheEntryPredicate[] filter)
IgniteInternalFuture<Boolean>	GridLocalCache.txLockAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isRead, boolean retval, TransactionIsolation isolation, boolean invalidate, long accessTtl, CacheEntryPredicate[] filter)
void	GridLocalCache.unlockAll(Collection<? extends K> keys, CacheEntryPredicate[] filter) Unlocks given keys only if current thread owns the locks.

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.local.atomic

Methods in org.apache.ignite.internal.processors.cache.local.atomic with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	GridLocalAtomicCache.lockAllAsync(Collection<? extends K> keys, long timeout, CacheEntryPredicate... filter) All or nothing synchronous lock for passed in keys.
V	GridLocalAtomicCache.put(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate[] filter) Internal method that is called from CacheEntryImpl.
void	GridLocalAtomicCache.putAll(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Stores given key-value pairs in cache.
IgniteInternalFuture<?>	GridLocalAtomicCache.putAllAsync(Map<? extends K,? extends V> m, CacheEntryPredicate[] filter) Asynchronously stores given key-value pairs in cache.
IgniteInternalFuture<V>	GridLocalAtomicCache.putAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridLocalAtomicCache.putx(K key, V val, CacheEntryPredicate[] filter) Stores given key-value pair in cache.
boolean	GridLocalAtomicCache.putx(K key, V val, GridCacheEntryEx cached, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridLocalAtomicCache.putxAsync(K key, V val, GridCacheEntryEx entry, long ttl, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
V	GridLocalAtomicCache.remove(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
void	GridLocalAtomicCache.removeAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<?>	GridLocalAtomicCache.removeAllAsync(Collection<? extends K> keys, CacheEntryPredicate[] filter) Asynchronously removes given key mappings from cache for entries for which the optionally passed in filters do pass.
IgniteInternalFuture<V>	GridLocalAtomicCache.removeAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
boolean	GridLocalAtomicCache.removex(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridLocalAtomicCache.removexAsync(K key, GridCacheEntryEx entry, CacheEntryPredicate... filter) Internal method that is called from CacheEntryImpl.
IgniteInternalFuture<Boolean>	GridLocalAtomicCache.txLockAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isRead, boolean retval, TransactionIsolation isolation, boolean invalidate, long accessTtl, CacheEntryPredicate[] filter)
void	GridLocalAtomicCache.unlockAll(Collection<? extends K> keys, CacheEntryPredicate... filter) Unlocks given keys only if current thread owns the locks.

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.transactions

Methods in org.apache.ignite.internal.processors.cache.transactions that return CacheEntryPredicate

Modifier and Type	Method and Description
CacheEntryPredicate[]	IgniteTxEntry.filters()

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
protected IgniteTxEntry	IgniteTxLocalAdapter.addEntry(GridCacheOperation op, CacheObject val, javax.cache.processor.EntryProcessor entryProcessor, Object[] invokeArgs, GridCacheEntryEx entry, javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, boolean filtersSet, long drTtl, long drExpireTime, GridCacheVersion drVer)
protected <K,V> IgniteInternalFuture<Set<KeyCacheObject>>	IgniteTxLocalAdapter.enlistWrite(GridCacheContext cacheCtx, Collection<?> keys, GridCacheEntryEx cached, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean implicit, Map<?,?> lookup, Map<?,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap, Object[] invokeArgs, boolean retval, boolean lockOnly, CacheEntryPredicate[] filter, GridCacheReturn ret, Collection<KeyCacheObject> enlisted, Map<KeyCacheObject,GridCacheDrInfo> drPutMap, Map<KeyCacheObject,GridCacheVersion> drRmvMap) Internal routine for putAll(..)
void	IgniteTxEntry.filters(CacheEntryPredicate[] filters)
<K,V> GridTuple<CacheObject>	IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx, boolean failFast, KeyCacheObject key, CacheEntryPredicate[] filter)
<K,V> GridTuple<CacheObject>	IgniteInternalTx.peek(GridCacheContext ctx, boolean failFast, KeyCacheObject key, CacheEntryPredicate[] filter)
protected Set<KeyCacheObject>	IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx, Iterable<KeyCacheObject> keys, Set<KeyCacheObject> failed, GridCacheReturn ret, boolean rmv, boolean retval, boolean read, long accessTtl, CacheEntryPredicate[] filter, boolean computeInvoke) Post lock processing for put or remove.
<K,V> IgniteInternalFuture<GridCacheReturn>	IgniteTxLocalAdapter.putAllAsync(GridCacheContext cacheCtx, Map<? extends K,? extends V> map, boolean retval, GridCacheEntryEx cached, long ttl, CacheEntryPredicate[] filter)
<K,V> IgniteInternalFuture<GridCacheReturn>	IgniteTxLocalEx.putAllAsync(GridCacheContext cacheCtx, Map<? extends K,? extends V> map, boolean retval, GridCacheEntryEx cached, long ttl, CacheEntryPredicate[] filter)
<K,V> IgniteInternalFuture<GridCacheReturn>	IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx, Collection<? extends K> keys, GridCacheEntryEx cached, boolean retval, CacheEntryPredicate[] filter)
<K,V> IgniteInternalFuture<GridCacheReturn>	IgniteTxLocalEx.removeAllAsync(GridCacheContext cacheCtx, Collection<? extends K> keys, GridCacheEntryEx cached, boolean retval, CacheEntryPredicate[] filter)

Constructors in org.apache.ignite.internal.processors.cache.transactions with parameters of type CacheEntryPredicate

Constructor and Description
IgniteTxEntry(GridCacheContext<?,?> ctx, IgniteInternalTx tx, GridCacheOperation op, CacheObject val, javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor, Object[] invokeArgs, long ttl, GridCacheEntryEx entry, CacheEntryPredicate[] filters, GridCacheVersion conflictVer) This constructor is meant for local transactions.

Uses of CacheEntryPredicate in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util that return CacheEntryPredicate

Modifier and Type	Method and Description
static CacheEntryPredicate	F0.and0(CacheEntryPredicate[] p1, CacheEntryPredicate... p2)
static CacheEntryPredicate	F0.and0(CacheEntryPredicate p, CacheEntryPredicate... ps)

Methods in org.apache.ignite.internal.util with parameters of type CacheEntryPredicate

Modifier and Type	Method and Description
static CacheEntryPredicate	F0.and0(CacheEntryPredicate[] p1, CacheEntryPredicate... p2)
static CacheEntryPredicate	F0.and0(CacheEntryPredicate[] p1, CacheEntryPredicate... p2)
static CacheEntryPredicate	F0.and0(CacheEntryPredicate p, CacheEntryPredicate... ps)
static CacheEntryPredicate	F0.and0(CacheEntryPredicate p, CacheEntryPredicate... ps)