| Modifier and Type | Method and Description |
|---|---|
void |
IgniteEvents.localListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Adds an event listener for local events.
|
<T extends Event> |
IgniteEvents.localQuery(IgnitePredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends Event> |
IgniteEvents.remoteListen(IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<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 Event> |
IgniteEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<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 Event> |
IgniteEvents.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this projection for events using passed in predicate filter for event
selection.
|
boolean |
IgniteEvents.stopLocalListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes local event listener.
|
<T extends Event> |
IgniteEvents.waitForLocal(IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ClusterGroup.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterGroup |
ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgnitePredicate<? extends Event>,int[]> |
IgniteConfiguration.getLocalEventListeners()
Gets map of pre-configured local event listeners.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteConfiguration.setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)
Sets map of pre-configured local event listeners.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.p
Projection predicate.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
IgniteClusterAsyncImpl.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
IgnitePredicate<ClusterNode> |
ClusterGroupAdapter.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCache<?,?>> |
IgniteEx.cachesx(IgnitePredicate<? super GridCache<?,?>>... p)
Gets configured cache instance that satisfy all provided predicates including non-public caches.
|
Collection<GridCache<?,?>> |
IgniteKernal.cachesx(IgnitePredicate<? super GridCache<?,?>>[] p)
Gets configured cache instance that satisfy all provided predicates including non-public caches.
|
ClusterGroup |
IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
ClusterGroup |
ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
void |
IgniteEventsImpl.localListen(IgnitePredicate<? extends Event> lsnr,
int[] types)
Adds an event listener for local events.
|
<T extends Event> |
IgniteEventsImpl.localQuery(IgnitePredicate<T> p,
int... types)
Queries local node for events using passed-in predicate filter for event selection.
|
<T extends Event> |
IgniteEventsImpl.remoteListen(IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<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 Event> |
IgniteEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<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 Event> |
IgniteEventsImpl.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this projection for events using passed in predicate filter for event
selection.
|
boolean |
IgniteEventsImpl.stopLocalListen(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes local event listener.
|
<T extends Event> |
IgniteEventsImpl.waitForLocal(IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
| Constructor and Description |
|---|
ClusterGroupAdapter(ClusterGroup parent,
GridKernalContext ctx,
UUID subjId,
IgnitePredicate<ClusterNode> p) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Class<? extends ComputeTask<?,?>>> |
GridDeploymentManager.findAllTasks(IgnitePredicate<? super Class<? extends ComputeTask<?,?>>>... p) |
GridDeployment |
GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
IgniteUuid clsLdrId,
Map<UUID,IgniteUuid> participants,
IgnitePredicate<ClusterNode> nodeFilter) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ClusterNode> |
GridDiscoveryManager.nodes(Collection<UUID> ids,
IgnitePredicate<UUID>... p)
Gets collection of node for given node IDs and predicates.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEventStorageManager.addLocalEventListener(IgnitePredicate<? extends Event> lsnr,
int[] types)
Adds local user event listener.
|
<T extends Event> |
GridEventStorageManager.localEvents(IgnitePredicate<T> p) |
<T extends Event> |
GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p,
Collection<? extends ClusterNode> nodes,
long timeout) |
boolean |
GridEventStorageManager.removeLocalEventListener(IgnitePredicate<? extends Event> lsnr,
int... types)
Removes user listener for specified events, if any.
|
<T extends Event> |
GridEventStorageManager.waitForEvent(IgnitePredicate<T> p,
int... types) |
Event |
GridEventStorageManager.waitForEvent(long timeout,
Runnable c,
IgnitePredicate<? super Event> p,
int... types) |
| Modifier and Type | Class and Description |
|---|---|
static class |
GridCacheProjectionImpl.FullFilter<K,V> |
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate[] |
GridCacheConcurrentMap.NON_INTERNAL_ARR
Non-internal predicate array.
|
protected IgnitePredicate<GridCacheEntryInfo<K,V>> |
GridCachePreloaderAdapter.preloadPred
Preload predicate.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheUtils.alwaysFalse() |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridCacheUtils.cachePrimary(CacheAffinity<K> aff,
ClusterNode n) |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheUtils.empty() |
IgnitePredicate<? super javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionImpl.FullFilter.entryFilter() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.equalsPeekArray(V val) |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.hasGetArray() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.hasPeekArray() |
static <K,V> IgnitePredicate<K> |
GridCacheUtils.keyHasMeta(GridCacheContext<K,V> ctx,
String meta) |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.noGetArray() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.noPeekArray() |
static <K,V> IgnitePredicate<GridDhtLocalPartition<K,V>> |
GridCacheUtils.notEvicted() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionEx.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionImpl.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.predicate()
Gets predicate on which this projection is based on or
null
if predicate is not defined. |
IgnitePredicate<GridCacheEntryInfo<K,V>> |
GridCachePreloader.preloadPredicate() |
IgnitePredicate<GridCacheEntryInfo<K,V>> |
GridCachePreloaderAdapter.preloadPredicate() |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheUtils.readEntryFilterArray(ObjectInput in)
Reads array from input stream.
|
static <K,V> IgnitePredicate<IgniteTxEntry<K,V>> |
GridCacheUtils.reads() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.trueArray() |
IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridCacheContext.truex() |
protected <T> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheMessage.unmarshalFilter(byte[][] byteCol,
GridCacheSharedContext<K,V> ctx,
ClassLoader ldr) |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p) |
static <K,V> IgnitePredicate<IgniteTxEntry<K,V>> |
GridCacheUtils.writes() |
| Modifier and Type | Method and Description |
|---|---|
Collection<V> |
GridCacheConcurrentMap.allValues(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Collection of all (possibly
null) values. |
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheEntryEx.clear(GridCacheVersion ver,
boolean readers,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
void |
GridCacheAdapter.clearLocally0(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
boolean |
GridCacheAdapter.clearLocally0(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
boolean |
GridCacheMapEntry.compact(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Optimizes the size of this entry.
|
boolean |
GridCacheEntryEx.compact(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Optimizes the size of this entry.
|
boolean |
GridCacheAdapter.compact(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
void |
GridCacheAdapter.compactAll(Iterable<K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheConcurrentMap.entries(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheConcurrentMap.entriesx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Returns entry set containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.entrySet(Collection<? extends K> keys,
IgnitePredicate<K> keyFilter,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.entrySet(Collection<? extends K> keys,
IgnitePredicate<K> keyFilter,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.entrySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionEx.entrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
IgniteCacheProxy.entrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionImpl.entrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.entrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets entry set containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.entrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets entry set containing internal entries.
|
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry,
GridCacheVersion obsoleteVer,
boolean explicit,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
boolean |
GridCacheAdapter.evict(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
void |
GridCacheAdapter.evictAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
boolean |
GridCacheMapEntry.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
boolean |
GridCacheEntryEx.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
boolean |
GridCacheProjectionImpl.forAll(IgnitePredicate<javax.cache.Cache.Entry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
boolean |
CacheProjection.forAll(IgnitePredicate<javax.cache.Cache.Entry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
boolean |
GridCacheProxyImpl.forAll(IgnitePredicate<javax.cache.Cache.Entry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
boolean |
GridCacheAdapter.forAll(IgnitePredicate<javax.cache.Cache.Entry<K,V>> vis)
Tests whether the predicate holds for all entries.
|
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerRemove(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerRemove(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerSet(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerSet(IgniteInternalTx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
byte[] valBytes,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId,
String taskName) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
byte[] valBytes,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId,
String taskName) |
GridTuple3<Boolean,V,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
boolean intercept,
UUID subjId,
String taskName)
Update method for local cache in atomic mode.
|
GridTuple3<Boolean,V,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
boolean intercept,
UUID subjId,
String taskName)
Update method for local cache in atomic mode.
|
boolean |
GridCacheMapEntry.invalidate(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheEntryEx.invalidate(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Invalidates this entry if it passes given filter.
|
<E> boolean |
GridCacheContext.isAll(E e,
IgnitePredicate<? super E>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
<K1,V1> boolean |
GridCacheContext.isAll(GridCacheEntryEx<K1,V1> e,
IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
Set<K> |
GridCacheProjectionImpl.keySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Set of keys cached on this node.
|
Set<K> |
CacheProjection.keySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Set of keys cached on this node.
|
Set<K> |
GridCacheProxyImpl.keySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Set of keys cached on this node.
|
Set<K> |
GridCacheConcurrentMap.keySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Key set.
|
Set<K> |
GridCacheAdapter.keySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
boolean |
GridCacheProjectionImpl.lock(K key,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
CacheProjection.lock(K key,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<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,
IgnitePredicate<javax.cache.Cache.Entry<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,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
CacheProjection.lockAll(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheAdapter.lockAll(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProjectionImpl.lockAll(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
boolean |
GridCacheProxyImpl.lockAll(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
CacheProjection.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
CacheProjection.lockAsync(K key,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.lockAsync(K key,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.lockAsync(K key,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.lockAsync(K key,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
protected <T> byte[][] |
GridCacheMessage.marshalFilter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheSharedContext<K,V> ctx) |
V |
GridCacheEntryEx.peek(Collection<GridCachePeekMode> modes,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheMapEntry.peek(Collection<GridCachePeekMode> modes,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheEntryEx.peek(GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheMapEntry.peek(GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheAdapter.peek(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter) |
GridTuple<V> |
GridCacheMapEntry.peek0(boolean failFast,
GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
IgniteInternalTx<K,V> tx) |
GridTuple<V> |
GridCacheEntryEx.peek0(boolean failFast,
GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
IgniteInternalTx<K,V> tx) |
protected GridTuple<V> |
GridCacheAdapter.peek0(boolean failFast,
K key,
GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Map<K,V> |
GridCacheAdapter.peekAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
protected Map<K,V> |
GridCacheAdapter.peekAll0(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
Collection<K> skipped) |
V |
GridCacheEntryEx.peekFailFast(GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Peeks into entry without loading value or updating statistics.
|
V |
GridCacheMapEntry.peekFailFast(GridCachePeekMode mode,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Peeks into entry without loading value or updating statistics.
|
void |
GridCachePreloader.preloadPredicate(IgnitePredicate<GridCacheEntryInfo<K,V>> p) |
void |
GridCachePreloaderAdapter.preloadPredicate(IgnitePredicate<GridCacheEntryInfo<K,V>> preloadPred) |
protected void |
GridCacheMessage.prepareFilter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters,
GridCacheSharedContext<K,V> ctx) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.primaryEntrySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionEx.primaryEntrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets set of primary entries containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheProjectionImpl.primaryEntrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets set of primary entries containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.primaryEntrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets set of primary entries containing internal entries.
|
Set<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.primaryEntrySetx(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Gets set of primary entries containing internal entries.
|
Set<K> |
GridCacheAdapter.primaryKeySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Collection<V> |
GridCacheAdapter.primaryValues(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
CacheProjection<K,V> |
GridCacheProjectionImpl.projection(IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter)
Gets cache projection based on given entry filter.
|
CacheProjection<K,V> |
CacheProjection.projection(IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter)
Gets cache projection based on given entry filter.
|
CacheProjection<K,V> |
GridCacheProxyImpl.projection(IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter)
Gets cache projection based on given entry filter.
|
CacheProjection<K,V> |
GridCacheAdapter.projection(IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter)
Gets cache projection based on given entry filter.
|
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
CacheProjection.put(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Stores given key-value pair in cache.
|
V |
GridCacheAdapter.put(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Stores given key-value pair in cache.
|
V |
GridCacheProjectionImpl.put(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
V |
GridCacheProxyImpl.put(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
void |
CacheProjection.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProjectionImpl.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
void |
GridCacheAdapter.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
CacheProjection.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheAdapter.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
CacheProjection.putAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pair in cache.
|
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
CacheProjection.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheProxyImpl.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
boolean |
GridCacheAdapter.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
CacheProjection.putxAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
CacheProjection.remove(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mapping from cache.
|
V |
GridCacheProjectionImpl.remove(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Removes given key mapping from cache.
|
V |
GridCacheProxyImpl.remove(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Removes given key mapping from cache.
|
V |
GridCacheAdapter.remove(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Removes given key mapping from cache.
|
void |
GridCacheProjectionImpl.removeAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
void |
CacheProjection.removeAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<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,
IgnitePredicate<javax.cache.Cache.Entry<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,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
CacheProjection.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridCacheProjectionImpl.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
CacheProjection.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
CacheProjection.removeAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheAdapter.removeAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
CacheProjection.removex(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheAdapter.removex(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProjectionImpl.removex(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Removes given key mapping from cache.
|
boolean |
GridCacheProxyImpl.removex(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
CacheProjection.removexAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mapping from cache.
|
boolean |
GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes,
GridCacheMessage<K,V> msg,
GridIoPolicy plc,
IgnitePredicate<ClusterNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
abstract IgniteInternalFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
void |
CacheProjection.unlock(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheAdapter.unlock(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProjectionImpl.unlock(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
GridCacheProxyImpl.unlock(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given key only if current thread owns the lock.
|
void |
CacheProjection.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheProjectionImpl.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridCacheProxyImpl.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
Collection<V> |
GridCacheConcurrentMap.values(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Collection of non-
null values. |
Collection<V> |
GridCacheAdapter.values(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p) |
boolean |
GridCacheMapEntry.visitable(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Constructor and Description |
|---|
GridCacheEntrySet(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
GridCacheIterator(GridCacheContext<K,V> cctx,
Iterable<? extends javax.cache.Cache.Entry<K,V>> c,
IgniteClosure<javax.cache.Cache.Entry<K,V>,T> trans,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridCacheKeySet(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridCacheProjectionImpl(CacheProjection<K,V> parent,
GridCacheContext<K,V> cctx,
IgniteBiPredicate<K,V> kvFilter,
IgnitePredicate<? super javax.cache.Cache.Entry<K,V>> entryFilter,
Set<CacheFlag> flags,
UUID subjId,
boolean keepPortable,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
GridCacheValueCollection(GridCacheContext<K,V> ctx,
Collection<? extends javax.cache.Cache.Entry<K,V>> c,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
All or nothing synchronous lock for passed in keys.
|
protected abstract IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridTuple<V> |
GridDistributedTxRemoteAdapter.peek(GridCacheContext<K,V> cacheCtx,
boolean failFast,
K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean isInvalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridNearLockResponse<K,V>> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridCacheContext<K,V> cacheCtx,
ClusterNode nearNode,
GridNearLockRequest<K,V> req,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter0) |
GridDhtFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Acquires locks in partitioned cache.
|
void |
GridDhtCacheAdapter.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Constructor and Description |
|---|
GridDhtLockFuture(GridCacheContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
long topVer,
int cnt,
boolean read,
long timeout,
GridDhtTxLocalAdapter<K,V> tx,
long threadId,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridNearAtomicUpdateRequest.filter() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
V |
GridDhtAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridDhtAtomicCache.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridDhtAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridDhtAtomicCache.removeAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
| Constructor and Description |
|---|
GridNearAtomicUpdateFuture(GridCacheContext<K,V> cctx,
GridDhtAtomicCache<K,V> cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<? extends K> keys,
Collection<?> vals,
Object[] invokeArgs,
Collection<GridCacheDrInfo<V>> drPutVals,
Collection<GridCacheVersion> drRmvVals,
boolean retval,
boolean rawRetval,
GridCacheEntryEx<K,V> cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
UUID subjId,
int taskNameHash) |
GridNearAtomicUpdateRequest(int cacheId,
UUID nodeId,
GridCacheVersion futVer,
boolean fastMap,
GridCacheVersion updateVer,
long topVer,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
boolean retval,
boolean forceTransformBackups,
javax.cache.expiry.ExpiryPolicy expiryPlc,
Object[] invokeArgs,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
UUID subjId,
int taskNameHash)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
This is an entry point to pessimistic locking within transaction.
|
void |
GridDhtColocatedCache.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<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,
GridNearTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPreloader.preloadPredicate(IgnitePredicate<GridCacheEntryInfo<K,V>> preloadPred) |
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
GridNearLockRequest.filter() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearCacheAdapter.clearLocally0(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
boolean |
GridNearCacheAdapter.clearLocally0(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
boolean |
GridNearCacheAdapter.compact(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridNearCacheAdapter.entrySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
boolean |
GridNearCacheAdapter.evict(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
void |
GridNearCacheAdapter.evictAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
boolean |
GridNearCacheAdapter.evictNearOnly(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
void |
GridNearLockRequest.filter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
Set<K> |
GridNearCacheAdapter.keySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Set of keys cached on this node.
|
protected IgniteInternalFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
protected IgniteInternalFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
Set<K> |
GridNearCacheAdapter.nearKeySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter) |
V |
GridNearCacheAdapter.peek(K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>> filter) |
Map<K,V> |
GridNearCacheAdapter.peekAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
GridNearCacheAdapter.primaryEntrySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Set<K> |
GridNearCacheAdapter.primaryKeySet(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
Collection<V> |
GridNearCacheAdapter.primaryValues(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridNearAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.removeAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridNearAtomicCache.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
void |
GridNearTransactionalCache.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
Collection<V> |
GridNearCacheAdapter.values(IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
| Constructor and Description |
|---|
GridNearLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
GridNearTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
GridLocalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
void |
GridLocalCache.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
IgnitePredicate<javax.cache.Cache.Entry<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,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridLocalAtomicCache.putAll(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
GridLocalAtomicCache.putAllAsync(Map<? extends K,? extends V> m,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously stores given key-value pairs in cache.
|
IgniteInternalFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridLocalAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridLocalAtomicCache.removeAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
GridLocalAtomicCache.removeAllAsync(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
IgniteInternalFuture<?> |
GridLocalAtomicCache.removeAllAsync(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Asynchronously removes mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<? extends K> keys,
long timeout,
IgniteTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
void |
GridLocalAtomicCache.unlockAll(Collection<? extends K> keys,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Unlocks given keys only if current thread owns the locks.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<javax.cache.Cache.Entry<Object,Object>> |
GridCacheQueryRequest.projectionFilter() |
IgnitePredicate<javax.cache.Cache.Entry<Object,Object>> |
GridCacheQueryAdapter.projectionFilter() |
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgnitePredicate<javax.cache.Cache.Entry<Object,Object>> prjPred,
String clsName,
String clause,
IgniteBiPredicate<Object,Object> filter,
boolean incMeta,
boolean keepPortable) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
IgnitePredicate<javax.cache.Cache.Entry<Object,Object>> prjPred,
GridCacheQueryType type,
IgniteLogger log,
int pageSize,
long timeout,
boolean keepAll,
boolean incBackups,
boolean dedup,
ClusterGroup prj,
IgniteBiPredicate<Object,Object> filter,
String clsName,
String clause,
boolean incMeta,
boolean keepPortable,
UUID subjId,
int taskHash) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
IgnitePredicate<javax.cache.Cache.Entry<Object,Object>> prjFilter,
IgniteReducer<Object,Object> rdc,
IgniteClosure<Object,Object> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepPortable,
UUID subjId,
int taskHash) |
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] |
IgniteTxEntry.filters() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteTxEntry<K,V> |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
V val,
javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx<K,V> entry,
javax.cache.expiry.ExpiryPolicy expiryPlc,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
protected IgniteInternalFuture<Set<K>> |
IgniteTxLocalAdapter.enlistWrite(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap,
Object[] invokeArgs,
boolean retval,
boolean lockOnly,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
void |
IgniteTxEntry.filters(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters) |
GridTuple<V> |
IgniteInternalTx.peek(GridCacheContext<K,V> ctx,
boolean failFast,
K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
GridTuple<V> |
IgniteTxLocalAdapter.peek(GridCacheContext<K,V> cacheCtx,
boolean failFast,
K key,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
protected Set<K> |
IgniteTxLocalAdapter.postLockWrite(GridCacheContext<K,V> cacheCtx,
Iterable<? extends K> keys,
Set<K> failed,
GridCacheReturn ret,
boolean rmv,
boolean retval,
boolean read,
long accessTtl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
boolean computeInvoke)
Post lock processing for put or remove.
|
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalEx.putAllAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean retval,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean retval,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
javax.cache.processor.EntryProcessor<K,V,?> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
IgniteTxMap(Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> txMap,
IgnitePredicate<IgniteTxEntry<K,V>> filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
int bufSize,
long interval,
boolean autoUnsubscribe,
IgnitePredicate<ClusterNode> prjPred) |
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
GridServiceAssignments.nodeFilter() |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T> p,
IgnitePredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<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> IgnitePredicate<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> IgnitePredicate<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> IgnitePredicate<T> |
F0.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static <T> IgnitePredicate<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> IgnitePredicate<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> IgnitePredicate<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. |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate (non peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T> p,
IgnitePredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
F0.and(IgnitePredicate<? super T> p,
IgnitePredicate<? super T>... ps)
Get a predicate (not peer-deployable) that evaluates to
true if each of its component predicates
evaluates to true. |
static <T extends R,R> |
IgniteUtils.arrayList(Collection<T> c,
IgnitePredicate<? super T>... p) |
static <T extends R,R> |
IgniteUtils.arrayList(Iterable<T> c,
int cap,
IgnitePredicate<? super T>... p) |
boolean |
GridAtomicInteger.checkAndSet(IgnitePredicate<Integer> p,
int update)
Atomically updates value only if passed in predicate returns
true. |
boolean |
GridAtomicLong.checkAndSet(IgnitePredicate<Long> p,
long update)
Atomically updates value only if passed in predicate returns
true. |
static boolean |
F0.isAllNodePredicates(IgnitePredicate<?>... ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
N |
GridConsistentHash.node(Object key,
IgnitePredicate<N>... p)
Gets node for a given key.
|
List<N> |
GridConsistentHash.nodes(Object key,
int cnt,
IgnitePredicate<N>... p)
Gets specified count of adjacent nodes for a given key.
|
static <T> IgnitePredicate<T> |
F0.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static ClusterNode |
IgniteUtils.oldest(Collection<ClusterNode> c,
IgnitePredicate<ClusterNode> p)
Gets oldest node out of collection of nodes.
|
static List<Integer> |
IgniteUtils.toIntList(int[] arr,
IgnitePredicate<Integer>... p)
Converts array of integers into list.
|
static ClusterNode |
IgniteUtils.youngest(Collection<ClusterNode> c,
IgnitePredicate<ClusterNode> p)
Gets youngest node out of collection of nodes.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
F0.isAllNodePredicates(Iterable<? extends IgnitePredicate<?>> ps)
Tests if all passed in predicates are instances of
GridNodePredicate class. |
| Constructor and Description |
|---|
GridReflectionCache(IgnitePredicate<Field> fp,
IgnitePredicate<Method> mp)
Reflection cache with specified field and method predicates.
|
GridReflectionCache(IgnitePredicate<Field> fp,
IgnitePredicate<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 |
IgnitePredicateX<E1>
Convenient predicate subclass that allows for thrown grid exception.
|
| Modifier and Type | Field and Description |
|---|---|
static IgnitePredicate |
GridFunc.EMPTY_COLLECTION |
static IgnitePredicate<String> |
GridFunc.EMPTY_STRING |
static IgnitePredicate<Object> |
GridFunc.IS_NOT_NULL |
static IgnitePredicate<Object> |
GridFunc.IS_NULL |
static IgnitePredicate |
GridFunc.NOT_EMPTY_COLLECTION |
static IgnitePredicate<String> |
GridFunc.NOT_EMPTY_STRING |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
GridFunc.alwaysFalse()
Gets predicate that always returns
false. |
static <T> IgnitePredicate<T> |
GridFunc.alwaysTrue()
Gets predicate that always returns
true. |
static <T> IgnitePredicate<T> |
GridFunc.and(Collection<? extends IgnitePredicate<? super T>> ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>... ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.as(IgniteClosure<? super T,Boolean> c)
Converts given closure to predicate.
|
static <E1,E2> IgnitePredicate<IgniteBiTuple<E1,E2>> |
GridFunc.as0(IgniteBiPredicate<? super E1,? super E2> p)
Converts predicate with two separate values to a predicate with tuple.
|
static <T> IgnitePredicate<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> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsEntriesGet(javax.cache.Cache.Entry<K,V>... entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsEntriesGet(Collection<? extends javax.cache.Cache.Entry<K,V>> entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsEntriesPeek(javax.cache.Cache.Entry<K,V>... entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsEntriesPeek(Collection<? extends javax.cache.Cache.Entry<K,V>> entries)
Gets predicate which returns
true if cache entry matches any given key-value pair. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsGet(Collection<? extends V> vals)
Gets predicate which returns true if
org.apache.ignite.cache.Entry#get()
method returns value that is contained in given collection. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<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> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsGet(V... vals)
Gets predicate which returns true if
org.apache.ignite.cache.Entry#get() method returns
value that is contained among given values. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsPeek(Collection<? extends V> vals)
Gets predicate which returns true if
org.apache.ignite.cache.Entry#peek() methods returns
value that is contained in given collection. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<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> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheContainsPeek(V... vals)
Gets predicate which returns true if
org.apache.ignite.cache.Entry#peek() methods returns
value that is contained among given values. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheHasGetValue()
Gets predicate which returns
true if org.apache.ignite.cache.Entry#get()
method returns non-null value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<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> IgnitePredicate<javax.cache.Cache.Entry<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> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheHasPeekValue()
Gets predicate which returns
true if
Entry.peek() method
returns non-null value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheKeys(IgnitePredicate<? super K>... ps)
Converts key filter to entry filter using
org.apache.ignite.cache.Entry#getKey()
to get value. |
static IgnitePredicate<ClusterNode> |
GridFunc.cacheNodesForNames(String... cacheNames)
Gets node predicate which returns
true for all nodes which have given cache names
started. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheNoGetValue()
Gets predicate which returns
true if org.apache.ignite.cache.Entry#get()
method returns null value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheNoPeekValue()
Gets predicate which returns
true if
Entry.peek()
method returns null value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheValuesGet(IgnitePredicate<? super V>... ps)
Converts value filter to entry filter using
org.apache.ignite.cache.Entry#get() to get value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheValuesPeek(IgnitePredicate<? super V>... ps)
Converts value filter to entry filter using
org.apache.ignite.cache.Entry#peek()
to get value. |
static <X,Y> IgnitePredicate<X> |
GridFunc.compose(IgnitePredicate<? super Y> p,
IgniteClosure<? super X,? extends Y> f)
Gets a predicate that is composed of given predicate and closure.
|
static <T> IgnitePredicate<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> IgnitePredicate<T> |
GridFunc.equalTo(T target)
Gets predicate that evaluates to
true if its free variable is equal
to target or both are null. |
static IgnitePredicate<Event> |
GridFunc.eventAfter(long tstamp)
Gets event predicate that returns
true only if event was produced
after given timestamp. |
static IgnitePredicate<Event> |
GridFunc.eventId(IgniteUuid... ids)
Gets event predicate that returns
true only if event id is one of the given. |
static IgnitePredicate<Event> |
GridFunc.eventNode(Collection<? extends ClusterNode> nodes)
Gets event predicate that returns
true only if node that produced the event
is one of the given. |
static IgnitePredicate<Event> |
GridFunc.eventNode(String gridName,
IgnitePredicate<ClusterNode>... p)
Gets event predicate that returns
true only if node that produced the event
satisfies all given predicates. |
static IgnitePredicate<Event> |
GridFunc.eventNodeId(UUID... nodeIds)
Gets event predicate that returns
true only if event was produced on one of
given nodes (specified by ids). |
static IgnitePredicate<Event> |
GridFunc.eventType(int... types)
Gets event predicate that returns
true only if event type is one of the given. |
static IgnitePredicate<Boolean> |
GridFunc.identityPredicate()
Gets identity predicate, i.e. the predicate that returns its argument value.
|
static IgnitePredicate<UUID> |
GridFunc.idForNodeId(UUID nodeId)
Creates
UUID predicate evaluating on the given node ID. |
static IgnitePredicate<UUID> |
GridFunc.idForNodeIds(Collection<UUID> nodeIds)
Creates
UUID predicate evaluating on the given node IDs. |
static IgnitePredicate<UUID> |
GridFunc.idForNodeIds(UUID... nodeIds)
Creates
UUID predicate evaluating on the given node IDs. |
static <T> IgnitePredicate<T> |
GridFunc.in(Collection<? extends T> c)
Gets predicate that returns
true if its free variable is contained
in given collection. |
static <T> IgnitePredicate<T> |
GridFunc.in(T[] c)
Gets predicate that returns
true if its free variable is contained
in given array. |
static <T> IgnitePredicate<T> |
GridFunc.instanceOf(Class<?> cls)
Gets predicate that evaluates to
true if its free variable is instance of the given class. |
static <T> IgnitePredicate<Collection<T>> |
GridFunc.isEmptyCollection()
Gets predicate which checks if collection is
null or empty. |
static IgnitePredicate<String> |
GridFunc.isEmptyString()
Gets predicate which checks if string is
null or empty. |
static <T> IgnitePredicate<Collection<T>> |
GridFunc.isNotEmptyCollection()
Gets predicate which checks if collection is not
null or empty. |
static IgnitePredicate<String> |
GridFunc.isNotEmptyString()
Gets predicate which checks if string is not
null or empty. |
static <T> IgnitePredicate<T> |
GridFunc.isNull()
Gets predicate that evaluates to
true if its free variable is null. |
static <T extends ClusterNode> |
GridFunc.localNode(UUID locNodeId)
Gets predicate that evaluates to
true only for given local node ID. |
static <K,V> IgnitePredicate<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> IgnitePredicate<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 ClusterNode> |
GridFunc.nodeForNodeId(UUID nodeId)
Creates grid node predicate evaluating on the given node ID.
|
static <T extends ClusterNode> |
GridFunc.nodeForNodeIds(Collection<UUID> nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static <T extends ClusterNode> |
GridFunc.nodeForNodeIds(UUID... nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static IgnitePredicate<ClusterNode> |
GridFunc.nodeForNodes(ClusterNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static IgnitePredicate<ClusterNode> |
GridFunc.nodeForNodes(Collection<? extends ClusterNode> nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static <T> IgnitePredicate<T> |
GridFunc.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static <T> IgnitePredicate<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> IgnitePredicate<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> IgnitePredicate<T> |
GridFunc.notIn(Collection<? extends T> c)
Gets predicate that returns
true if its free variable is not
contained in given collection. |
static <T> IgnitePredicate<T> |
GridFunc.notIn(T[] c)
Gets predicate that returns
true if its free variable is not
contained in given array. |
static <T> IgnitePredicate<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> IgnitePredicate<T> |
GridFunc.notNull()
Gets predicate that evaluates to
true if its free variable is not null. |
static <T> IgnitePredicate<T> |
GridFunc.or(Collection<? extends IgnitePredicate<? super T>> ps)
Get a predicate that evaluates to
true if any of its component
predicates evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.or(IgnitePredicate<? super T>... ps)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.or(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T extends ClusterNode> |
GridFunc.remoteNodes(UUID locNodeId)
Gets predicate that evaluates to
false for given local node ID. |
static IgnitePredicate<IgniteInternalFuture<?>> |
GridFunc.unfinishedFutures()
Returns predicate for filtering unfinished futures.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteClosure<ClusterGroup,IgnitePredicate<ClusterNode>> |
GridFunc.predicate()
Gets closure that transform a grid projection into its predicate.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>... ps)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.and(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate that evaluates to
true if each of its component predicates
evaluates to true. |
static <X> IgniteClosure<X,Boolean> |
GridFunc.as(IgnitePredicate<? super X> p)
Converts given predicate to closure.
|
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheKeys(IgnitePredicate<? super K>... ps)
Converts key filter to entry filter using
org.apache.ignite.cache.Entry#getKey()
to get value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheValuesGet(IgnitePredicate<? super V>... ps)
Converts value filter to entry filter using
org.apache.ignite.cache.Entry#get() to get value. |
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>> |
GridFunc.cacheValuesPeek(IgnitePredicate<? super V>... ps)
Converts value filter to entry filter using
org.apache.ignite.cache.Entry#peek()
to get value. |
static <X,Y> IgnitePredicate<X> |
GridFunc.compose(IgnitePredicate<? super Y> p,
IgniteClosure<? 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,
IgnitePredicate<? super T>... p)
Adds (copies) to given collection using provided predicates.
|
static <T> GridAbsPredicate |
GridFunc.curry(IgnitePredicate<? super T> f,
T e)
Curries given closure.
|
static <T> Iterable<T> |
GridFunc.drop(Iterable<T> c,
IgnitePredicate<? super T>... p)
Removes elements in-place from given collection.
|
static IgnitePredicate<Event> |
GridFunc.eventNode(String gridName,
IgnitePredicate<ClusterNode>... 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<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,
IgnitePredicate<? 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,
IgniteClosure<? super V,Y> f,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgniteClosure<? super V,Y> f,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgniteInClosure<? super X> f,
IgnitePredicate<? 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,
IgniteInClosure<? super IgniteBiTuple<K,V>> f,
IgnitePredicate<? super IgniteBiTuple<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,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided array. |
static <T> boolean |
GridFunc.isAll(T t,
IgnitePredicate<? super T>... p)
Tests if all provided predicates evaluate to
true for given value. |
static boolean |
GridFunc.isAlwaysFalse(IgnitePredicate p)
Tests whether or not given predicate is the one returned from
GridFunc.alwaysFalse() method. |
static boolean |
GridFunc.isAlwaysFalse(IgnitePredicate[] p)
Tests whether or not given set of predicates consists only of one predicate returned from
GridFunc.alwaysFalse() method. |
static boolean |
GridFunc.isAlwaysTrue(IgnitePredicate p)
Tests whether or not given predicate is the one returned from
GridFunc.alwaysTrue() method. |
static boolean |
GridFunc.isAlwaysTrue(IgnitePredicate[] 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgniteClosure<? super T1,T2> trans,
boolean readOnly,
IgnitePredicate<? super T1>... p)
Creates and returns transforming iterator from given collection and optional
filtering predicates.
|
static <T1,T2> Iterator<T2> |
GridFunc.iterator(Iterator<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
boolean readOnly,
IgnitePredicate<? super T1>... p) |
static <T> GridIterator<T> |
GridFunc.iterator0(Iterable<? extends T> c,
boolean readOnly,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? super V>... p)
Loses all entries in input map which values are evaluated to
true by all
given predicates. |
static <T> IgnitePredicate<T> |
GridFunc.not(IgnitePredicate<? super T>... p)
Negates given predicates.
|
static <T> IgnitePredicate<T> |
GridFunc.or(IgnitePredicate<? super T>... ps)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.or(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <T> IgnitePredicate<T> |
GridFunc.or(IgnitePredicate<? super T>[] p1,
IgnitePredicate<? super T>... p2)
Get a predicate that evaluates to
true if any of its component predicates
evaluates to true. |
static <V> IgniteBiTuple<Collection<V>,Collection<V>> |
GridFunc.partition(Iterable<? extends V> c,
IgnitePredicate<? 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> IgniteBiTuple<Collection<V>,Collection<V>> |
GridFunc.partition(V[] c,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgnitePredicate<? super T>... p)
Gets size of the given collection with provided optional predicates.
|
static <T> int |
GridFunc.size(Iterator<? extends T> it,
IgnitePredicate<? super T>... p)
Gets size of the given iterator with provided optional predicates.
|
static <T> int |
GridFunc.size(T[] c,
IgnitePredicate<? super T>... p)
Gets size of the given array with provided optional predicates.
|
static <T0,T extends T0> |
GridFunc.split(Collection<T> c,
IgnitePredicate<? super T>... p)
Splits given collection in two using provided set of predicates.
|
static <X,Y> Collection<Y> |
GridFunc.transform(Collection<? extends X> c,
IgniteClosure<? super X,Y> f,
IgnitePredicate<? 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,
IgniteClosure<? super X,Y> f,
IgnitePredicate<? super X>... p)
Transforms one collection to another using provided closure and predicate.
|
static <T1,T2> List<T2> |
GridFunc.transformList(Collection<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
IgnitePredicate<? 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,
IgniteClosure<? super T1,T2> trans,
IgnitePredicate<? super T1>... p)
Creates a view on given set with provided transformer and predicates.
|
static <T> Collection<T> |
GridFunc.view(Collection<T> c,
IgnitePredicate<? 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,
IgnitePredicate<? 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,
IgniteClosure<? super K,V> mapClo,
IgnitePredicate<? super K>... p)
Read-only map view of a collection.
|
static <T1,T2> Collection<T2> |
GridFunc.viewReadOnly(Collection<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
IgnitePredicate<? 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,
IgniteBiClosure<K,V,V1> trans,
IgnitePredicate<? 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,
IgniteClosure<V,V1> trans,
IgnitePredicate<? super K>... p)
Read-only view on map that supports transformation of values and key filtering.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgnitePredicate<T> |
GridFunc.and(Collection<? extends IgnitePredicate<? 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 IgnitePredicate<? super T>> p)
Tests if all provided predicates evaluate to
true for given value. |
static <T> boolean |
GridFunc.isAny(T t,
Iterable<? extends IgnitePredicate<? super T>> p)
Tests if any of provided predicates evaluate to
true for given value. |
static <T> IgnitePredicate<T> |
GridFunc.or(Collection<? extends IgnitePredicate<? 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 IgnitePredicate by extending it. |
interface |
PCE<K,V>
Defines
alias for GridPredicate<Entry<K, V>> by extending
IgnitePredicate. |
interface |
PE
Defines
alias for GridPredicate<GridEvent> by extending
IgnitePredicate. |
interface |
PN
Defines
alias for GridPredicate<GridNode> by extending
IgnitePredicate. |
| Modifier and Type | Class and Description |
|---|---|
class |
PX1<E1>
Defines
alias for IgnitePredicateX by extending it. |
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<ClusterNode> |
ServiceConfiguration.getNodeFilter()
Gets node filter used to filter nodes on which the service will be deployed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ServiceConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)
Sets node filter used to filter nodes on which the service will be deployed.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
EventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<Event> |
MemoryEventStorageSpi.getFilter()
Gets filter for events to be recorded.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Event> |
MemoryEventStorageSpi.localEvents(IgnitePredicate<T> p)
Queries locally-stored events only.
|
void |
MemoryEventStorageSpi.setFilter(IgnitePredicate<Event> filter)
Sets filter for events to be recorded.
|
| Constructor and Description |
|---|
StreamerRandomEventRouter(IgnitePredicate<ClusterNode>... predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
| Constructor and Description |
|---|
StreamerRandomEventRouter(Collection<IgnitePredicate<ClusterNode>> predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
| Modifier and Type | Method and Description |
|---|---|
IgnitePredicate<Object> |
StreamerWindowAdapter.getFilter()
Gets optional event filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamerWindowAdapter.setFilter(IgnitePredicate<Object> filter)
Sets event filter.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015