| Modifier and Type | Class and Description |
|---|---|
class |
CacheEntryPredicateAdapter |
class |
CacheEntryPredicateContainsValue |
class |
CacheEntryPredicateHasValue |
class |
CacheEntryPredicateNoValue |
class |
CacheEntrySerializablePredicate |
| 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) |
CacheEntryPredicate |
CacheOperationFilter.createPredicate(CacheObject val)
Creare predicate from operation filter.
|
static CacheEntryPredicate[] |
GridCacheUtils.empty0() |
CacheEntryPredicate |
GridCacheContext.equalsVal(V val) |
static CacheEntryPredicate[] |
GridCacheUtils.filterArray(CacheEntryPredicate filter)
Create filter array.
|
CacheEntryPredicate |
GridCacheContext.hasVal() |
CacheEntryPredicate |
GridCacheContext.noVal() |
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 |
|---|---|
Collection<GridCacheMapEntry> |
GridCacheConcurrentMapImpl.allEntries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridCacheConcurrentMap.allEntries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridNoStorageCacheMap.allEntries(CacheEntryPredicate... filter) |
Collection<GridCacheMapEntry> |
GridCacheConcurrentMapImpl.entries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridCacheConcurrentMap.entries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridNoStorageCacheMap.entries(CacheEntryPredicate... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.entrySet(CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridCacheConcurrentMapImpl.entrySet(CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridCacheConcurrentMap.entrySet(CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridNoStorageCacheMap.entrySet(CacheEntryPredicate... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.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>> |
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.
|
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) |
static CacheEntryPredicate[] |
GridCacheUtils.filterArray(CacheEntryPredicate filter)
Create filter array.
|
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 retval,
boolean evt,
boolean metrics,
boolean keepBinary,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
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,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicUpdateFuture fut) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
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,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicUpdateFuture fut) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
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,
boolean keepBinary,
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<KeyCacheObject> |
GridCacheConcurrentMapImpl.keySet(CacheEntryPredicate... filter) |
Set<KeyCacheObject> |
GridCacheConcurrentMap.keySet(CacheEntryPredicate... filter) |
Set<KeyCacheObject> |
GridNoStorageCacheMap.keySet(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) |
Iterable<V> |
GridCacheAdapter.values(CacheEntryPredicate... filter)
Collection of values cached on this node.
|
boolean |
GridCacheMapEntry.visitable(CacheEntryPredicate[] filter) |
| Constructor and Description |
|---|
CacheEntrySerializablePredicate(CacheEntryPredicate p) |
| Modifier and Type | Method and Description |
|---|---|
Iterable<GridCacheMapEntry> |
GridCachePartitionedConcurrentMap.allEntries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridDhtLocalPartition.allEntries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridCachePartitionedConcurrentMap.entries(CacheEntryPredicate... filter) |
Iterable<GridCacheMapEntry> |
GridDhtLocalPartition.entries(CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridCachePartitionedConcurrentMap.entrySet(CacheEntryPredicate... filter) |
Set<GridCacheMapEntry> |
GridDhtLocalPartition.entrySet(CacheEntryPredicate... filter) |
Set<KeyCacheObject> |
GridCachePartitionedConcurrentMap.keySet(CacheEntryPredicate... filter) |
Set<KeyCacheObject> |
GridDhtLocalPartition.keySet(CacheEntryPredicate... filter) |
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,
boolean keepBinary)
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,
boolean keepBinary) |
| Modifier and Type | Field and Description |
|---|---|
protected CacheEntryPredicate[] |
GridNearAtomicAbstractUpdateFuture.filter
Optional filter.
|
| 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) |
boolean |
GridDhtAtomicCache.isFastMap(CacheEntryPredicate[] filters,
GridCacheOperation op)
Whether this is fast-map operation.
|
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 |
|---|
GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Object[] invokeArgs,
boolean retval,
boolean rawRetval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
int remapCnt,
boolean waitTopFut)
Constructor.
|
GridNearAtomicSingleUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Object key,
Object val,
Object[] invokeArgs,
boolean retval,
boolean rawRetval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
int remapCnt,
boolean waitTopFut) |
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,
boolean keepBinary,
int remapCnt,
boolean waitTopFut) |
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 keepBinary,
boolean clientReq,
boolean addDepInfo,
int maxEntryCnt)
Constructor.
|
| Constructor and Description |
|---|
GridDhtColocatedLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
| Modifier and Type | Method and Description |
|---|---|
CacheEntryPredicate[] |
GridNearLockRequest.filter() |
| 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,
CacheEntryPredicate filter) |
IgniteInternalFuture<V> |
GridNearAtomicCache.getAndPutAsync0(K key,
V val,
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) |
| Constructor and Description |
|---|
GridNearLockFuture(GridCacheContext<?,?> cctx,
Collection<KeyCacheObject> keys,
GridNearTxLocal tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
| 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,
boolean keepBinary) |
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.
|
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.putAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.putAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
K key,
V val,
boolean retval,
CacheEntryPredicate filter) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<? extends K> keys,
boolean retval,
CacheEntryPredicate filter,
boolean singleRmv) |
<K,V> IgniteInternalFuture<GridCacheReturn> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext cacheCtx,
AffinityTopologyVersion entryTopVer,
Collection<? extends K> keys,
boolean retval,
CacheEntryPredicate filter,
boolean singleRmv) |
| 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)
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.6.0 Release Date : May 18 2016