| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCache.loadCache(IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteMessaging.localListen(Object topic,
IgniteBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
void |
IgniteCache.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
<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 cluster group (possibly including
local node if it belongs to the cluster group 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 cluster group (possibly including
local node if it belongs to the cluster group as well).
|
UUID |
IgniteMessaging.remoteListen(Object topic,
IgniteBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the cluster group (possibly including
this node if it belongs to the cluster group as well).
|
void |
IgniteMessaging.stopLocalListen(Object topic,
IgniteBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<ClusterNode,List<ClusterNode>> |
FairAffinityFunction.getAffinityBackupFilter()
Gets optional backup filter.
|
IgniteBiPredicate<ClusterNode,ClusterNode> |
FairAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FairAffinityFunction.setAffinityBackupFilter(IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
void |
FairAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.
Use
affinityBackupFilter instead. |
| Constructor and Description |
|---|
FairAffinityFunction(int parts,
IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<ClusterNode,List<ClusterNode>> |
RendezvousAffinityFunction.getAffinityBackupFilter()
Gets optional backup filter.
|
IgniteBiPredicate<ClusterNode,ClusterNode> |
RendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RendezvousAffinityFunction.setAffinityBackupFilter(IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
void |
RendezvousAffinityFunction.setBackupFilter(IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.
Use
affinityBackupFilter instead. |
| Constructor and Description |
|---|
RendezvousAffinityFunction(int parts,
IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<K,V> |
ScanQuery.getFilter()
Gets filter.
|
| Modifier and Type | Method and Description |
|---|---|
ScanQuery<K,V> |
ScanQuery.setFilter(IgniteBiPredicate<K,V> filter)
Sets filter.
|
| Constructor and Description |
|---|
ScanQuery(IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
ScanQuery(Integer part,
IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GridifyNodeFilter
Predicate node filter.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<K,V> |
CacheQueryExecutedEvent.scanQueryFilter()
Gets scan query filter.
|
IgniteBiPredicate<K,V> |
CacheQueryReadEvent.scanQueryFilter()
Gets scan query filter.
|
| Constructor and Description |
|---|
CacheQueryExecutedEvent(ClusterNode node,
String msg,
int type,
String qryType,
String cacheName,
String clsName,
String clause,
IgniteBiPredicate<K,V> scanQryFilter,
CacheEntryEventSerializableFilter<K,V> contQryFilter,
Object[] args,
UUID subjId,
String taskName) |
CacheQueryReadEvent(ClusterNode node,
String msg,
int type,
String qryType,
String cacheName,
String clsName,
String clause,
IgniteBiPredicate<K,V> scanQryFilter,
CacheEntryEventSerializableFilter<K,V> contQryFilter,
Object[] args,
UUID subjId,
String taskName,
K key,
V val,
V oldVal,
Object row) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteMessagingImpl.localListen(Object topic,
IgniteBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
<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 cluster group (possibly including
local node if it belongs to the cluster group 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 cluster group (possibly including
local node if it belongs to the cluster group as well).
|
UUID |
IgniteMessagingImpl.remoteListen(Object topic,
IgniteBiPredicate<UUID,?> p)
Adds a message listener for a given topic to all nodes in the cluster group (possibly including
this node if it belongs to the cluster group as well).
|
void |
IgniteMessagingImpl.stopLocalListen(Object topic,
IgniteBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Constructor and Description |
|---|
GridMessageListenHandler(Object topic,
IgniteBiPredicate<UUID,Object> pred) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.addUserMessageListener(Object topic,
IgniteBiPredicate<UUID,?> p) |
void |
GridIoManager.removeUserMessageListener(Object topic,
IgniteBiPredicate<UUID,?> p) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheProxy.loadCache(IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteCacheProxy.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
IgniteInternalCache.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
IgniteInternalFuture<?> |
IgniteInternalCache.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheProxyImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridCacheAdapter.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
IgniteInternalFuture<?> |
GridNearCacheAdapter.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<Object,Object> |
GridCacheQueryRequest.keyValueFilter() |
<K,V> IgniteBiPredicate<K,V> |
GridCacheQueryAdapter.scanFilter() |
| Modifier and Type | Method and Description |
|---|---|
<T,R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(IgniteBiPredicate<K,V> filter,
IgniteClosure<T,R> trans,
Integer part,
boolean keepBinary)
Creates user's predicate based scan query.
|
<R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(IgniteBiPredicate<K,V> filter,
Integer part,
boolean keepBinary)
Creates user's predicate based scan query.
|
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteBiPredicate<Object,Object> filter,
IgniteClosure<Map.Entry,Object> transform,
Integer part,
boolean keepBinary) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteLogger log,
int pageSize,
long timeout,
boolean keepAll,
boolean incBackups,
boolean dedup,
ClusterGroup prj,
IgniteBiPredicate<Object,Object> filter,
Integer part,
String clsName,
String clause,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
String clsName,
String clause,
IgniteBiPredicate<Object,Object> filter,
Integer part,
boolean incMeta,
boolean keepBinary) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
Integer part,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
boolean addDepInfo) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridSetQueryPredicate<K,V>
Predicate for query over
IgniteSet items. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridOffHeapProcessor.removex(String spaceName,
int part,
KeyCacheObject key,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from offheap space for the given key.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformEventFilterListener
Platform event filter and listener.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformCacheEntryFilter
Platform cache entry filter interface.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformCacheEntryFilterImpl
Interop filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformEventFilterListenerImpl
Platform event filter.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformMessageFilter
Platform message filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformMessageFilterImpl
Platform message filter.
|
class |
PlatformMessageLocalFilter
Interop local filter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgnitePredicate2X<E1,E2>
Convenient predicate subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridOffHeapMap.removex(int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
boolean |
GridOffHeapPartitionedMap.removex(int part,
int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridUnsafeMap.removex(int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
boolean |
GridUnsafePartitionedMap.removex(int part,
int hash,
byte[] keyBytes,
IgniteBiPredicate<Long,Integer> p)
Removes value from off-heap map without returning it.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
P2<T1,T2>
Defines
alias for IgniteBiPredicate by extending it. |
interface |
PKV<K,V>
Defines
alias for GridPredicate2<K, V> by extending
IgnitePredicate. |
| Modifier and Type | Class and Description |
|---|---|
class |
PX2<T1,T2>
Defines
alias for IgnitePredicate2X by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorQueryScanSubstringFilter
Filter scan results by specified substring in string presentation of key or value.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MessagingListenActor<T>
Convenience actor-base adapter for
IgniteMessaging.localListen(Object, IgniteBiPredicate)
method. |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteSpiContext.addLocalMessageListener(Object topic,
IgniteBiPredicate<UUID,?> p)
Register an local message listener to receive messages sent by remote nodes.
|
void |
IgniteSpiContext.removeLocalMessageListener(Object topic,
IgniteBiPredicate<UUID,?> p)
Removes a previously registered local message listener.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> IgniteBiPredicate<K,V> |
IndexingQueryFilter.forSpace(String spaceName)
Creates optional predicate for space.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.9.0 Release Date : March 2 2017