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.hibernate	Contains implementation of Hibernate L2 cache.
org.apache.ignite.cache.query	Contains APIs for creating and executing cache queries.
org.apache.ignite.compute.gridify	Contains APIs utilized for AOP-based grid-enabling.
org.apache.ignite.events	Contains Event Subscription functionality together with various events emitted by Ignite.
org.apache.ignite.messaging	Contains Topic-based Messaging functionality.
org.apache.ignite.ml.dataset	Base package for machine learning dataset classes.
org.apache.ignite.ml.dataset.impl.cache	Base package for cache based implementation of machine learning dataset.
org.apache.ignite.ml.dataset.impl.cache.util	Contains util classes used in cache based implementation of dataset.
org.apache.ignite.ml.dataset.impl.local	Base package for local implementation of machine learning dataset.
org.apache.ignite.ml.selection.cv	Root package for cross-validation algorithms.
org.apache.ignite.ml.selection.scoring.cursor	Util classes used for score calculation.
org.apache.ignite.ml.selection.scoring.evaluator	Package for model evaluator classes.
org.apache.ignite.ml.selection.split	Root package for dataset splitters and cross validation.
org.apache.ignite.ml.trainers	Contains model trainers.
org.apache.ignite.spi	Contains common classes and interfaces for SPI implementations.
org.apache.ignite.tensorflow.cluster	TensorFlow integration API that allows to start and maintain TensorFlow cluster using infrastructure tools from package org.apache.ignite.tensorflow.core.

Uses of IgniteBiPredicate in org.apache.ignite

Methods in org.apache.ignite with parameters of type IgniteBiPredicate

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> UUID	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> UUID	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> IgniteFuture<UUID>	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> IgniteFuture<UUID>	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.

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 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".

Methods in org.apache.ignite.cache.affinity.rendezvous that return IgniteBiPredicate

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.

Methods in org.apache.ignite.cache.affinity.rendezvous with parameters of type IgniteBiPredicate

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.

Constructors in org.apache.ignite.cache.affinity.rendezvous with parameters of type IgniteBiPredicate

Constructor and Description
RendezvousAffinityFunction(int parts, @Nullable IgniteBiPredicate<ClusterNode,ClusterNode> backupFilter) Initializes optional counts for replicas and backups.

Uses of IgniteBiPredicate in org.apache.ignite.cache.hibernate

Methods in org.apache.ignite.cache.hibernate with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
void	HibernateCacheProxy.localLoadCache(@Nullable IgniteBiPredicate p, Object... args) Delegates to CacheStore.loadCache(IgniteBiInClosure, Object...) method to load state from the underlying persistent storage.
org.apache.ignite.internal.IgniteInternalFuture<?>	HibernateCacheProxy.localLoadCacheAsync(@Nullable IgniteBiPredicate p, Object... args) Asynchronously delegates to CacheStore.loadCache(IgniteBiInClosure, Object...) method to reload state from the underlying persistent storage.
Iterator<javax.cache.Cache.Entry<Object,Object>>	HibernateCacheProxy.scanIterator(boolean keepBinary, @Nullable IgniteBiPredicate p)

Uses of IgniteBiPredicate in org.apache.ignite.cache.query

Methods in org.apache.ignite.cache.query that return IgniteBiPredicate

Modifier and Type	Method and Description
IgniteBiPredicate<K,V>	ScanQuery.getFilter() Gets filter.

Methods in org.apache.ignite.cache.query with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
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 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.

Uses of IgniteBiPredicate in org.apache.ignite.compute.gridify

Subinterfaces of IgniteBiPredicate in org.apache.ignite.compute.gridify

Modifier and Type	Interface and Description
interface	GridifyNodeFilter Predicate node filter.

Uses of IgniteBiPredicate in org.apache.ignite.events

Methods in org.apache.ignite.events that return IgniteBiPredicate

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.

Constructors in org.apache.ignite.events with parameters of type IgniteBiPredicate

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)

Uses of IgniteBiPredicate in org.apache.ignite.messaging

