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

Packages that use CacheEntryPredicate

Package	Description
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.atomic
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.transactions

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	Description
class	CacheEntryPredicateAdapter
class	CacheEntryPredicateContainsValue
class	CacheEntryPredicateHasValue
class	CacheEntryPredicateNoValue
class	CacheEntrySerializablePredicate

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

Modifier and Type	Method	Description
static CacheEntryPredicate[]	GridCacheUtils.alwaysFalse0Arr()
@Nullable CacheEntryPredicate	CacheOperationFilter.createPredicate(@Nullable CacheObject val)	Creare predicate from operation filter.
static CacheEntryPredicate[]	GridCacheUtils.empty0()
CacheEntryPredicate	GridCacheContext.equalsVal(V val)
static CacheEntryPredicate[]	GridCacheUtils.filterArray(@Nullable CacheEntryPredicate filter)	Create filter array.
CacheEntryPredicate	GridCacheContext.hasVal()
CacheEntryPredicate	GridCacheContext.noVal()
CacheEntryPredicate	CacheEntrySerializablePredicate.predicate()

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

Modifier and Type	Method	Description
Iterable<GridCacheMapEntry>	GridCacheConcurrentMap.entries(int cacheId, CacheEntryPredicate... filter)
Collection<GridCacheMapEntry>	GridCacheConcurrentMapImpl.entries(int cacheId, CacheEntryPredicate... filter)
Iterable<GridCacheMapEntry>	GridNoStorageCacheMap.entries(int cacheId, CacheEntryPredicate... filter)
Set<javax.cache.Cache.Entry<K,V>>	GridCacheAdapter.entrySet(@Nullable CacheEntryPredicate... filter)
Set<GridCacheMapEntry>	GridCacheConcurrentMap.entrySet(int cacheId, CacheEntryPredicate... filter)
Set<GridCacheMapEntry>	GridCacheConcurrentMapImpl.entrySet(int cacheId, CacheEntryPredicate... filter)
Set<GridCacheMapEntry>	GridNoStorageCacheMap.entrySet(int cacheId, CacheEntryPredicate... filter)
boolean	CacheEvictionManager.evict(@Nullable GridCacheEntryEx entry, @Nullable GridCacheVersion obsoleteVer, boolean explicit, @Nullable CacheEntryPredicate[] filter)
boolean	CacheOffheapEvictionManager.evict(@Nullable GridCacheEntryEx entry, @Nullable GridCacheVersion obsoleteVer, boolean explicit, @Nullable CacheEntryPredicate[] filter)
boolean	GridCacheEvictionManager.evict(@Nullable GridCacheEntryEx entry, @Nullable GridCacheVersion obsoleteVer, boolean explicit, @Nullable CacheEntryPredicate[] filter)
boolean	GridCacheEntryEx.evictInternal(GridCacheVersion obsoleteVer, @Nullable CacheEntryPredicate[] filter, boolean evictOffheap)
boolean	GridCacheMapEntry.evictInternal(GridCacheVersion obsoleteVer, @Nullable CacheEntryPredicate[] filter, boolean evictOffheap)
static CacheEntryPredicate[]	GridCacheUtils.filterArray(@Nullable CacheEntryPredicate filter)	Create filter array.
V	GridCacheAdapter.getAndPut(K key, V val, @Nullable CacheEntryPredicate filter)
protected V	GridCacheAdapter.getAndPut0(K key, V val, @Nullable CacheEntryPredicate filter)
protected IgniteInternalFuture<V>	GridCacheAdapter.getAndPutAsync(K key, V val, @Nullable CacheEntryPredicate filter)
IgniteInternalFuture<V>	GridCacheAdapter.getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
GridCacheUpdateAtomicResult	GridCacheEntryEx.innerUpdate(GridCacheVersion ver, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, @Nullable Object val, @Nullable Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean checkVer, boolean readRepairRecovery, AffinityTopologyVersion topVer, @Nullable CacheEntryPredicate[] filter, GridDrType drType, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, String taskName, @Nullable CacheObject prevVal, @Nullable Long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, boolean transformOp)
GridCacheUpdateAtomicResult	GridCacheMapEntry.innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, @Nullable Object writeObj, @Nullable Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, @Nullable IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean verCheck, boolean readRepairRecovery, AffinityTopologyVersion topVer, @Nullable CacheEntryPredicate[] filter, GridDrType drType, long explicitTtl, long explicitExpireTime, @Nullable GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, String taskName, @Nullable CacheObject prevVal, @Nullable Long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, boolean transformOp)
boolean	GridCacheContext.isAll(GridCacheEntryEx e, CacheEntryPredicate[] p)
boolean	GridCacheContext.isAllLocked(GridCacheEntryEx e, CacheEntryPredicate[] p)
boolean	GridCacheAdapter.put(K key, V val, CacheEntryPredicate filter)
protected boolean	GridCacheAdapter.put0(K key, V val, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridCacheAdapter.putAsync(K key, V val, @Nullable CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridCacheAdapter.putAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
boolean	GridCacheContext.putIfAbsentFilter(@Nullable CacheEntryPredicate[] p)
boolean	GridCacheAdapter.remove(K key, @Nullable CacheEntryPredicate filter)
protected boolean	GridCacheAdapter.remove0(K key, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridCacheAdapter.removeAsync(K key, @Nullable CacheEntryPredicate filter)
protected IgniteInternalFuture<Boolean>	GridCacheAdapter.removeAsync0(K key, @Nullable CacheEntryPredicate filter)
boolean	GridCacheMapEntry.visitable(CacheEntryPredicate[] filter)

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

Constructor	Description
CacheEntrySerializablePredicate(CacheEntryPredicate p)

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	Description
Iterable<GridCacheMapEntry>	GridCachePartitionedConcurrentMap.entries(int cacheId, CacheEntryPredicate... filter)
Set<GridCacheMapEntry>	GridCachePartitionedConcurrentMap.entrySet(int cacheId, CacheEntryPredicate... filter)

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

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

Modifier and Type	Field	Description
protected CacheEntryPredicate[]	GridNearAtomicAbstractUpdateFuture.filter	Optional filter.

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

Modifier and Type	Method	Description
@Nullable CacheEntryPredicate[]	GridNearAtomicAbstractSingleUpdateRequest.filter()
abstract @Nullable CacheEntryPredicate[]	GridNearAtomicAbstractUpdateRequest.filter()
@Nullable CacheEntryPredicate[]	GridNearAtomicFullUpdateRequest.filter()
@Nullable CacheEntryPredicate[]	GridNearAtomicSingleUpdateFilterRequest.filter()

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

Modifier and Type	Method	Description
protected V	GridDhtAtomicCache.getAndPut0(K key, V val, @Nullable CacheEntryPredicate filter)
IgniteInternalFuture<V>	GridDhtAtomicCache.getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
protected boolean	GridDhtAtomicCache.put0(K key, V val, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridDhtAtomicCache.putAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
protected boolean	GridDhtAtomicCache.remove0(K key, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridDhtAtomicCache.removeAsync0(K key, @Nullable CacheEntryPredicate filter)

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

Constructor	Description
GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, @Nullable Object[] invokeArgs, boolean retval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, int taskNameHash, boolean skipStore, boolean keepBinary, boolean recovery, int remapCnt)	Constructor.
GridNearAtomicSingleUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, Object key, @Nullable Object val, @Nullable Object[] invokeArgs, boolean retval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, int taskNameHash, boolean skipStore, boolean keepBinary, boolean recovery, int remapCnt)
GridNearAtomicUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, Collection<?> keys, @Nullable Collection<?> vals, @Nullable Object[] invokeArgs, @Nullable Collection<GridCacheDrInfo> conflictPutVals, @Nullable Collection<GridCacheVersion> conflictRmvVals, boolean retval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, int taskNameHash, boolean skipStore, boolean keepBinary, boolean recovery, int remapCnt)

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

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

Modifier and Type	Method	Description
Set<javax.cache.Cache.Entry<K,V>>	GridNearCacheAdapter.entrySet(@Nullable CacheEntryPredicate... filter)
V	GridNearAtomicCache.getAndPut(K key, V val, @Nullable CacheEntryPredicate filter)
IgniteInternalFuture<V>	GridNearAtomicCache.getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
boolean	GridNearAtomicCache.put(K key, V val, CacheEntryPredicate filter)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.putAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, K key, V val, boolean retval, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridNearAtomicCache.putAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
boolean	GridNearAtomicCache.remove(K key, @Nullable CacheEntryPredicate filter)
<K,V> IgniteInternalFuture<GridCacheReturn>	GridNearTxLocal.removeAllAsync(GridCacheContext cacheCtx, @Nullable AffinityTopologyVersion entryTopVer, Collection<? extends K> keys, boolean retval, CacheEntryPredicate filter, boolean singleRmv)
IgniteInternalFuture<Boolean>	GridNearAtomicCache.removeAsync(K key, @Nullable CacheEntryPredicate filter)

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	Description
CacheEntryPredicate[]	IgniteTxEntry.filters()

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

Modifier and Type	Method	Description
IgniteTxEntry	IgniteTxLocalAdapter.addEntry(GridCacheOperation op, @Nullable CacheObject val, @Nullable javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, GridCacheEntryEx entry, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, boolean filtersSet, long drTtl, long drExpireTime, @Nullable GridCacheVersion drVer, boolean skipStore, boolean keepBinary, boolean addReader)
void	IgniteTxEntry.filters(CacheEntryPredicate[] filters)
protected void	IgniteTxLocalAdapter.postLockWrite(GridCacheContext cacheCtx, Iterable<KeyCacheObject> keys, GridCacheReturn ret, boolean rmv, boolean retval, boolean read, long accessTtl, CacheEntryPredicate[] filter, boolean computeInvoke)	Post lock processing for put or remove.

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

Constructor	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, boolean skipStore, boolean keepBinary, boolean addReader)	This constructor is meant for local transactions.