Uses of Interface
org.apache.ignite.lang.IgniteBiPredicate
-
Packages that use IgniteBiPredicate Package Description org.apache.ignite Contains entry-point Ignite & HPC APIs.org.apache.ignite.cache.affinity.rendezvous Contains HRW-based cache affinity for partitioned cache.org.apache.ignite.cache.query Contains APIs for creating and executing cache queries.org.apache.ignite.events Contains Event Subscription functionality together with various events emitted by Ignite.org.apache.ignite.lang Contains general language constructs and functional APIs for distributed computations.org.apache.ignite.messaging Contains Topic-based Messaging functionality.org.apache.ignite.spi Contains common classes and interfaces for SPI implementations. -
-
Uses of IgniteBiPredicate in org.apache.ignite
Methods in org.apache.ignite with parameters of type IgniteBiPredicate Modifier and Type Method Description void
IgniteCache. loadCache(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)
ExecutesIgniteCache.localLoadCache(IgniteBiPredicate, Object...)
on all cache nodes.IgniteFuture<Void>
IgniteCache. loadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)
Asynchronously executesIgniteCache.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, @Nullable Object... args)
Delegates toCacheStore.loadCache(IgniteBiInClosure,Object...)
method to load state from the underlying persistent storage.IgniteFuture<Void>
IgniteCache. localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)
Asynchronously loads state from the underlying persistent storage by delegating toCacheStore.loadCache(IgniteBiInClosure,Object...)
method.<T extends Event>
UUIDIgniteEvents. remoteListen(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable 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>
UUIDIgniteEvents. remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable 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>
IgniteFuture<UUID>IgniteEvents. remoteListenAsync(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable 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>
IgniteFuture<UUID>IgniteEvents. remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable 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. -
Uses of IgniteBiPredicate in org.apache.ignite.cache.affinity.rendezvous
Classes in org.apache.ignite.cache.affinity.rendezvous that implement IgniteBiPredicate Modifier and Type Class Description class
ClusterNodeAttributeAffinityBackupFilter
Attribute-based affinity backup filter that forces each partition's primary and backup nodes to different hardware which is not expected to fail simultaneously, e.g., in AWS, to different "availability zones".class
ClusterNodeAttributeColocatedBackupFilter
This class can be used as aRendezvousAffinityFunction.affinityBackupFilter
to create cache templates in Spring that force each partition's primary and backup to be co-located on nodes with the same attribute value.Methods in org.apache.ignite.cache.affinity.rendezvous that return IgniteBiPredicate Modifier and Type Method Description @Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>>
RendezvousAffinityFunction. getAffinityBackupFilter()
Gets optional backup filter.@Nullable IgniteBiPredicate<ClusterNode,ClusterNode>
RendezvousAffinityFunction. getBackupFilter()
Gets optional backup filter.Methods in org.apache.ignite.cache.affinity.rendezvous with parameters of type IgniteBiPredicate Modifier and Type Method Description RendezvousAffinityFunction
RendezvousAffinityFunction. setAffinityBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,List<ClusterNode>> affinityBackupFilter)
Sets optional backup filter.RendezvousAffinityFunction
RendezvousAffinityFunction. setBackupFilter(@Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Deprecated.UseaffinityBackupFilter
instead.Constructors in org.apache.ignite.cache.affinity.rendezvous with parameters of type IgniteBiPredicate Constructor Description RendezvousAffinityFunction(int parts, @Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter)
Initializes optional counts for replicas and backups. -
Uses of IgniteBiPredicate in org.apache.ignite.cache.query
Methods in org.apache.ignite.cache.query that return IgniteBiPredicate Modifier and Type Method Description IgniteBiPredicate<K,V>
IndexQuery. getFilter()
Gets remote cache entries filter.IgniteBiPredicate<K,V>
ScanQuery. getFilter()
Gets filter.Methods in org.apache.ignite.cache.query with parameters of type IgniteBiPredicate Modifier and Type Method Description IndexQuery<K,V>
IndexQuery. setFilter(IgniteBiPredicate<K,V> filter)
Sets remote cache entries filter.ScanQuery<K,V>
ScanQuery. setFilter(@Nullable IgniteBiPredicate<K,V> filter)
Sets filter.Constructors in org.apache.ignite.cache.query with parameters of type IgniteBiPredicate Constructor Description ScanQuery(@Nullable Integer part, @Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter.ScanQuery(@Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter. -
Uses of IgniteBiPredicate in org.apache.ignite.events
Methods in org.apache.ignite.events that return IgniteBiPredicate Modifier and Type Method Description @Nullable IgniteBiPredicate<K,V>
CacheQueryExecutedEvent. scanQueryFilter()
Gets scan query filter.@Nullable IgniteBiPredicate<K,V>
CacheQueryReadEvent. scanQueryFilter()
Gets scan query filter.Constructors in org.apache.ignite.events with parameters of type IgniteBiPredicate Constructor 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)
-
Uses of IgniteBiPredicate in org.apache.ignite.lang
Methods in org.apache.ignite.lang that return IgniteBiPredicate Modifier and Type Method 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.Methods in org.apache.ignite.lang with parameters of type IgniteBiPredicate Modifier and Type Method 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. -
Uses of IgniteBiPredicate in org.apache.ignite.messaging
Classes in org.apache.ignite.messaging that implement IgniteBiPredicate Modifier and Type Class Description class
MessagingListenActor<T>
Convenience actor-base adapter forIgniteMessaging.localListen(Object, IgniteBiPredicate)
method. -
Uses of IgniteBiPredicate in org.apache.ignite.spi
Methods in org.apache.ignite.spi with parameters of type IgniteBiPredicate Modifier and Type Method 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.
-