Classes in org.apache.ignite.messaging that implement IgniteBiPredicate

Modifier and Type	Class and Description
class	MessagingListenActor<T> Convenience actor-base adapter for IgniteMessaging.localListen(Object, IgniteBiPredicate) method.

Uses of IgniteBiPredicate in org.apache.ignite.ml.dataset

Methods in org.apache.ignite.ml.dataset with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
DatasetBuilder<K,V>	DatasetBuilder.withFilter(IgniteBiPredicate<K,V> filterToAdd) Returns new instance of DatasetBuilder using conjunction of internal filter and filterToAdd.

Uses of IgniteBiPredicate in org.apache.ignite.ml.dataset.impl.cache

Methods in org.apache.ignite.ml.dataset.impl.cache with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
DatasetBuilder<K,V>	CacheBasedDatasetBuilder.withFilter(IgniteBiPredicate<K,V> filterToAdd) Returns new instance of DatasetBuilder using conjunction of internal filter and filterToAdd.

Constructors in org.apache.ignite.ml.dataset.impl.cache with parameters of type IgniteBiPredicate

Constructor and Description
CacheBasedDataset(Ignite ignite, IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter, IgniteCache<Integer,C> datasetCache, PartitionDataBuilder<K,V,C,D> partDataBuilder, UUID datasetId) Constructs a new instance of dataset based on Ignite Cache, which is used as upstream and as reliable storage for partition context as well.
CacheBasedDatasetBuilder(Ignite ignite, IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter) Constructs a new instance of cache based dataset builder that makes CacheBasedDataset.

Uses of IgniteBiPredicate in org.apache.ignite.ml.dataset.impl.cache.util

Methods in org.apache.ignite.ml.dataset.impl.cache.util with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
static <K,V,C extends Serializable,D extends AutoCloseable> D	ComputeUtils.getData(Ignite ignite, String upstreamCacheName, IgniteBiPredicate<K,V> filter, String datasetCacheName, UUID datasetId, int part, PartitionDataBuilder<K,V,C,D> partDataBuilder) Extracts partition data from the local storage, if it's not found in local storage recovers this data from a partition upstream and context.
static <K,V,C extends Serializable> void	ComputeUtils.initContext(Ignite ignite, String upstreamCacheName, IgniteBiPredicate<K,V> filter, String datasetCacheName, PartitionContextBuilder<K,V,C> ctxBuilder, int retries) Initializes partition context by loading it from a partition upstream.
static <K,V,C extends Serializable> void	ComputeUtils.initContext(Ignite ignite, String upstreamCacheName, IgniteBiPredicate<K,V> filter, String datasetCacheName, PartitionContextBuilder<K,V,C> ctxBuilder, int retries, int interval) Initializes partition context by loading it from a partition upstream.

Uses of IgniteBiPredicate in org.apache.ignite.ml.dataset.impl.local

Methods in org.apache.ignite.ml.dataset.impl.local with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
DatasetBuilder<K,V>	LocalDatasetBuilder.withFilter(IgniteBiPredicate<K,V> filterToAdd) Returns new instance of DatasetBuilder using conjunction of internal filter and filterToAdd.

Constructors in org.apache.ignite.ml.dataset.impl.local with parameters of type IgniteBiPredicate

Constructor and Description
LocalDatasetBuilder(Map<K,V> upstreamMap, IgniteBiPredicate<K,V> filter, int partitions) Constructs a new instance of local dataset builder that makes LocalDataset.

Uses of IgniteBiPredicate in org.apache.ignite.ml.selection.cv

