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.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.persistence	This package contain cache with persistence implementation.
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cache.tree.mvcc.data

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

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

Modifier and Type	Method and 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 and 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(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	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	CacheEvictionManager.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)
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, @Nullable CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, @Nullable CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, @Nullable GridCacheVersion explicitVer, @Nullable UUID subjId, String taskName, @Nullable GridCacheVersion dhtVer, @Nullable Long updateCntr)
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, AffinityTopologyVersion topVer, @Nullable CacheEntryPredicate[] filter, GridDrType drType, long conflictTtl, long conflictExpireTime, @Nullable GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, @Nullable UUID subjId, 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, AffinityTopologyVersion topVer, @Nullable CacheEntryPredicate[] filter, GridDrType drType, long explicitTtl, long explicitExpireTime, @Nullable GridCacheVersion conflictVer, boolean conflictResolve, boolean intercept, @Nullable UUID subjId, String taskName, @Nullable CacheObject prevVal, @Nullable Long updateCntr, @Nullable GridDhtAtomicAbstractUpdateFuture fut, boolean transformOp)
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>>	GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, @Nullable Object writeObj, @Nullable Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, boolean evt, boolean metrics, @Nullable CacheEntryPredicate[] filter, boolean intercept, @Nullable UUID subjId, String taskName, boolean transformOp) Update method for local cache in atomic mode.
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>>	GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, @Nullable Object writeObj, @Nullable Object[] invokeArgs, boolean writeThrough, boolean readThrough, boolean retval, boolean keepBinary, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, boolean evt, boolean metrics, @Nullable CacheEntryPredicate[] filter, boolean intercept, @Nullable UUID subjId, String taskName, boolean transformOp) Update method for local cache in atomic mode.
boolean	GridCacheContext.isAll(GridCacheEntryEx e, CacheEntryPredicate[] p)
boolean	GridCacheContext.isAllLocked(GridCacheEntryEx e, CacheEntryPredicate[] p)
MvccUpdateResult	IgniteCacheOffheapManager.CacheDataStore.mvccRemove(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, boolean primary, boolean needHistory, boolean needOldVal, boolean retVal)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccRemove(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, boolean primary, boolean needHistory, boolean needOldVal, boolean retVal)
@Nullable MvccUpdateResult	IgniteCacheOffheapManager.mvccRemove(GridCacheMapEntry entry, MvccSnapshot mvccSnapshot, boolean primary, boolean needHist, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.mvccRemove(GridCacheMapEntry entry, MvccSnapshot mvccSnapshot, boolean primary, boolean needHistory, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccRemove(@Nullable IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, boolean needHist, boolean needOldValue, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccRemove(IgniteInternalTx tx, UUID affNodeId, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, boolean needHistory, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal)
GridCacheUpdateTxResult	GridCacheEntryEx.mvccSet(@Nullable IgniteInternalTx tx, UUID affNodeId, CacheObject val, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, long ttl0, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, GridCacheOperation op, boolean needHistory, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary)
GridCacheUpdateTxResult	GridCacheMapEntry.mvccSet(IgniteInternalTx tx, UUID affNodeId, CacheObject val, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, long ttl0, AffinityTopologyVersion topVer, MvccSnapshot mvccVer, GridCacheOperation op, boolean needHistory, boolean noCreate, boolean needOldVal, CacheEntryPredicate filter, boolean retVal, boolean keepBinary)
MvccUpdateResult	IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, boolean primary, boolean needHist, boolean noCreate, boolean needOldVal, boolean retVal, boolean keepBinary)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, @Nullable CacheEntryPredicate filter, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, boolean primary, boolean needHistory, boolean noCreate, boolean needOldVal, boolean retVal, boolean keepBinary)
MvccUpdateResult	IgniteCacheOffheapManager.mvccUpdate(GridCacheMapEntry entry, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, boolean primary, boolean needHist, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs)
MvccUpdateResult	IgniteCacheOffheapManagerImpl.mvccUpdate(GridCacheMapEntry entry, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccSnapshot, boolean primary, boolean needHistory, boolean noCreate, boolean needOldVal, @Nullable CacheEntryPredicate filter, boolean retVal, boolean keepBinary, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs)
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 and 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 and Description
Iterable<GridCacheMapEntry>	GridCachePartitionedConcurrentMap.entries(int cacheId, CacheEntryPredicate... filter)
Set<GridCacheMapEntry>	GridCachePartitionedConcurrentMap.entrySet(int cacheId, CacheEntryPredicate... filter)
IgniteInternalFuture<GridNearLockResponse>	GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> cacheCtx, ClusterNode nearNode, GridNearLockRequest req, @Nullable CacheEntryPredicate[] filter0)
GridDhtFuture<Boolean>	GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(@Nullable Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx txx, boolean isInvalidate, boolean isRead, boolean retval, TransactionIsolation isolation, long createTtl, long accessTtl, CacheEntryPredicate[] filter, boolean skipStore, boolean keepBinary) Acquires locks in partitioned cache.

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

