| Modifier and Type | Method and Description |
|---|---|
void |
GridCache.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object... args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
GridFuture<?> |
GridCache.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object... args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
GridCacheProjection<K,V> |
GridCacheProjection.projection(GridBiPredicate<K,V> p)
Gets cache projection based on given key-value predicate.
|
| Modifier and Type | Method and Description |
|---|---|
GridBiPredicate<GridNode,GridNode> |
GridCacheConsistentHashAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheConsistentHashAffinityFunction.setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter)
Sets optional backup filter.
|
| Constructor and Description |
|---|
GridCacheConsistentHashAffinityFunction(int parts,
GridBiPredicate<GridNode,GridNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
GridBiPredicate<GridNode,GridNode> |
GridCacheRendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheRendezvousAffinityFunction.setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter)
Sets optional backup filter.
|
| Constructor and Description |
|---|
GridCacheRendezvousAffinityFunction(int parts,
GridBiPredicate<GridNode,GridNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
GridBiPredicate<UUID,Collection<Map.Entry<K,V>>> |
GridCacheContinuousQuery.callback()
Gets local callback.
|
GridBiPredicate<K,V> |
GridCacheContinuousQuery.filter()
Gets key-value filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheContinuousQuery.callback(GridBiPredicate<UUID,Collection<Map.Entry<K,V>>> cb)
Sets mandatory local callback.
|
GridCacheQuery<Map.Entry<K,V>> |
GridCacheQueries.createScanQuery(GridBiPredicate<K,V> filter)
Creates user's predicate based scan query.
|
void |
GridCacheContinuousQuery.filter(GridBiPredicate<K,V> filter)
Sets optional key-value filter.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridifyNodeFilter
Predicate node filter.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends GridEvent> |
GridEvents.remoteListen(GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridMessagingImpl.localListen(Object topic,
GridBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
<T extends GridEvent> |
GridEventsImpl.remoteListen(GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
<T extends GridEvent> |
GridEventsImpl.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
GridBiPredicate<UUID,T> locLsnr,
GridPredicate<T> rmtFilter,
int... types)
Adds event listener for specified events to all nodes in the projection (possibly including
local node if it belongs to the projection as well).
|
GridFuture<UUID> |
GridMessagingImpl.remoteListen(Object topic,
GridBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the projection (possibly including
this node if it belongs to the projection as well).
|
void |
GridMessagingImpl.stopLocalListen(Object topic,
GridBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Constructor and Description |
|---|
GridMessageListenHandler(Object topic,
GridBiPredicate<UUID,Object> pred) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.addUserMessageListener(Object topic,
GridBiPredicate<UUID,?> p) |
void |
GridIoManager.removeUserMessageListener(Object topic,
GridBiPredicate<UUID,?> p) |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> GridBiPredicate<K,V> |
GridCacheUtils.typeFilter(Class<?> keyType,
Class<?> valType)
Gets type filter for projections.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheAdapter.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
GridFuture<?> |
GridCacheAdapter.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
GridFuture<?> |
GridCacheProxyImpl.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
GridCacheProjection<K,V> |
GridCacheProjectionImpl.projection(GridBiPredicate<K,V> p)
Gets cache projection based on given key-value predicate.
|
GridCacheProjection<K,V> |
GridCacheAdapter.projection(GridBiPredicate<K,V> p)
Gets cache projection based on given key-value predicate.
|
GridCacheProjection<K,V> |
GridCacheProxyImpl.projection(GridBiPredicate<K,V> p)
Gets cache projection based on given key-value predicate.
|
| Constructor and Description |
|---|
GridCacheProjectionImpl(GridCacheProjection<K,V> parent,
GridCacheContext<K,V> cctx,
GridBiPredicate<K,V> kvFilter,
GridPredicate<? super GridCacheEntry<K,V>> entryFilter,
Set<GridCacheFlag> flags,
UUID subjId) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridSetQueryPredicate<K,V>
Predicate for query over
GridCacheSet items. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtCacheAdapter.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearCacheAdapter.loadCache(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Delegates to
GridCacheStore.loadCache(GridBiInClosure,Object...) method
to load state from the underlying persistent storage. |
GridFuture<?> |
GridNearCacheAdapter.loadCacheAsync(GridBiPredicate<K,V> p,
long ttl,
Object[] args)
Asynchronously delegates to
GridCacheStore.loadCache(GridBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
GridBiPredicate<Object,Object> |
GridCacheQueryRequest.keyValueFilter() |
<K,V> GridBiPredicate<K,V> |
GridCacheQueryAdapter.scanFilter() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheQuery<Map.Entry<K,V>> |
GridCacheQueriesImpl.createScanQuery(GridBiPredicate<K,V> filter)
Creates user's predicate based scan query.
|
GridCacheQuery<Map.Entry<K,V>> |
GridCacheQueriesProxy.createScanQuery(GridBiPredicate<K,V> filter)
Creates user's predicate based scan query.
|
| Modifier and Type | Method and Description |
|---|---|
GridBiPredicate<UUID,Collection<Map.Entry<K,V>>> |
GridCacheContinuousQueryAdapter.callback()
Gets local callback.
|
GridBiPredicate<K,V> |
GridCacheContinuousQueryAdapter.filter()
Gets key-value filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheContinuousQueryAdapter.callback(GridBiPredicate<UUID,Collection<Map.Entry<K,V>>> cb)
Sets mandatory local callback.
|
void |
GridCacheContinuousQueryAdapter.filter(GridBiPredicate<K,V> filter)
Sets optional key-value filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridMessagingListenActor<T>
Convenience actor-base adapter for
GridMessaging.localListen(Object, GridBiPredicate)
method. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridMessaging.localListen(Object topic,
GridBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
GridFuture<UUID> |
GridMessaging.remoteListen(Object topic,
GridBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the projection (possibly including
this node if it belongs to the projection as well).
|
void |
GridMessaging.stopLocalListen(Object topic,
GridBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridPredicate2X<E1,E2>
Convenient predicate subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <T1,T2> GridBiPredicate<T1,T2> |
GridFunc.as(GridBiClosure<? super T1,? super T2,Boolean> c)
Converts given closure to predicate.
|
| Modifier and Type | Method and Description |
|---|---|
static <X1,X2> GridBiClosure<X1,X2,Boolean> |
GridFunc.as(GridBiPredicate<? super X1,? super X2> p)
Converts given predicate to closure.
|
static <E1,E2> GridPredicate<GridBiTuple<E1,E2>> |
GridFunc.as0(GridBiPredicate<? super E1,? super E2> p)
Converts predicate with two separate values to a predicate with tuple.
|
static <A,B> boolean |
GridFunc.isAll2(A a,
B b,
GridBiPredicate<? super A,? super B> p)
Tests if all provided predicates evaluate to
true for given values. |
static <A,B> boolean |
GridFunc.isAll2(A a,
B b,
GridBiPredicate<? super A,? super B>[] p)
Tests if all provided predicates evaluate to
true for given values. |
static <A,B> boolean |
GridFunc.isAny2(A a,
B b,
GridBiPredicate<? super A,? super B>... p)
Tests if any of provided predicates evaluate to
true for given values. |
static <K,V> GridBiTuple<Map<K,V>,Map<K,V>> |
GridFunc.partition(Map<? extends K,? extends V> m,
GridBiPredicate<? super K,? super V> p)
Partitions input map in two: first containing entries for which given predicate evaluates
to
true - and second containing the entries for which predicate evaluates to false. |
| Modifier and Type | Method and Description |
|---|---|
static <A,B> boolean |
GridFunc.isAll2(A a,
B b,
Iterable<? extends GridBiPredicate<? super A,? super B>> p)
Tests if all provided predicates evaluate to
true for given values. |
static <A,B> boolean |
GridFunc.isAny2(A a,
B b,
Iterable<? extends GridBiPredicate<? super A,? super B>> p)
Tests if any of provided predicates evaluate to
true for given values. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
P2<T1,T2>
Defines
alias for GridBiPredicate by extending it. |
interface |
PKV<K,V>
Defines
alias for GridPredicate2<K, V> by extending
GridPredicate. |
| Modifier and Type | Class and Description |
|---|---|
class |
PX2<T1,T2>
Defines
alias for GridPredicate2X by extending it. |
Copyright © 2014. All rights reserved.