Methods in org.apache.ignite.ml.selection.cv with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
double[]	CrossValidation.score(DatasetTrainer<M,L> trainer, Metric<L> scoreCalculator, Ignite ignite, IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, int cv) Computes cross-validated metrics.
CrossValidationResult	CrossValidation.score(DatasetTrainer<M,L> trainer, Metric<L> scoreCalculator, Ignite ignite, IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, int cv, ParamGrid paramGrid) Computes cross-validated metrics with a passed parameter grid.
double[]	CrossValidation.score(DatasetTrainer<M,L> trainer, Metric<L> scoreCalculator, Ignite ignite, IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, UniformMapper<K,V> mapper, int cv) Computes cross-validated metrics.
double[]	CrossValidation.score(DatasetTrainer<M,L> trainer, Metric<L> scoreCalculator, Map<K,V> upstreamMap, IgniteBiPredicate<K,V> filter, int parts, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, int cv) Computes cross-validated metrics.
double[]	CrossValidation.score(DatasetTrainer<M,L> trainer, Metric<L> scoreCalculator, Map<K,V> upstreamMap, IgniteBiPredicate<K,V> filter, int parts, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, UniformMapper<K,V> mapper, int cv) Computes cross-validated metrics.

Uses of IgniteBiPredicate in org.apache.ignite.ml.selection.scoring.cursor

Constructors in org.apache.ignite.ml.selection.scoring.cursor with parameters of type IgniteBiPredicate

Constructor and Description
CacheBasedLabelPairCursor(IgniteCache<K,V> upstreamCache, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, Model<Vector,L> mdl) Constructs a new instance of cache based truth with prediction cursor.
LocalLabelPairCursor(Map<K,V> upstreamMap, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, Model<Vector,L> mdl) Constructs a new instance of local truth with prediction cursor.

Uses of IgniteBiPredicate in org.apache.ignite.ml.selection.scoring.evaluator

Methods in org.apache.ignite.ml.selection.scoring.evaluator with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
static <L,K,V> double	Evaluator.evaluate(IgniteCache<K,V> dataCache, IgniteBiPredicate<K,V> filter, Model<Vector,L> mdl, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor, Accuracy<L> metric) Computes the given metric on the given cache.

Uses of IgniteBiPredicate in org.apache.ignite.ml.selection.split

Methods in org.apache.ignite.ml.selection.split that return IgniteBiPredicate

Modifier and Type	Method and Description
IgniteBiPredicate<K,V>	TrainTestSplit.getTestFilter()
IgniteBiPredicate<K,V>	TrainTestSplit.getTrainFilter()

Constructors in org.apache.ignite.ml.selection.split with parameters of type IgniteBiPredicate

Constructor and Description
TrainTestSplit(IgniteBiPredicate<K,V> trainFilter, IgniteBiPredicate<K,V> testFilter) Constructs a new instance of train test split.
TrainTestSplit(IgniteBiPredicate<K,V> trainFilter, IgniteBiPredicate<K,V> testFilter) Constructs a new instance of train test split.

Uses of IgniteBiPredicate in org.apache.ignite.ml.trainers

Methods in org.apache.ignite.ml.trainers with parameters of type IgniteBiPredicate

Modifier and Type	Method and Description
<K,V> M	DatasetTrainer.fit(Ignite ignite, IgniteCache<K,V> cache, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor) Trains model based on the specified data.
<K,V> M	DatasetTrainer.fit(Map<K,V> data, IgniteBiPredicate<K,V> filter, int parts, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor) Trains model based on the specified data.
<K,V> M	DatasetTrainer.update(M mdl, Ignite ignite, IgniteCache<K,V> cache, IgniteBiPredicate<K,V> filter, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor) Gets state of model in arguments, update in according to new data and return new model.
<K,V> M	DatasetTrainer.update(M mdl, Map<K,V> data, IgniteBiPredicate<K,V> filter, int parts, IgniteBiFunction<K,V,Vector> featureExtractor, IgniteBiFunction<K,V,L> lbExtractor) Gets state of model in arguments, update in according to new data and return new model.

Uses of IgniteBiPredicate in org.apache.ignite.spi

Methods in org.apache.ignite.spi with parameters of type IgniteBiPredicate

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.

Uses of IgniteBiPredicate in org.apache.ignite.tensorflow.cluster

Classes in org.apache.ignite.tensorflow.cluster that implement IgniteBiPredicate

Modifier and Type	Class and Description
class	TensorFlowClusterGateway TensorFlow cluster gateway that allows to subscribe on changes in cluster configuration.