| Modifier and Type | Class and Description |
|---|---|
class |
CacheEntryPredicateAdapter |
class |
CacheEntryPredicateContainsValue |
class |
CacheEntryPredicateHasValue |
class |
CacheEntryPredicateNoValue |
class |
CacheEntrySerializablePredicate |
| Modifier and Type | Field and Description |
|---|---|
static CacheEntryPredicate[] |
GridCacheConcurrentMap.NON_INTERNAL_ARR
Non-internal predicate array.
|
| 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 |
CacheEntrySerializablePredicate.predicate() |
static <K,V> CacheEntryPredicate[] |
GridCacheUtils.readEntryFilterArray(ObjectInput in)
Reads array from input stream.
|
static CacheEntryPredicate |
GridCacheUtils.typeFilter0(Class<?> keyType,
Class<?> valType) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> Collection<V> |
GridCacheConcurrentMap.allValues(CacheEntryPredicate[] filter)
Collection of all (possibly
null) values. |
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers,
CacheEntryPredicate[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheEntryEx.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>> |
IgniteInternalCache.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 |
GridCacheMapEntry.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter) |
boolean |
GridCacheEntryEx.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter) |
V |
GridCacheAdapter.getAndPut(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
GridCacheAdapter.getAndPutAsync(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
GridCacheAdapter.getAndPutAsync0(K key,
V val,
CacheEntryPredicate... filter) |
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.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.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 |
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) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
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) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
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) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
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>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
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 |
GridCacheMapEntry.invalidate(CacheEntryPredicate[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheEntryEx.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> |
GridCacheAdapter.keySet(CacheEntryPredicate... filter) |
<K,V> Set<K> |
GridCacheConcurrentMap.keySet(CacheEntryPredicate... filter)
Key set.
|
Set<K> |
GridCacheAdapter.keySetx(CacheEntryPredicate... filter) |
<K,V> Set<K> |
GridCacheConcurrentMap.keySetx(CacheEntryPredicate... filter)
Key set including internal keys.
|
IgniteInternalFuture<?> |
GridCacheAdapter.localRemoveAll(CacheEntryPredicate filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.primaryEntrySet(CacheEntryPredicate... filter) |
Set<K> |
GridCacheAdapter.primaryKeySet(CacheEntryPredicate... filter) |
boolean |
GridCacheAdapter.put(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putAsync(K key,
V val,
CacheEntryPredicate... filter) |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putAsync0(K key,
V val,
CacheEntryPredicate... filter) |
boolean |
GridCacheContext.putIfAbsentFilter(CacheEntryPredicate[] p) |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removeAsync(K key,
CacheEntryPredicate... filter) |
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) |
| Constructor and Description |
|---|
CacheEntrySerializablePredicate(CacheEntryPredicate p) |
| Modifier and Type | Method and Description |
|---|---|
GridTuple<CacheObject> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext cacheCtx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<GridNearLockResponse> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<?,?> 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,
boolean skipStore)
Acquires locks in partitioned cache.
|
| Constructor and Description |
|---|
GridDhtLockFuture(GridCacheContext<?,?> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
AffinityTopologyVersion topVer,
int cnt,
boolean read,
boolean needReturnVal,
long timeout,
GridDhtTxLocalAdapter tx,
long threadId,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore) |
| Modifier and Type | Method and Description |
|---|---|
CacheEntryPredicate[] |
GridNearAtomicUpdateRequest.filter() |
| Modifier and Type | Method and Description |
|---|---|
V |
GridDhtAtomicCache.getAndPut(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
GridDhtAtomicCache.getAndPutAsync0(K key,
V val,
CacheEntryPredicate... filter) |
IgniteInternalFuture<?> |
GridDhtAtomicCache.localRemoveAll(CacheEntryPredicate filter) |
boolean |
GridDhtAtomicCache.put(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.putAsync0(K key,
V val,
CacheEntryPredicate... filter) |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.removeAsync(K key,
CacheEntryPredicate... filter) |
| 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,
boolean skipStore) |
GridNearAtomicUpdateRequest(int cacheId,
UUID nodeId,
GridCacheVersion futVer,
boolean fastMap,
GridCacheVersion updateVer,
AffinityTopologyVersion topVer,
boolean topLocked,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
Object[] invokeArgs,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean clientReq)
Constructor.
|
| Constructor and Description |
|---|
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore) |
| Modifier and Type | Method and Description |
|---|---|
CacheEntryPredicate[] |
GridNearLockRequest.filter() |
| 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) |
void |
GridNearLockRequest.filter(CacheEntryPredicate[] filter,
GridCacheContext ctx) |
V |
GridNearAtomicCache.getAndPut(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
GridNearAtomicCache.getAndPutAsync0(K key,
V val,
CacheEntryPredicate... filter) |
Set<K> |
GridNearCacheAdapter.keySet(CacheEntryPredicate[] filter) |
IgniteInternalFuture<?> |
GridNearAtomicCache.localRemoveAll(CacheEntryPredicate filter) |
Set<K> |
GridNearCacheAdapter.nearKeySet(CacheEntryPredicate filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridNearCacheAdapter.primaryEntrySet(CacheEntryPredicate... filter) |
Set<K> |
GridNearCacheAdapter.primaryKeySet(CacheEntryPredicate... filter) |
boolean |
GridNearAtomicCache.put(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.putAsync0(K key,
V val,
CacheEntryPredicate... filter) |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.removeAsync(K key,
CacheEntryPredicate... filter) |
Collection<V> |
GridNearCacheAdapter.values(CacheEntryPredicate... filter)
Collection of values cached on this node.
|
| Constructor and Description |
|---|
GridNearLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
CacheEntryPredicate[] filter) |
| Modifier and Type | Method and Description |
|---|---|
V |
GridLocalAtomicCache.getAndPut(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
GridLocalAtomicCache.getAndPutAsync0(K key,
V val,
CacheEntryPredicate... filter) |
boolean |
GridLocalAtomicCache.put(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.putAsync0(K key,
V val,
CacheEntryPredicate... filter) |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.removeAsync(K key,
CacheEntryPredicate... filter) |
| Modifier and Type | Method and Description |
|---|---|
CacheEntryPredicate[] |
IgniteTxEntry.filters() |
| 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,
boolean skipStore) |
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,
boolean skipStore)
Internal routine for putAll(..)
|
void |
IgniteTxEntry.filters(CacheEntryPredicate[] filters) |
GridTuple<CacheObject> |
IgniteInternalTx.peek(GridCacheContext ctx,
boolean failFast,
KeyCacheObject key,
CacheEntryPredicate[] filter) |
GridTuple<CacheObject> |
IgniteTxLocalAdapter.peek(GridCacheContext cacheCtx,
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> |
IgniteTxLocalEx.putAllAsync(GridCacheContext cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx cached,
long ttl,
CacheEntryPredicate[] filter) |
<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.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx cached,
boolean retval,
CacheEntryPredicate[] filter) |
| 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)
This constructor is meant for local transactions.
|
| Modifier and Type | Method and Description |
|---|---|
static CacheEntryPredicate |
F0.and0(CacheEntryPredicate[] p1,
CacheEntryPredicate... p2) |
static CacheEntryPredicate |
F0.and0(CacheEntryPredicate p,
CacheEntryPredicate... ps) |
| 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) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.2.0-incubating Release Date : June 16 2015