| Modifier and Type | Method and Description |
|---|---|
GridPredicate<GridNode> |
GridProjection.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
| Modifier and Type | Method and Description |
|---|---|
GridProjection |
GridProjection.forPredicate(GridPredicate<GridNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheProjection.forAll(GridPredicate<GridCacheEntry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
boolean |
GridCacheProjection.lock(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheEntry.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheProjection.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheProjection.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheProjection.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheEntry.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
GridCacheProjection<K,V> |
GridCacheProjection.projection(GridPredicate<GridCacheEntry<K,V>> filter)
Gets cache projection based on given entry filter.
|
V |
GridCacheProjection.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
void |
GridCacheProjection.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pairs in cache.
|
GridFuture<?> |
GridCacheProjection.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridCacheProjection.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously stores given key-value pair in cache.
|
boolean |
GridCacheProjection.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheProjection.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
V |
GridCacheEntry.remove(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheProjection.remove(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mapping from cache.
|
void |
GridCacheProjection.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProjection.removeAll(GridPredicate<GridCacheEntry<K,V>>... filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridCacheProjection.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProjection.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridCacheEntry.removeAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheProjection.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
boolean |
GridCacheEntry.removex(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheProjection.removex(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheEntry.removexAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheProjection.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
V |
GridCacheEntry.set(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEntry.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEntry.setx(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEntry.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
void |
GridCacheEntry.unlock(GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheProjection.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjection.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEvents.localListen(GridPredicate<? extends GridEvent> lsnr,
int... types)
Adds an event listener for local events.
|
<T extends GridEvent> |
GridEvents.localQuery(GridPredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends GridEvent> |
GridEvents.remoteListen(GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEvents.remoteQuery(GridPredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this projection for events using passed in predicate filter for event
selection.
|
boolean |
GridEvents.stopLocalListen(GridPredicate<? extends GridEvent> lsnr,
int... types)
Removes local event listener.
|
<T extends GridEvent> |
GridEvents.waitForLocal(GridPredicate<T> filter,
int... types)
Gets event future that allows for asynchronous waiting for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
GridPredicate<GridNode> |
GridProjectionAdapter.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCache<?,?>> |
GridEx.cachesx(GridPredicate<? super GridCache<?,?>>... p)
Gets configured cache instance that satisfy all provided predicates including non-public caches.
|
Collection<GridCache<?,?>> |
GridKernal.cachesx(GridPredicate<? super GridCache<?,?>>[] p)
Gets configured cache instance that satisfy all provided predicates including non-public caches.
|
GridProjection |
GridProjectionAdapter.forPredicate(GridPredicate<GridNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
void |
GridEventsImpl.localListen(GridPredicate<? extends GridEvent> lsnr,
int[] types)
Adds an event listener for local events.
|
<T extends GridEvent> |
GridEventsImpl.localQuery(GridPredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends GridEvent> |
GridEventsImpl.remoteListen(GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEventsImpl.remoteQuery(GridPredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this projection for events using passed in predicate filter for event
selection.
|
boolean |
GridEventsImpl.stopLocalListen(GridPredicate<? extends GridEvent> lsnr,
int... types)
Removes local event listener.
|
<T extends GridEvent> |
GridEventsImpl.waitForLocal(GridPredicate<T> filter,
int... types)
Gets event future that allows for asynchronous waiting for the specified events.
|
| Constructor and Description |
|---|
GridProjectionAdapter(GridProjection parent,
GridKernalContext ctx,
UUID subjId,
GridPredicate<GridNode> p) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends GridComputeTask<?,?>>> |
GridDeploymentManager.findAllTasks(GridPredicate<? super Class<? extends GridComputeTask<?,?>>>... p) |
GridDeployment |
GridDeploymentManager.getGlobalDeployment(GridDeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
GridUuid clsLdrId,
Map<UUID,GridUuid> participants,
GridPredicate<GridNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridDiscoveryManager.nodes(Collection<UUID> ids,
GridPredicate<UUID>... p)
Gets collection of node for given node IDs and predicates.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEventStorageManager.addLocalEventListener(GridPredicate<? extends GridEvent> lsnr,
int[] types)
Adds local user event listener.
|
<T extends GridEvent> |
GridEventStorageManager.localEvents(GridPredicate<T> p) |
<T extends GridEvent> |
GridEventStorageManager.remoteEventsAsync(GridPredicate<T> p,
Collection<? extends GridNode> nodes,
long timeout) |
boolean |
GridEventStorageManager.removeLocalEventListener(GridPredicate<? extends GridEvent> lsnr,
int... types)
Removes user listener for specified events, if any.
|
<T extends GridEvent> |
GridEventStorageManager.waitForEvent(GridPredicate<T> p,
int... types) |
GridEvent |
GridEventStorageManager.waitForEvent(long timeout,
Runnable c,
GridPredicate<? super GridEvent> p,
int... types) |
| Modifier and Type | Field and Description |
|---|---|
static GridPredicate[] |
GridCacheConcurrentMap.NON_INTERNAL_ARR
Non-internal predicate array.
|
protected GridPredicate<GridCacheEntryInfo<K,V>> |
GridCachePreloaderAdapter.preloadPred
Preload predicate.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheUtils.alwaysFalse() |
static <K,V> GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheUtils.empty() |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.equalsPeekArray(V val) |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheTxEntry.filters() |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.hasGetArray() |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.hasPeekArray() |
static <K,V> GridPredicate<K> |
GridCacheUtils.keyHasMeta(GridCacheContext<K,V> ctx,
String meta) |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.noGetArray() |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.noPeekArray() |
static <K,V> GridPredicate<GridDhtLocalPartition<K,V>> |
GridCacheUtils.notEvicted() |
GridPredicate<GridCacheEntry<K,V>> |
GridCacheProjectionEx.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
GridPredicate<GridCacheEntry<K,V>> |
GridCacheProjectionImpl.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
GridPredicate<GridCacheEntry<K,V>> |
GridCacheAdapter.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
GridPredicate<GridCacheEntry<K,V>> |
GridCacheProxyImpl.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
GridPredicate<GridCacheEntryInfo<K,V>> |
GridCachePreloaderAdapter.preloadPredicate() |
GridPredicate<GridCacheEntryInfo<K,V>> |
GridCachePreloader.preloadPredicate() |
static <K,V> GridPredicate<GridCacheTxEntry<K,V>> |
GridCacheUtils.reads() |
static <K,V> GridPredicate<GridCacheTxEntry<K,V>> |
GridCacheUtils.transferRequired() |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.trueArray() |
GridPredicate<GridCacheEntry<K,V>> |
GridCacheContext.truex() |
protected <T> GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheMessage.unmarshalFilter(byte[][] byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.vararg(GridPredicate<GridCacheEntry<K,V>> p) |
static <K,V> GridPredicate<GridCacheTxEntry<K,V>> |
GridCacheUtils.writes() |
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheTxEntry<K,V> |
GridCacheTxLocalAdapter.addEntry(GridCacheOperation op,
V val,
GridClosure<V,V> transformClos,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
Collection<V> |
GridCacheConcurrentMap.allValues(GridPredicate<GridCacheEntry<K,V>>[] filter)
Collection of all (possibly
null) values. |
protected void |
GridCacheTxLocalAdapter.checkValid(GridPredicate<GridCacheEntry<K,V>>[] filter)
Checks transaction expiration.
|
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheEntryEx.clear(GridCacheVersion ver,
boolean readers,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheAdapter.clear0(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.clearAll0(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
boolean |
GridCacheMapEntry.compact(GridPredicate<GridCacheEntry<K,V>>[] filter)
Optimizes the size of this entry.
|
boolean |
GridCacheEntryEx.compact(GridPredicate<GridCacheEntry<K,V>>[] filter)
Optimizes the size of this entry.
|
boolean |
GridCacheAdapter.compact(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.compactAll(Iterable<K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
boolean |
GridCacheAdapter.containsAllKeys(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
boolean |
GridCacheAdapter.containsAllValues(Collection<? extends V> vals,
GridPredicate<GridCacheEntry<K,V>> filter) |
boolean |
GridCacheAdapter.containsAnyKeys(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
boolean |
GridCacheAdapter.containsAnyValues(Collection<? extends V> vals,
GridPredicate<GridCacheEntry<K,V>> filter) |
boolean |
GridCacheAdapter.containsKey(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
boolean |
GridCacheAdapter.containsValue(V val,
GridPredicate<GridCacheEntry<K,V>> filter) |
protected GridFuture<Set<K>> |
GridCacheTxLocalAdapter.enlistWrite(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
long ttl,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,? extends GridClosure<V,V>> transformMap,
boolean retval,
boolean lockOnly,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
Set<GridCacheEntry<K,V>> |
GridCacheConcurrentMap.entries(GridPredicate<GridCacheEntry<K,V>>... filter)
|
Set<GridCacheEntry<K,V>> |
GridCacheConcurrentMap.entriesx(GridPredicate<GridCacheEntry<K,V>>... filter)
Returns entry set containing internal entries.
|
Set<GridCacheEntry<K,V>> |
GridCacheAdapter.entrySet(Collection<? extends K> keys,
GridPredicate<K> keyFilter,
GridPredicate<GridCacheEntry<K,V>>... filter) |
Set<GridCacheEntry<K,V>> |
GridCacheAdapter.entrySet(Collection<? extends K> keys,
GridPredicate<K> keyFilter,
GridPredicate<GridCacheEntry<K,V>>... filter) |
Set<GridCacheEntry<K,V>> |
GridCacheAdapter.entrySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
Set<GridCacheEntry<K,V>> |
GridCacheProjectionEx.entrySetx(GridPredicate<GridCacheEntry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<GridCacheEntry<K,V>> |
GridCacheProjectionImpl.entrySetx(GridPredicate<GridCacheEntry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<GridCacheEntry<K,V>> |
GridCacheAdapter.entrySetx(GridPredicate<GridCacheEntry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<GridCacheEntry<K,V>> |
GridCacheProxyImpl.entrySetx(GridPredicate<GridCacheEntry<K,V>>... filter)
Gets entry set containing internal entries.
|
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry,
GridCacheVersion obsoleteVer,
boolean explicit,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheAdapter.evict(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.evictAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
boolean |
GridCacheMapEntry.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheEntryEx.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridCacheTxEntry.filters(GridPredicate<GridCacheEntry<K,V>>[] filters) |
boolean |
GridCacheProjectionImpl.forAll(GridPredicate<GridCacheEntry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
boolean |
GridCacheAdapter.forAll(GridPredicate<GridCacheEntry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
boolean |
GridCacheProxyImpl.forAll(GridPredicate<GridCacheEntry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
Map<K,V> |
GridCacheAdapter.getAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
protected GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean checkTx,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheTxLocalAdapter.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridCacheTxLocalEx.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<V> |
GridCacheAdapter.getAsync(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
V |
GridCacheMapEntry.innerGet(GridCacheTxEx<K,V> tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheEntryEx.innerGet(GridCacheTxEx<K,V> tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheEntryEx.innerReload(GridPredicate<GridCacheEntry<K,V>>... filter)
Reloads entry from underlying storage.
|
V |
GridCacheMapEntry.innerReload(GridPredicate<GridCacheEntry<K,V>>[] filter)
Reloads entry from underlying storage.
|
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerRemove(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerRemove(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerSet(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerSet(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId) |
GridBiTuple<Boolean,V> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean intercept,
UUID subjId)
Update method for local cache in atomic mode.
|
GridBiTuple<Boolean,V> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean intercept,
UUID subjId)
Update method for local cache in atomic mode.
|
boolean |
GridCacheMapEntry.invalidate(GridPredicate<GridCacheEntry<K,V>>[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheEntryEx.invalidate(GridPredicate<GridCacheEntry<K,V>>[] filter)
Invalidates this entry if it passes given filter.
|
<E> boolean |
GridCacheContext.isAll(E e,
GridPredicate<? super E>[] p)
Same as
GridFunc.isAll(Object, GridPredicate[]), but safely unwraps
exceptions. |
<K,V> boolean |
GridCacheContext.isAll(GridCacheEntryEx<K,V> e,
GridPredicate<GridCacheEntry<K,V>>[] p)
Same as
GridFunc.isAll(Object, GridPredicate[]), but safely unwraps
exceptions. |
Set<K> |
GridCacheConcurrentMap.keySet(GridPredicate<GridCacheEntry<K,V>>... filter)
Key set.
|
Set<K> |
GridCacheAdapter.keySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
boolean |
GridCacheProjectionImpl.lock(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... 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,
GridPredicate<GridCacheEntry<K,V>>... 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,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
GridCacheFilterEvaluationEntry.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheEvictionEntry.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheEntryImpl.lock(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Synchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
boolean |
GridCacheAdapter.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProjectionImpl.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProxyImpl.lockAll(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheProxyImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridCacheAdapter.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheProxyImpl.lockAsync(K key,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheEvictionEntry.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
GridFuture<Boolean> |
GridCacheEntryImpl.lockAsync(long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously acquires lock on a cached object associated with this entry
only if the passed in filter (if any) passes.
|
protected <T> byte[][] |
GridCacheMessage.marshalFilter(GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
GridTuple<V> |
GridCacheTxEx.peek(boolean failFast,
K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridTuple<V> |
GridCacheTxLocalAdapter.peek(boolean failFast,
K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheEntryEx.peek(Collection<GridCachePeekMode> modes,
GridPredicate<GridCacheEntry<K,V>>... filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheMapEntry.peek(Collection<GridCachePeekMode> modes,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheEntryEx.peek(GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>... filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheMapEntry.peek(GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheAdapter.peek(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
GridTuple<V> |
GridCacheMapEntry.peek0(boolean failFast,
GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheTxEx<K,V> tx) |
GridTuple<V> |
GridCacheEntryEx.peek0(boolean failFast,
GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheTxEx<K,V> tx) |
protected GridTuple<V> |
GridCacheAdapter.peek0(boolean failFast,
K key,
GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>... filter) |
Map<K,V> |
GridCacheAdapter.peekAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
protected Map<K,V> |
GridCacheAdapter.peekAll0(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter,
Collection<K> skipped) |
V |
GridCacheEntryEx.peekFailFast(GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>... filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheMapEntry.peekFailFast(GridCachePeekMode mode,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Peeks into entry without loading value or updating statistics.
|
protected Set<K> |
GridCacheTxLocalAdapter.postLockWrite(Iterable<? extends K> keys,
Set<K> failed,
Map<K,V> transformed,
Map<? extends K,? extends GridClosure<V,V>> transformMap,
GridCacheReturn<V> ret,
boolean rmv,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Post lock processing for put or remove.
|
void |
GridCachePreloaderAdapter.preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> preloadPred) |
void |
GridCachePreloader.preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> p) |
protected void |
GridCacheMessage.prepareFilter(GridPredicate<GridCacheEntry<K,V>>[] filters,
GridCacheContext<K,V> ctx) |
Set<GridCacheEntry<K,V>> |
GridCacheAdapter.primaryEntrySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
Set<K> |
GridCacheAdapter.primaryKeySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
Collection<V> |
GridCacheAdapter.primaryValues(GridPredicate<GridCacheEntry<K,V>>... filter) |
GridCacheProjection<K,V> |
GridCacheProjectionImpl.projection(GridPredicate<GridCacheEntry<K,V>> filter)
Gets cache projection based on given entry filter.
|
GridCacheProjection<K,V> |
GridCacheAdapter.projection(GridPredicate<GridCacheEntry<K,V>> filter)
Gets cache projection based on given entry filter.
|
GridCacheProjection<K,V> |
GridCacheProxyImpl.projection(GridPredicate<GridCacheEntry<K,V>> filter)
Gets cache projection based on given entry filter.
|
Set<GridCacheEntry<K,V>> |
GridCacheConcurrentMap.projections(GridPredicate<GridCacheEntry<K,V>>[] filter)
Entry wrapper set casted to projections.
|
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheTxLocalAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheTxLocalEx.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheAdapter.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
V |
GridCacheProjectionImpl.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
V |
GridCacheProxyImpl.put(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
void |
GridCacheProjectionImpl.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheAdapter.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
GridCacheReturn<V> |
GridCacheTxLocalAdapter.putAll(Map<? extends K,? extends V> map,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheReturn<V> |
GridCacheTxLocalEx.putAll(Map<? extends K,? extends V> map,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.putAllAsync(Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.putAllAsync(Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<?> |
GridCacheAdapter.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridCacheProjectionImpl.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<?> |
GridCacheProxyImpl.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheTxLocalAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheTxLocalEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
GridFuture<V> |
GridCacheTxLocalAdapter.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheTxLocalEx.putAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheTxLocalAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheAdapter.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheTxLocalAdapter.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheTxLocalEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridCacheTxLocalAdapter.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheTxLocalEx.putxAsync(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.putxAsync0(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.putxAsync0(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected V |
GridCacheMapEntry.readThrough(GridCacheTxEx<K,V> tx,
K key,
boolean reload,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridFuture<Object> |
GridCacheAdapter.readThroughAllAsync(Collection<? extends K> keys,
boolean reload,
GridCacheTxEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId,
GridBiInClosure<K,V> vis) |
V |
GridCacheAdapter.reload(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
Map<K,V> |
GridCacheAdapter.reloadAll(Collection<? extends K> keys,
boolean ret,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.reloadAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridCacheAdapter.reloadAll(GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheAdapter.reloadAllAsync(Collection<? extends K> keys,
boolean ret,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridCacheAdapter.reloadAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridCacheAdapter.reloadAllAsync(GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<V> |
GridCacheAdapter.reloadAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheFilterEvaluationEntry.remove(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheEvictionEntry.remove(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheEntryImpl.remove(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.remove(Object, GridPredicate[]) method. |
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheTxLocalAdapter.remove(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheTxLocalEx.remove(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheProjectionImpl.remove(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
V |
GridCacheAdapter.remove(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
V |
GridCacheProxyImpl.remove(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
void |
GridCacheProjectionImpl.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... 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,
GridPredicate<GridCacheEntry<K,V>>... 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,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridCacheReturn<V> |
GridCacheTxLocalAdapter.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheReturn<V> |
GridCacheTxLocalEx.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridCacheProjectionImpl.removeAll(GridPredicate<GridCacheEntry<K,V>>... filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheAdapter.removeAll(GridPredicate<GridCacheEntry<K,V>>... filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridCacheProxyImpl.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.removeAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean implicit,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.removeAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean implicit,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<?> |
GridCacheAdapter.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridCacheAdapter.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridCacheFilterEvaluationEntry.removeAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEvictionEntry.removeAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEntryImpl.removeAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removeAsync(Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheTxLocalAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<V> |
GridCacheTxLocalEx.removeAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
boolean |
GridCacheFilterEvaluationEntry.removex(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheEvictionEntry.removex(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheEntryImpl.removex(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removex(Object, GridPredicate[]) method. |
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheTxLocalAdapter.removex(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.removex(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheAdapter.removex(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProjectionImpl.removex(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProxyImpl.removex(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.removexAsync(GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEvictionEntry.removexAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.removexAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.removexAsync(Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<Boolean> |
GridCacheTxLocalEx.removexAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.removexAsync0(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.removexAsync0(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
boolean |
GridCacheIoManager.safeSend(Collection<? extends GridNode> nodes,
GridCacheMessage<K,V> msg,
GridPredicate<GridNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
V |
GridCacheFilterEvaluationEntry.set(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
V |
GridCacheEvictionEntry.set(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
V |
GridCacheEntryImpl.set(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.put(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheFilterEvaluationEntry.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEvictionEntry.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
GridFuture<V> |
GridCacheEntryImpl.setAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putAsync(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheFilterEvaluationEntry.setx(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEvictionEntry.setx(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
boolean |
GridCacheEntryImpl.setx(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putx(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheFilterEvaluationEntry.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>... filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEvictionEntry.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
GridFuture<Boolean> |
GridCacheEntryImpl.setxAsync(V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method has the same semantic as
GridCacheProjection.putxAsync(Object, Object, GridPredicate[]) method. |
abstract GridFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridCacheFilterEvaluationEntry.unlock(GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheEvictionEntry.unlock(GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheEntryImpl.unlock(GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks this entry only if current thread owns the lock.
|
void |
GridCacheAdapter.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjectionImpl.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProxyImpl.unlock(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjectionImpl.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheProxyImpl.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
Collection<V> |
GridCacheConcurrentMap.values(GridPredicate<GridCacheEntry<K,V>>... filter)
Collection of non-
null values. |
Collection<V> |
GridCacheAdapter.values(GridPredicate<GridCacheEntry<K,V>>... filter) |
GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheContext.vararg(GridPredicate<GridCacheEntry<K,V>> p) |
boolean |
GridCacheMapEntry.visitable(GridPredicate<GridCacheEntry<K,V>>[] filter) |
Set<GridCacheEntryImpl<K,V>> |
GridCacheConcurrentMap.wrappers(GridPredicate<GridCacheEntry<K,V>>[] filter)
Entry wrapper set.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridPartitionedCacheEntryImpl.evictDhtOnly(GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridPartitionedCacheEntryImpl.evictNearOnly(GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected abstract GridFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
GridTuple<V> |
GridDistributedTxRemoteAdapter.peek(boolean failFast,
K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridPartitionedCacheEntryImpl.peekDht(GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean isInvalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
GridDhtFuture<Collection<GridCacheEntryInfo<K,V>>> |
GridDhtCacheAdapter.getDhtAsync(UUID reader,
long msgId,
LinkedHashMap<? extends K,Boolean> keys,
boolean reload,
long topVer,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridNearLockResponse<K,V>> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridNode nearNode,
GridNearLockRequest<K,V> req,
GridPredicate<GridCacheEntry<K,V>>[] filter0) |
GridDhtFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Acquires locks in partitioned cache.
|
V |
GridDhtCacheAdapter.reload(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridDhtCacheAdapter.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Constructor and Description |
|---|
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
LinkedHashMap<? extends K,Boolean> keys,
boolean reload,
GridCacheTxLocalEx<K,V> tx,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filters,
UUID subjId) |
GridDhtLockFuture(GridCacheContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
long topVer,
int cnt,
boolean read,
long timeout,
GridDhtTxLocalAdapter<K,V> tx,
long threadId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
GridPredicate<GridCacheEntry<K,V>>[] filters,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
GridPredicate<GridCacheEntry<K,V>>[] |
GridNearAtomicUpdateRequest.filter() |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
protected GridFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridDhtAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridDhtAtomicCache.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
GridFuture<?> |
GridDhtAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridDhtAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridDhtAtomicCache.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridDhtAtomicCache.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridDhtAtomicCache.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridDhtAtomicCache.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
| Constructor and Description |
|---|
GridNearAtomicUpdateFuture(GridCacheContext<K,V> cctx,
GridDhtAtomicCache<K,V> cache,
GridCacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<? extends K> keys,
Collection<?> vals,
Collection<GridCacheDrInfo<V>> drPutVals,
Collection<GridCacheVersion> drRmvVals,
boolean retval,
boolean rawRetval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridNearAtomicUpdateRequest(UUID nodeId,
GridCacheVersion futVer,
boolean fastMap,
GridCacheVersion updateVer,
long topVer,
GridCacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
boolean retval,
boolean forceTransformBackups,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtColocatedCache.containsKey(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
GridFuture<Map<K,V>> |
GridDhtColocatedCache.loadAsync(Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
long topVer,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This is an entry point to pessimistic locking within transaction.
|
void |
GridDhtColocatedCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Constructor and Description |
|---|
GridDhtColocatedLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
GridDhtColocatedTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPreloader.preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> preloadPred) |
| Modifier and Type | Method and Description |
|---|---|
GridPredicate<GridCacheEntry<K,V>>[] |
GridNearGetRequest.filter() |
GridPredicate<GridCacheEntry<K,V>>[] |
GridNearLockRequest.filter() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearCacheAdapter.clear0(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridNearCacheAdapter.clearAll0(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridNearCacheAdapter.compact(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridNearCacheAdapter.containsKey(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
Set<GridCacheEntry<K,V>> |
GridNearCacheAdapter.entrySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
boolean |
GridNearCacheAdapter.evict(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridNearCacheAdapter.evictAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridNearCacheAdapter.evictNearOnly(K key,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridNearLockRequest.filter(GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
protected GridFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
Set<K> |
GridNearCacheAdapter.keySet(GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridNearCacheAdapter.loadAsync(GridCacheTxEx tx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
protected GridFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected GridFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
Set<K> |
GridNearCacheAdapter.nearKeySet(GridPredicate<GridCacheEntry<K,V>> filter) |
V |
GridNearCacheAdapter.peek(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
Map<K,V> |
GridNearCacheAdapter.peekAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
Set<GridCacheEntry<K,V>> |
GridNearCacheAdapter.primaryEntrySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
Set<K> |
GridNearCacheAdapter.primaryKeySet(GridPredicate<GridCacheEntry<K,V>>... filter) |
Collection<V> |
GridNearCacheAdapter.primaryValues(GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridNearAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
GridFuture<?> |
GridNearAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
protected V |
GridNearCacheEntry.readThrough(GridCacheTxEx<K,V> tx,
K key,
boolean reload,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridFuture<Object> |
GridNearCacheAdapter.readThroughAllAsync(Collection<? extends K> keys,
boolean reload,
GridCacheTxEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId,
GridBiInClosure<K,V> vis) |
V |
GridNearCacheAdapter.reload(K key,
GridPredicate<GridCacheEntry<K,V>>... filter) |
void |
GridNearCacheAdapter.reloadAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridNearCacheAdapter.reloadAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<?> |
GridNearCacheAdapter.reloadAllAsync(GridPredicate<GridCacheEntry<K,V>> filter) |
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridNearAtomicCache.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridNearAtomicCache.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridNearAtomicCache.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridNearTransactionalCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
Collection<V> |
GridNearCacheAdapter.values(GridPredicate<GridCacheEntry<K,V>>... filter) |
| Constructor and Description |
|---|
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
GridCacheTxLocalEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filters,
UUID subjId) |
GridNearGetRequest(GridUuid futId,
GridUuid miniId,
GridCacheVersion ver,
LinkedHashMap<K,Boolean> keys,
boolean reload,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridNearLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
org.gridgain.grid.kernal.processors.cache.distributed.near.GridNearTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
GridFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridLocalCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
V |
GridLocalAtomicCache.get(K key,
GridPredicate<GridCacheEntry<K,V>> filter) |
Map<K,V> |
GridLocalAtomicCache.getAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>> filter) |
GridFuture<Map<K,V>> |
GridLocalAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridLocalAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridPredicate<GridCacheEntry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
V |
GridLocalAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridLocalAtomicCache.putAll(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
GridFuture<?> |
GridLocalAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
GridFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Stores given key-value pair in cache.
|
GridFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridLocalAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridLocalAtomicCache.removeAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
GridLocalAtomicCache.removeAll(GridPredicate<GridCacheEntry<K,V>>[] filter)
Removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<?> |
GridLocalAtomicCache.removeAllAsync(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
GridFuture<?> |
GridLocalAtomicCache.removeAllAsync(GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
GridFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridLocalAtomicCache.unlockAll(Collection<? extends K> keys,
GridPredicate<GridCacheEntry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
GridPredicate<GridCacheEntry<Object,Object>> |
GridCacheQueryRequest.projectionFilter() |
GridPredicate<GridCacheEntry<Object,Object>> |
GridCacheQueryAdapter.projectionFilter() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheContinuousQuery<K,V> |
GridCacheContinuousQueryManager.createQuery(GridPredicate<GridCacheEntry<K,V>> prjPred) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
int bufSize,
long interval,
boolean autoUnsubscribe,
GridPredicate<GridNode> prjPred) |
| Modifier and Type | Method and Description |
|---|---|
<T extends GridEvent> |
GridEventStorageSpi.localEvents(GridPredicate<T> p)
Queries locally-stored events only.
|
| Modifier and Type | Method and Description |
|---|---|
GridPredicate<GridEvent> |
GridMemoryEventStorageSpi.getFilter()
Gets filter for events to be recorded.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends GridEvent> |
GridMemoryEventStorageSpi.localEvents(GridPredicate<T> p)
Queries locally-stored events only.
|
void |
GridMemoryEventStorageSpi.setFilter(GridPredicate<GridEvent> filter)
Sets filter for events to be recorded.
|
| Constructor and Description |
|---|
GridStreamerRandomEventRouter(GridPredicate<GridNode>... predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
| Constructor and Description |
|---|
GridStreamerRandomEventRouter(Collection<GridPredicate<GridNode>> predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
| Modifier and Type | Method and Description |
|---|---|
GridPredicate<Object> |
GridStreamerWindowAdapter.getFilter()
Gets optional event filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerWindowAdapter.setFilter(GridPredicate<Object> filter)
Sets event filter.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridPredicate<T> |
F0.and(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
F0.and(GridPredicate<? super T> p,
GridPredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
F0.contains(Collection<T> c)
Provides predicate (not peer-deployable) which returns
true if it receives an element
that is contained in the passed in collection. |
static <T> GridPredicate<T> |
F0.equalTo(T target)
Gets predicate (not perr-deployable) that evaluates to
true if its free variable is equal
to target or both are null. |
static <T> GridPredicate<T> |
F0.in(Collection<? extends T> c)
Gets predicate (not peer-deployable) that returns
true if its free variable is contained
in given collection. |
static <T> GridPredicate<T> |
F0.not(GridPredicate<? super T>... p)
Negates given predicates.
|
static <T> GridPredicate<T> |
F0.notContains(Collection<T> c)
Provides predicate (not peer-deployable) which returns
true if it receives an element
that is not contained in the passed in collection. |
static <T> GridPredicate<T> |
F0.notEqualTo(T target)
Gets predicate (not peer-deployable) that evaluates to
true if its free variable is not equal
to target or both are null. |
static <T> GridPredicate<T> |
F0.notIn(Collection<? extends T> c)
Gets predicate (not peer-deployable) that returns
true if its free variable
is not contained in given collection. |
static <K,V> GridPredicate<GridCacheEntry<K,V>>[] |
GridUtils.readEntryFilterArray(ObjectInput in)
Reads array from input stream.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridPredicate<T> |
F0.and(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
F0.and(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
F0.and(GridPredicate<? super T> p,
GridPredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
F0.and(GridPredicate<? super T> p,
GridPredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
boolean |
GridAtomicInteger.checkAndSet(GridPredicate<Integer> p,
int update)
Atomically updates value only if passed in predicate returns
true. |
boolean |
GridAtomicLong.checkAndSet(GridPredicate<Long> p,
long update)
Atomically updates value only if passed in predicate returns
true. |
static boolean |
F0.isAllNodePredicates(GridPredicate<?>... ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
N |
GridConsistentHash.node(Object key,
GridPredicate<N>... p)
Gets node for a given key.
|
List<N> |
GridConsistentHash.nodes(Object key,
int cnt,
GridPredicate<N>... p)
Gets specified count of adjacent nodes for a given key.
|
static <T> GridPredicate<T> |
F0.not(GridPredicate<? super T>... p)
Negates given predicates.
|
static List<Integer> |
GridUtils.toIntList(int[] arr,
GridPredicate<Integer>... p)
Converts array of integers into list.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
F0.isAllNodePredicates(Iterable<? extends GridPredicate<?>> ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
| Constructor and Description |
|---|
GridReflectionCache(GridPredicate<Field> fp,
GridPredicate<Method> mp)
Reflection cache with specified field and method predicates.
|
GridReflectionCache(GridPredicate<Field> fp,
GridPredicate<Method> mp)
Reflection cache with specified field and method predicates.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNodePredicate
Convenient node predicate as a separate class.
|
class |
GridPredicateX<E1>
Convenient predicate subclass that allows for thrown grid exception.
|
| Modifier and Type | Field and Description |
|---|---|
static GridPredicate |
GridFunc.EMPTY_COLLECTION |
static GridPredicate<String> |
GridFunc.EMPTY_STRING |
static GridPredicate<Object> |
GridFunc.IS_NOT_NULL |
static GridPredicate<Object> |
GridFunc.IS_NULL |
static GridPredicate |
GridFunc.NOT_EMPTY_COLLECTION |
static GridPredicate<String> |
GridFunc.NOT_EMPTY_STRING |
| Modifier and Type | Method and Description |
|---|---|
static <T> GridPredicate<T> |
GridFunc.alwaysFalse()
Gets predicate that always returns
false. |
static <T> GridPredicate<T> |
GridFunc.alwaysTrue()
Gets predicate that always returns
true. |
static <T> GridPredicate<T> |
GridFunc.and(Collection<? extends GridPredicate<? super T>> ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.and(GridPredicate<? super T>... ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.and(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.as(GridClosure<? super T,Boolean> c)
Converts given closure to predicate.
|
static <E1,E2> GridPredicate<GridBiTuple<E1,E2>> |
GridFunc.as0(GridBiPredicate<? super E1,? super E2> p)
Converts predicate with two separate values to a predicate with tuple.
|
static <T> GridPredicate<T> |
GridFunc.breaker(boolean firstVal)
Gets breaker predicate which will return a predicate that will
evaluate to
firstVal when checked the first time,
but then will always evaluate to the opposite value. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheBackup()
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsEntriesGet(Collection<? extends Map.Entry<K,V>> entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsEntriesGet(Map.Entry<K,V>... entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsEntriesPeek(Collection<? extends Map.Entry<K,V>> entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsEntriesPeek(Map.Entry<K,V>... entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsGet(Collection<? extends V> vals)
Gets predicate which returns true if
GridCacheEntry.get()
method returns value that is contained in given collection. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsGet(Map<K,V> map)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsGet(V... vals)
Gets predicate which returns true if
GridCacheEntry.get() method returns
value that is contained among given values. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsPeek(Collection<? extends V> vals)
Gets predicate which returns true if
GridCacheEntry.peek() methods returns
value that is contained in given collection. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsPeek(Map<K,V> map)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheContainsPeek(V... vals)
Gets predicate which returns true if
GridCacheEntry.peek() methods returns
value that is contained among given values. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheExpireAfter(long msec)
Gets predicate which returns
true if entry expires on or after given time
in milliseconds. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheExpireBefore(long msec)
Gets predicate which returns
true if entry expires on or before given time
in milliseconds. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheHasGetValue()
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheHasKeys(Collection<? extends K> keys)
Gets predicate which returns
true if entry's key is contained in given collection. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheHasKeys(K... keys)
Gets predicate which returns
true if entry's key is equal to any of provided keys. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheHasPeekValue()
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheKeys(GridPredicate<? super K>... ps)
Converts key filter to entry filter using
Map.Entry.getKey()
to get value. |
static GridPredicate<GridNode> |
GridFunc.cacheNodesForNames(String... cacheNames)
Gets node predicate which returns
true for all nodes which have given cache names
started. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheNoGetValue()
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheNoPeekValue()
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cachePrimary()
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheValuesGet(GridPredicate<? super V>... ps)
Converts value filter to entry filter using
GridCacheEntry.get() to get value. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheValuesPeek(GridPredicate<? super V>... ps)
Converts value filter to entry filter using
GridCacheEntry.peek()
to get value. |
static <X,Y> GridPredicate<X> |
GridFunc.compose(GridPredicate<? super Y> p,
GridClosure<? super X,? extends Y> f)
Gets a predicate that is composed of given predicate and closure.
|
static <T> GridPredicate<T> |
GridFunc.contains(Collection<T> c)
Provides predicate which returns
true if it receives an element
that is contained in the passed in collection. |
static <T> GridPredicate<T> |
GridFunc.equalTo(T target)
Gets predicate that evaluates to
true if its free variable is equal
to target or both are null. |
static GridPredicate<GridEvent> |
GridFunc.eventAfter(long tstamp)
Gets event predicate that returns
true only if event was produced
after given timestamp. |
static GridPredicate<GridEvent> |
GridFunc.eventId(GridUuid... ids)
Gets event predicate that returns
true only if event id is one of the given. |
static GridPredicate<GridEvent> |
GridFunc.eventNode(Collection<? extends GridNode> nodes)
Gets event predicate that returns
true only if node that produced the event
is one of the given. |
static GridPredicate<GridEvent> |
GridFunc.eventNode(String gridName,
GridPredicate<GridNode>... p)
Gets event predicate that returns
true only if node that produced the event
satisfies all given predicates. |
static GridPredicate<GridEvent> |
GridFunc.eventNodeId(UUID... nodeIds)
Gets event predicate that returns
true only if event was produced on one of
given nodes (specified by ids). |
static GridPredicate<GridEvent> |
GridFunc.eventType(int... types)
Gets event predicate that returns
true only if event type is one of the given. |
static GridPredicate<GridFuture<?>> |
GridFunc.finishedFutures()
Returns predicate for filtering finished futures.
|
static GridPredicate<Boolean> |
GridFunc.identityPredicate()
Gets identity predicate, i.e.
|
static GridPredicate<UUID> |
GridFunc.idForNodeId(UUID nodeId)
Creates
UUID predicate evaluating on the given node ID. |
static GridPredicate<UUID> |
GridFunc.idForNodeIds(Collection<UUID> nodeIds)
Creates
UUID predicate evaluating on the given node IDs. |
static GridPredicate<UUID> |
GridFunc.idForNodeIds(UUID... nodeIds)
Creates
UUID predicate evaluating on the given node IDs. |
static <T> GridPredicate<T> |
GridFunc.in(Collection<? extends T> c)
Gets predicate that returns
true if its free variable is contained
in given collection. |
static <T> GridPredicate<T> |
GridFunc.in(T[] c)
Gets predicate that returns
true if its free variable is contained
in given array. |
static <T> GridPredicate<T> |
GridFunc.instanceOf(Class<?> cls)
Gets predicate that evaluates to
true if its free variable is instance of the given class. |
static <T> GridPredicate<Collection<T>> |
GridFunc.isEmptyCollection()
Gets predicate which checks if collection is
null or empty. |
static GridPredicate<String> |
GridFunc.isEmptyString()
Gets predicate which checks if string is
null or empty. |
static <T> GridPredicate<Collection<T>> |
GridFunc.isNotEmptyCollection()
Gets predicate which checks if collection is not
null or empty. |
static GridPredicate<String> |
GridFunc.isNotEmptyString()
Gets predicate which checks if string is not
null or empty. |
static <T> GridPredicate<T> |
GridFunc.isNull()
Gets predicate that evaluates to
true if its free variable is null. |
static <T extends GridNode> |
GridFunc.localNode(UUID locNodeId)
Gets predicate that evaluates to
true only for given local node ID. |
static <K,V> GridPredicate<Map.Entry<K,V>> |
GridFunc.mapKey(K key)
Gets utility predicate that accepts
Map.Entry value and compares its key
to the given value. |
static <K,V> GridPredicate<Map.Entry<K,V>> |
GridFunc.mapValue(V val)
Gets utility predicate that accepts
Map.Entry value and compares
its value to the given value. |
static <T extends GridMetadataAware> |
GridFunc.meta(Iterable<String> names)
Creates predicate that accepts subclass of
GridMetadataAware interface and
evaluates to true if it contains given metadata names (values are ignored). |
static <T extends GridMetadataAware> |
GridFunc.meta(Map<String,?> meta)
Creates predicate that accepts subclass of
GridMetadataAware interface
and evaluates to true if it contains all provided metadata. |
static <T extends GridMetadataAware> |
GridFunc.meta(String... names)
Creates predicate that accepts subclass of
GridMetadataAware interface
and evaluates to true if it contains given metadata names (values are ignored). |
static <T extends GridMetadataAware> |
GridFunc.meta(String name,
Object val)
Creates predicate that accepts subclass of
GridMetadataAware interface
and evaluates to true if it contains given metadata. |
static <T extends GridMetadataAware> |
GridFunc.metaEntry(Collection<? extends Map.Entry<String,?>> meta)
Creates predicate that accepts subclass of
GridMetadataAware interface
and evaluates to true if it contains all provided metadata. |
static <T extends GridMetadataAware> |
GridFunc.metaEntry(Map.Entry<String,?>... meta)
Creates predicate that accepts subclass of
GridMetadataAware
interface and evaluates to true if it contains all provided metadata. |
static <T extends GridNode> |
GridFunc.nodeForNodeId(UUID nodeId)
Creates grid node predicate evaluating on the given node ID.
|
static <T extends GridNode> |
GridFunc.nodeForNodeIds(Collection<UUID> nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static <T extends GridNode> |
GridFunc.nodeForNodeIds(UUID... nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static GridPredicate<GridNode> |
GridFunc.nodeForNodes(Collection<? extends GridNode> nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static GridPredicate<GridNode> |
GridFunc.nodeForNodes(GridNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static <T> GridPredicate<T> |
GridFunc.not(GridPredicate<? super T>... p)
Negates given predicates.
|
static <T> GridPredicate<T> |
GridFunc.notContains(Collection<T> c)
Provides predicate which returns
true if it receives an element
that is not contained in the passed in collection. |
static <T> GridPredicate<T> |
GridFunc.notEqualTo(T target)
Gets predicate that evaluates to
true if its free variable is not equal
to target or both are null. |
static <T> GridPredicate<T> |
GridFunc.notIn(Collection<? extends T> c)
Gets predicate that returns
true if its free variable is not
contained in given collection. |
static <T> GridPredicate<T> |
GridFunc.notIn(T[] c)
Gets predicate that returns
true if its free variable is not
contained in given array. |
static <T> GridPredicate<T> |
GridFunc.notInstanceOf(Class<?> cls)
Gets predicate that evaluates to
true if its free variable is not an instance
of the given class. |
static <T> GridPredicate<T> |
GridFunc.notNull()
Gets predicate that evaluates to
true if its free variable is not null. |
static <T> GridPredicate<T> |
GridFunc.or(Collection<? extends GridPredicate<? super T>> ps)
Get a predicate that evaluates to
true if any of its component
predicates evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.or(GridPredicate<? super T>... ps)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.or(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T extends GridNode> |
GridFunc.remoteNodes(UUID locNodeId)
Gets predicate that evaluates to
false for given local node ID. |
static GridPredicate<GridFuture<?>> |
GridFunc.unfinishedFutures()
Returns predicate for filtering unfinished futures.
|
| Modifier and Type | Method and Description |
|---|---|
static GridClosure<GridProjection,GridPredicate<GridNode>> |
GridFunc.predicate()
Gets closure that transform a grid projection into its predicate.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridPredicate<T> |
GridFunc.and(GridPredicate<? super T>... ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.and(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.and(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <X> GridClosure<X,Boolean> |
GridFunc.as(GridPredicate<? super X> p)
Converts given predicate to closure.
|
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheKeys(GridPredicate<? super K>... ps)
Converts key filter to entry filter using
Map.Entry.getKey()
to get value. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheValuesGet(GridPredicate<? super V>... ps)
Converts value filter to entry filter using
GridCacheEntry.get() to get value. |
static <K,V> GridPredicate<GridCacheEntry<K,V>> |
GridFunc.cacheValuesPeek(GridPredicate<? super V>... ps)
Converts value filter to entry filter using
GridCacheEntry.peek()
to get value. |
static <X,Y> GridPredicate<X> |
GridFunc.compose(GridPredicate<? super Y> p,
GridClosure<? super X,? extends Y> f)
Gets a predicate that is composed of given predicate and closure.
|
static <T> Collection<T> |
GridFunc.copy(Collection<T> to,
Iterable<? extends T> from,
GridPredicate<? super T>... p)
Adds (copies) to given collection using provided predicates.
|
static <T> GridAbsPredicate |
GridFunc.curry(GridPredicate<? super T> f,
T e)
Curries given closure.
|
static <T> Iterable<T> |
GridFunc.drop(Iterable<T> c,
GridPredicate<? super T>... p)
Removes elements in-place from given collection.
|
static GridPredicate<GridEvent> |
GridFunc.eventNode(String gridName,
GridPredicate<GridNode>... p)
Gets event predicate that returns
true only if node that produced the event
satisfies all given predicates. |
static <V> boolean |
GridFunc.exist(Iterable<? extends V> c,
GridPredicate<? super V>... p)
Checks for existence of the element in input collection for which all provided predicates
evaluate to
true. |
static <K1,K extends K1,V1,V extends V1> |
GridFunc.exist(Map<K,V> m,
GridPredicate<? super Map.Entry<K,V>>... p)
Checks for existence of the entry in input map for which all provided predicates
evaluate to
true. |
static <V> boolean |
GridFunc.exist(V[] c,
GridPredicate<? super V>... p)
Checks for existence of the element in input array for which all provided predicates
evaluate to
true. |
static <T> List<T> |
GridFunc.filterList(List<T> c,
boolean cp,
GridPredicate<T>... p)
Loses all elements in input list for which any of the predicates evaluate to
true. |
static <V> V |
GridFunc.find(Iterable<? extends V> c,
V dfltVal,
GridPredicate<? super V>... p)
Finds and returns first element in given collection for which any of the
provided predicates evaluates to
true. |
static <V,Y> Y |
GridFunc.find(Iterable<? extends V> c,
Y dfltVal,
GridClosure<? super V,Y> f,
GridPredicate<? super V>... p)
Finds, transforms and returns first element in given collection for which any of
the provided predicates evaluates to
true. |
static <V> V |
GridFunc.find(V[] c,
V dfltVal,
GridPredicate<? super V>... p)
Finds and returns first element in given array for which any of the provided
predicates evaluates to
true. |
static <V,Y> Y |
GridFunc.find(V[] c,
Y dfltVal,
GridClosure<? super V,Y> f,
GridPredicate<? super V>... p)
Finds, transforms and returns first element in given array for which any of the
provided predicates evaluates to
true. |
static <V> boolean |
GridFunc.forAll(Iterable<? extends V> c,
GridPredicate<? super V>... p)
Applies all given predicates to all elements in given input collection and returns
true if all of them evaluate to true for all elements. |
static <K1,K extends K1,V1,V extends V1> |
GridFunc.forAll(Map<K,V> m,
GridPredicate<? super Map.Entry<K,V>>... p)
Applies given predicates to all entries in given input map and returns
true
if all of them evaluates to true for all entries. |
static <V> boolean |
GridFunc.forAll(V[] c,
GridPredicate<? super V>... p)
Applies all given predicates to all elements in given input array and returns
true
if all of them evaluate to true for all elements. |
static <V> boolean |
GridFunc.forAny(Iterable<? extends V> c,
GridPredicate<? super V>... p)
Applies all given predicates to all elements in given input collection and returns
true if all predicates evaluate to true for at least one element. |
static <K1,K extends K1,V1,V extends V1> |
GridFunc.forAny(Map<K,V> m,
GridPredicate<? super Map.Entry<K,V>>... p)
Applies given predicates to all entries in given input map and returns
true
if all of them evaluates to true for at least one entry. |
static <V> boolean |
GridFunc.forAny(V[] c,
GridPredicate<? super V>... p)
Applies all given predicates to all elements in given input array and returns
true
if all of them evaluate to true for at least one element. |
static <X> void |
GridFunc.forEach(Iterable<? extends X> c,
GridInClosure<? super X> f,
GridPredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided
collection. |
static <K,V> void |
GridFunc.forEach(Map<? extends K,? extends V> m,
GridInClosure<? super GridBiTuple<K,V>> f,
GridPredicate<? super GridBiTuple<K,V>>... p)
Calls given
side-effect only closure (if provided) over the each element of the
provided map. |
static <X> void |
GridFunc.forEach(X[] c,
GridInClosure<? super X> f,
GridPredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided array. |
static <T> boolean |
GridFunc.isAll(T t,
GridPredicate<? super T>... p)
Tests if all provided predicates evaluate to
true for given value. |
static boolean |
GridFunc.isAlwaysFalse(GridPredicate p)
Tests whether or not given predicate is the one returned from
GridFunc.alwaysFalse() method. |
static boolean |
GridFunc.isAlwaysFalse(GridPredicate[] p)
Tests whether or not given set of predicates consists only of one predicate returned from
GridFunc.alwaysFalse() method. |
static boolean |
GridFunc.isAlwaysTrue(GridPredicate p)
Tests whether or not given predicate is the one returned from
GridFunc.alwaysTrue() method. |
static boolean |
GridFunc.isAlwaysTrue(GridPredicate[] p)
Tests whether or not given set of predicates consists only of one predicate returned from
GridFunc.alwaysTrue() method. |
static <T> boolean |
GridFunc.isAny(T t,
GridPredicate<? super T>... p)
Tests if any of provided predicates evaluate to
true for given value. |
static <T> GridIterable<T> |
GridFunc.iterable(Iterable<? extends T> c,
GridPredicate<? super T>... p)
Creates and returns iterable from given collection and optional filtering predicates.
|
static <T1,T2> GridIterator<T2> |
GridFunc.iterator(Iterable<? extends T1> c,
GridClosure<? super T1,T2> trans,
boolean readOnly,
GridPredicate<? super T1>... p)
Creates and returns transforming iterator from given collection and optional
filtering predicates.
|
static <T> GridIterator<T> |
GridFunc.iterator0(Iterable<? extends T> c,
boolean readOnly,
GridPredicate<? super T>... p)
Creates and returns iterator from given collection and optional filtering predicates.
|
static <T> Collection<T> |
GridFunc.lose(Collection<T> c,
boolean cp,
GridPredicate<? super T>... p)
Loses all elements in input collection that are evaluated to
true by
all given predicates. |
static <K,V> Map<K,V> |
GridFunc.lose(Map<K,V> m,
boolean cp,
GridPredicate<? super Map.Entry<K,V>>... p)
Loses all entries in input map that are evaluated to
true by all given predicates. |
static <K,V> Map<K,V> |
GridFunc.loseKeys(Map<K,V> m,
boolean cp,
GridPredicate<? super K>... p)
Loses all entries in input map which keys are evaluated to
true by all
given predicates. |
static <K,V> Map<K,V> |
GridFunc.loseValues(Map<K,V> m,
boolean cp,
GridPredicate<? super V>... p)
Loses all entries in input map which values are evaluated to
true by all
given predicates. |
static <T> GridPredicate<T> |
GridFunc.not(GridPredicate<? super T>... p)
Negates given predicates.
|
static <T> GridPredicate<T> |
GridFunc.or(GridPredicate<? super T>... ps)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.or(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T> GridPredicate<T> |
GridFunc.or(GridPredicate<? super T>[] p1,
GridPredicate<? super T>... p2)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <V> GridBiTuple<Collection<V>,Collection<V>> |
GridFunc.partition(Iterable<? extends V> c,
GridPredicate<? super V> p)
Partitions input collection in two: first containing elements for which given
predicate evaluates to
true - and second containing the elements for which
predicate evaluates to false. |
static <V> GridBiTuple<Collection<V>,Collection<V>> |
GridFunc.partition(V[] c,
GridPredicate<? super V> p)
Partitions input array in two: first containing elements for which given predicate
evaluates to
true - and second containing the elements for which predicate
evaluates to false. |
static <T> Collection<T> |
GridFunc.retain(Collection<T> c,
boolean cp,
GridPredicate<? super T>... p)
Retains all elements in input collection that are evaluated to
true
by all given predicates. |
static <K,V> Map<K,V> |
GridFunc.retain(Map<K,V> m,
boolean cp,
GridPredicate<? super Map.Entry<K,V>>... p)
For a given map retains all map entries that satisfy all provided predicates.
|
static <K,V> Map<K,V> |
GridFunc.retainKeys(Map<K,V> m,
boolean cp,
GridPredicate<? super K>... p)
For a given map retains all map entries which keys satisfy all provided predicates.
|
static <K,V> Map<K,V> |
GridFunc.retainValues(Map<K,V> m,
boolean cp,
GridPredicate<? super V>... p)
For a given map retains all map entries which values satisfy all provided predicates.
|
static <T> int |
GridFunc.size(Collection<? extends T> c,
GridPredicate<? super T>... p)
Gets size of the given collection with provided optional predicates.
|
static <T> int |
GridFunc.size(Iterator<? extends T> it,
GridPredicate<? super T>... p)
Gets size of the given iterator with provided optional predicates.
|
static <T> int |
GridFunc.size(T[] c,
GridPredicate<? super T>... p)
Gets size of the given array with provided optional predicates.
|
static <T0,T extends T0> |
GridFunc.split(Collection<T> c,
GridPredicate<? super T>... p)
Splits given collection in two using provided set of predicates.
|
static <X,Y> Collection<Y> |
GridFunc.transform(Collection<? extends X> c,
GridClosure<? super X,Y> f,
GridPredicate<? super X>... p)
Transforms one collection to another using provided closure and optional set of
predicates.
|
static <X,Y> Collection<Y> |
GridFunc.transform(Collection<Y> to,
Iterable<? extends X> from,
GridClosure<? super X,Y> f,
GridPredicate<? super X>... p)
Transforms one collection to another using provided closure and predicate.
|
static <T1,T2> List<T2> |
GridFunc.transformList(Collection<? extends T1> c,
GridClosure<? super T1,T2> trans,
GridPredicate<? super T1>... p)
Creates a view on given list with provided transformer and predicates.
|
static <T1,T2> Set<T2> |
GridFunc.transformSet(Collection<? extends T1> c,
GridClosure<? super T1,T2> trans,
GridPredicate<? super T1>... p)
Creates a view on given set with provided transformer and predicates.
|
static <T> Collection<T> |
GridFunc.view(Collection<T> c,
GridPredicate<? super T>... p)
Creates write-through light-weight view on given collection with provided predicates.
|
static <K0,K extends K0,V0,V extends V0> |
GridFunc.view(Map<K,V> m,
GridPredicate<? super K>... p)
Creates light-weight view on given map with provided predicates.
|
static <K0,K extends K0,V0,V extends V0> |
GridFunc.viewAsMap(Set<K> c,
GridClosure<? super K,V> mapClo,
GridPredicate<? super K>... p)
Read-only map view of a collection.
|
static <T1,T2> Collection<T2> |
GridFunc.viewReadOnly(Collection<? extends T1> c,
GridClosure<? super T1,T2> trans,
GridPredicate<? super T1>... p)
Creates read-only light-weight view on given collection with transformation and provided
predicates.
|
static <K0,K extends K0,V0,V extends V0,V1> |
GridFunc.viewReadOnly(Map<K,V> m,
GridBiClosure<K,V,V1> trans,
GridPredicate<? super K>... p)
Read-only view on map that supports transformation of values and key filtering.
|
static <K0,K extends K0,V0,V extends V0,V1> |
GridFunc.viewReadOnly(Map<K,V> m,
GridClosure<V,V1> trans,
GridPredicate<? super K>... p)
Read-only view on map that supports transformation of values and key filtering.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridPredicate<T> |
GridFunc.and(Collection<? extends GridPredicate<? super T>> ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> boolean |
GridFunc.isAll(T t,
Iterable<? extends GridPredicate<? super T>> p)
Tests if all provided predicates evaluate to
true for given value. |
static <T> boolean |
GridFunc.isAny(T t,
Iterable<? extends GridPredicate<? super T>> p)
Tests if any of provided predicates evaluate to
true for given value. |
static <T> GridPredicate<T> |
GridFunc.or(Collection<? extends GridPredicate<? super T>> ps)
Get a predicate that evaluates to
true if any of its component
predicates evaluates to true. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
P1<E1>
Defines
alias for GridPredicate by extending it. |
interface |
PCE<K,V>
Defines
alias for GridPredicate<GridCacheEntry<K, V>> by extending
GridPredicate. |
interface |
PE
Defines
alias for GridPredicate<GridEvent> by extending
GridPredicate. |
interface |
PN
Defines
alias for GridPredicate<GridNode> by extending
GridPredicate. |
| Modifier and Type | Class and Description |
|---|---|
class |
PX1<E1>
Defines
alias for GridPredicateX by extending it. |
Copyright © 2014. All rights reserved.