Constructor and Description
GridDhtLockFuture(GridCacheContext<?,?> cctx, UUID nearNodeId, GridCacheVersion nearLockVer, @NotNull AffinityTopologyVersion topVer, int cnt, boolean read, boolean needReturnVal, long timeout, GridDhtTxLocalAdapter tx, long threadId, long createTtl, long accessTtl, CacheEntryPredicate[] filter, boolean skipStore, boolean keepBinary)
GridDhtTxAbstractEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, @Nullable CacheEntryPredicate filter, boolean keepBinary)
GridDhtTxEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, Collection<Object> rows, EnlistOperation op, @Nullable CacheEntryPredicate filter, boolean needRes, boolean keepBinary) Constructor.

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 and 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 and Description
@Nullable CacheEntryPredicate[]	GridNearAtomicFullUpdateRequest.filter()
@Nullable CacheEntryPredicate[]	GridNearAtomicAbstractSingleUpdateRequest.filter()
abstract @Nullable CacheEntryPredicate[]	GridNearAtomicAbstractUpdateRequest.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 and 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 and Description
GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, @Nullable Object[] invokeArgs, boolean retval, boolean rawRetval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, UUID subjId, 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, boolean rawRetval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, UUID subjId, 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, boolean rawRetval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, UUID subjId, int taskNameHash, boolean skipStore, boolean keepBinary, boolean recovery, int remapCnt)

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

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

Constructor and Description
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx, Collection<KeyCacheObject> keys, @Nullable GridNearTxLocal tx, boolean read, boolean retval, long timeout, long createTtl, long accessTtl, CacheEntryPredicate[] filter, boolean skipStore, boolean keepBinary, boolean recovery)

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()
CacheEntryPredicate	GridNearTxEnlistRequest.filter()

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

Modifier and Type	Method and Description
Set<javax.cache.Cache.Entry<K,V>>	GridNearCacheAdapter.entrySet(CacheEntryPredicate... filter)
void	GridNearLockRequest.filter(CacheEntryPredicate[] filter, GridCacheContext ctx)
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)

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

Constructor and Description
GridNearLockFuture(GridCacheContext<?,?> cctx, Collection<KeyCacheObject> keys, @Nullable GridNearTxLocal tx, boolean read, boolean retval, long timeout, long createTtl, long accessTtl, CacheEntryPredicate[] filter, boolean skipStore, boolean keepBinary, boolean recovery)
GridNearTxEnlistFuture(GridCacheContext<?,?> cctx, GridNearTxLocal tx, long timeout, UpdateSourceIterator<?> it, int batchSize, boolean sequential, @Nullable CacheEntryPredicate filter, boolean needRes, boolean keepBinary)

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<KeyCacheObject> keys, long timeout, @Nullable IgniteTxLocalEx tx, CacheEntryPredicate[] filter)

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
protected V	GridLocalAtomicCache.getAndPut0(K key, V val, @Nullable CacheEntryPredicate filter)
IgniteInternalFuture<V>	GridLocalAtomicCache.getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
protected boolean	GridLocalAtomicCache.put0(K key, V val, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridLocalAtomicCache.putAsync0(K key, V val, @Nullable CacheEntryPredicate filter)
boolean	GridLocalAtomicCache.remove0(K key, CacheEntryPredicate filter)
IgniteInternalFuture<Boolean>	GridLocalAtomicCache.removeAsync0(K key, @Nullable CacheEntryPredicate filter)

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

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

Modifier and Type	Method and Description
MvccUpdateResult	GridCacheOffheapManager.GridCacheDataStore.mvccRemove(GridCacheContext cctx, KeyCacheObject key, MvccSnapshot mvccVer, CacheEntryPredicate filter, boolean primary, boolean needHistory, boolean needOldVal, boolean retVal)
MvccUpdateResult	GridCacheOffheapManager.GridCacheDataStore.mvccUpdate(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, MvccSnapshot mvccVer, CacheEntryPredicate filter, javax.cache.processor.EntryProcessor entryProc, Object[] invokeArgs, boolean primary, boolean needHistory, boolean noCreate, boolean needOldVal, boolean retVal, boolean keepBinary)

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
IgniteTxEntry	IgniteTxLocalAdapter.addEntry(GridCacheOperation op, @Nullable CacheObject val, @Nullable javax.cache.processor.EntryProcessor entryProcessor, 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 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, boolean skipStore, boolean keepBinary, boolean addReader) This constructor is meant for local transactions.

Uses of CacheEntryPredicate in org.apache.ignite.internal.processors.cache.tree.mvcc.data

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

Constructor and Description
MvccUpdateDataRow(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, int part, long expireTime, MvccSnapshot mvccSnapshot, MvccVersion newVer, @Nullable CacheEntryPredicate filter, boolean primary, boolean lockOnly, boolean needHist, boolean fastUpdate, boolean needOldVal, boolean needPrevValue)