| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCache.loadCache(IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
IgniteCache.loadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously 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. |
IgniteFuture<Void> |
IgniteCache.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
<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).
|
<T extends Event> |
IgniteEvents.remoteListenAsync(IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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).
|
IgniteFuture<UUID> |
IgniteMessaging.remoteListenAsync(Object topic,
IgniteBiPredicate<UUID,?> p)
Asynchronously 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 | Class and Description |
|---|---|
class |
ClusterNodeAttributeAffinityBackupFilter
This class can be used as a
RendezvousAffinityFunction.affinityBackupFilter to create
cache templates in Spring that force each partition's primary and backup to different hardware which
is not expected to fail simultaneously, e.g., in AWS, to different "availability zones". |
| 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 |
|---|---|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setAffinityBackupFilter(IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
RendezvousAffinityFunction |
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).
|
<T extends Event> |
IgniteEventsImpl.remoteListenAsync(IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
IgniteBiPredicate<UUID,T> locLsnr,
IgnitePredicate<T> rmtFilter,
int... types)
Asynchronously 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).
|
IgniteFuture<UUID> |
IgniteMessagingImpl.remoteListenAsync(Object topic,
IgniteBiPredicate<UUID,?> p)
Asynchronously 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 |
GatewayProtectedCacheProxy.loadCache(IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteCacheProxyImpl.loadCache(IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
GatewayProtectedCacheProxy.loadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
IgniteCacheProxyImpl.loadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
GatewayProtectedCacheProxy.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(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
void |
IgniteCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
void |
GridCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
IgniteFuture<Void> |
GatewayProtectedCacheProxy.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
IgniteInternalFuture<?> |
IgniteInternalCache.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
IgniteFuture<Void> |
IgniteCacheProxyImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
IgniteInternalFuture<?> |
GridCacheProxyImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(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(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
IgniteInternalCache.scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtCacheAdapter.localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(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(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(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
| Modifier and Type | Method and Description |
|---|---|
IgniteWalIteratorFactory.IteratorParametersBuilder |
IgniteWalIteratorFactory.IteratorParametersBuilder.filter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter) |
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<WALRecord.RecordType,WALPointer> |
RecordSerializerFactoryImpl.recordDeserializeFilter() |
| Modifier and Type | Method and Description |
|---|---|
RecordSerializerFactory |
RecordSerializerFactory.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
RecordSerializerFactoryImpl |
RecordSerializerFactoryImpl.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
| Constructor and Description |
|---|
RecordSerializerFactoryImpl(GridCacheSharedContext cctx,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter) |
RecordV1Serializer(RecordDataV1Serializer dataSerializer,
boolean writePointer,
boolean marshalledMode,
boolean skipPositionCheck,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)
Create an instance of V1 serializer.
|
RecordV2Serializer(RecordDataV2Serializer dataSerializer,
boolean writePointer,
boolean marshalledMode,
boolean skipPositionCheck,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)
Create an instance of Record V2 serializer.
|
| 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,
boolean forceLocal)
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,
boolean forceLocal) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteLogger log,
int pageSize,
long timeout,
boolean incBackups,
boolean dedup,
ClusterGroup prj,
IgniteBiPredicate<Object,Object> filter,
Integer part,
String clsName,
String clause,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
MvccSnapshot mvccSnapshot) |
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,
MvccSnapshot mvccSnapshot,
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 |
VisorQueryScanRegexFilter
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.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019