| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCache.loadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
IgniteCache.loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteMessaging.localListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
void |
IgniteCache.localLoadCache(@Nullable 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(@Nullable 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(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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(@Nullable 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(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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(@Nullable 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(@Nullable 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 |
|---|---|
@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> |
RendezvousAffinityFunction.getAffinityBackupFilter()
Gets optional backup filter.
|
@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> |
RendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setAffinityBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.
|
RendezvousAffinityFunction |
RendezvousAffinityFunction.setBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.
Use
affinityBackupFilter instead. |
| Constructor and Description |
|---|
RendezvousAffinityFunction(int parts,
@Nullable 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(@Nullable IgniteBiPredicate<K,V> filter)
Sets filter.
|
| Constructor and Description |
|---|
ScanQuery(@Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
ScanQuery(@Nullable Integer part,
@Nullable 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 |
|---|---|
@Nullable IgniteBiPredicate<K,V> |
CacheQueryReadEvent.scanQueryFilter()
Gets scan query filter.
|
@Nullable IgniteBiPredicate<K,V> |
CacheQueryExecutedEvent.scanQueryFilter()
Gets scan query filter.
|
| Constructor and Description |
|---|
CacheQueryExecutedEvent(ClusterNode node,
String msg,
int type,
String qryType,
@Nullable String cacheName,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<K,V> scanQryFilter,
@Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter,
@Nullable Object[] args,
@Nullable UUID subjId,
@Nullable String taskName) |
CacheQueryReadEvent(ClusterNode node,
String msg,
int type,
String qryType,
@Nullable String cacheName,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<K,V> scanQryFilter,
@Nullable CacheEntryEventSerializableFilter<K,V> contQryFilter,
@Nullable Object[] args,
@Nullable UUID subjId,
@Nullable String taskName,
K key,
V val,
V oldVal,
@Nullable Object row) |
| Modifier and Type | Class and Description |
|---|---|
class |
SecurityAwareBiPredicate<E1,E2>
Security aware IgniteBiPredicate.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteMessagingImpl.localListen(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Adds local listener for given topic on local node only.
|
<T extends Event> |
IgniteEventsImpl.remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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(@Nullable 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(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable 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(@Nullable 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(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Unregisters local listener for given topic on local node only.
|
| Constructor and Description |
|---|
GridMessageListenHandler(@Nullable Object topic,
IgniteBiPredicate<UUID,Object> pred) |
SecurityAwareBiPredicate(UUID subjectId,
IgniteBiPredicate<E1,E2> original) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.addUserMessageListener(@Nullable Object topic,
@Nullable IgniteBiPredicate<UUID,?> p) |
void |
GridIoManager.addUserMessageListener(@Nullable Object topic,
@Nullable IgniteBiPredicate<UUID,?> p,
UUID nodeId) |
void |
GridIoManager.removeUserMessageListener(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p) |
| Modifier and Type | Method and Description |
|---|---|
WALIterator |
IgniteWriteAheadLogManager.replay(WALPointer start,
@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)
Invoke this method to iterate over the written log entries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GatewayProtectedCacheProxy.loadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
IgniteCacheProxyImpl.loadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
GatewayProtectedCacheProxy.loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
IgniteFuture<Void> |
IgniteCacheProxyImpl.loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously executes
IgniteCache.localLoadCache(IgniteBiPredicate, Object...) on all cache nodes. |
void |
GatewayProtectedCacheProxy.localLoadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
IgniteCacheProxyImpl.localLoadCache(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
void |
IgniteInternalCache.localLoadCache(@Nullable 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. |
void |
GridCacheProxyImpl.localLoadCache(IgniteBiPredicate<K,V> p,
@Nullable Object[] args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
IgniteFuture<Void> |
GatewayProtectedCacheProxy.localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously loads state from the underlying persistent storage by delegating
to
CacheStore.loadCache(IgniteBiInClosure,Object...) method. |
IgniteFuture<Void> |
IgniteCacheProxyImpl.localLoadCacheAsync(@Nullable 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(@Nullable 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. |
IgniteInternalFuture<?> |
GridCacheProxyImpl.localLoadCacheAsync(IgniteBiPredicate<K,V> p,
@Nullable 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>> |
GridCacheAdapter.scanIterator(boolean keepBinary,
@Nullable IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheProxyImpl.scanIterator(boolean keepBinary,
@Nullable IgniteBiPredicate<Object,Object> p) |
Iterator<javax.cache.Cache.Entry<K,V>> |
IgniteInternalCache.scanIterator(boolean keepBinary,
@Nullable 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 |
|---|---|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(@Nullable WALIterator it,
IgniteBiPredicate<WALPointer,WALRecord> recPredicate,
IgnitePredicate<DataEntry> entryPredicate)
Apply update from some iterator and with specific filters.
|
| Modifier and Type | Method and Description |
|---|---|
WALIterator |
FileWriteAheadLogManager.replay(WALPointer start,
@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)
Invoke this method to iterate over the written log entries.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteWalIteratorFactory.IteratorParametersBuilder |
IgniteWalIteratorFactory.IteratorParametersBuilder.addFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter) |
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 |
|---|---|
RecordSerializerFactoryImpl |
RecordSerializerFactoryImpl.recordDeserializeFilter(@Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
RecordSerializerFactory |
RecordSerializerFactory.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
| Constructor and Description |
|---|
RecordSerializerFactoryImpl(GridCacheSharedContext cctx,
@Nullable 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 |
|---|---|
@Nullable IgniteBiPredicate<K,V> |
GridCacheQueryManager.ScanQueryIterator.filter() |
IgniteBiPredicate<Object,Object> |
GridCacheQueryRequest.keyValueFilter() |
<K,V> @Nullable IgniteBiPredicate<K,V> |
GridCacheQueryAdapter.scanFilter() |
| Modifier and Type | Method and Description |
|---|---|
<T,R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(@Nullable IgniteBiPredicate<K,V> filter,
@Nullable IgniteClosure<T,R> trans,
@Nullable Integer part,
boolean keepBinary,
boolean forceLocal,
Boolean dataPageScanEnabled)
Creates user's predicate based scan query.
|
<R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(@Nullable IgniteBiPredicate<K,V> filter,
@Nullable Integer part,
boolean keepBinary,
Boolean dataPageScanEnabled)
Creates user's predicate based scan query.
|
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
@Nullable IgniteBiPredicate<Object,Object> filter,
@Nullable IgniteClosure<Map.Entry,Object> transform,
@Nullable Integer part,
boolean keepBinary,
boolean forceLocal,
Boolean dataPageScanEnabled) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteLogger log,
int pageSize,
long timeout,
boolean incBackups,
boolean dedup,
ClusterGroup prj,
IgniteBiPredicate<Object,Object> filter,
@Nullable Integer part,
@Nullable String clsName,
String clause,
int limit,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
MvccSnapshot mvccSnapshot,
Boolean dataPageScanEnabled) |
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
@Nullable String clsName,
@Nullable String clause,
@Nullable IgniteBiPredicate<Object,Object> filter,
@Nullable Integer part,
boolean incMeta,
boolean keepBinary,
Boolean dataPageScanEnabled) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
int limit,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
@Nullable 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,
Boolean dataPageScanEnabled) |
| 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(@Nullable 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 | Method and Description |
|---|---|
default IgniteBiPredicate<E1,E2> |
IgniteBiPredicate.and(IgniteBiPredicate<E1,E2> then)
Returns a composed predicate that represents a short-circuiting logical
AND of this predicate and another.
|
| Modifier and Type | Method and Description |
|---|---|
default IgniteBiPredicate<E1,E2> |
IgniteBiPredicate.and(IgniteBiPredicate<E1,E2> then)
Returns a composed predicate that represents a short-circuiting logical
AND of this predicate and another.
|
| 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(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Register an local message listener to receive messages sent by remote nodes.
|
void |
IgniteSpiContext.removeLocalMessageListener(@Nullable Object topic,
IgniteBiPredicate<UUID,?> p)
Removes a previously registered local message listener.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020