Uses of Interface
org.apache.ignite.lang.IgnitePredicate

Packages that use IgnitePredicate

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.cluster	Contains cluster-related classes.
org.apache.ignite.configuration	Contains configuration-related classes.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.client.marshaller.jdk
org.apache.ignite.internal.cluster
org.apache.ignite.internal.managers.deployment	TODO.
org.apache.ignite.internal.managers.discovery	TODO.
org.apache.ignite.internal.managers.eventstorage	TODO.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
org.apache.ignite.internal.processors.cache.persistence
org.apache.ignite.internal.processors.cache.persistence.metastorage
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cluster
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.igfs	Contains high performance file system processor.
org.apache.ignite.internal.processors.platform
org.apache.ignite.internal.processors.platform.cluster
org.apache.ignite.internal.processors.platform.events
org.apache.ignite.internal.processors.platform.utils
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.processors.session	Session processing package to guarantee reuse of same session object on the same node.
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.lang
org.apache.ignite.internal.util.lang.gridfunc	Contains utilities classes for GridFunc.
org.apache.ignite.internal.util.nio	NIO server interfaces and common utility classes for NIO.
org.apache.ignite.internal.util.typedef	Contains typedefs definitions for frequently used classes.
org.apache.ignite.marshaller	Contains various supported marshallers.
org.apache.ignite.marshaller.jdk	Contains JDK java.io based marshaller.
org.apache.ignite.services	Contains main Managed Services APIs.
org.apache.ignite.spi.discovery.tcp.internal	Contains internal implementation.
org.apache.ignite.spi.eventstorage	Contains APIs for event storage SPI.
org.apache.ignite.spi.eventstorage.memory	Contains default in-memory implementation for event storage SPI.
org.apache.ignite.util

Uses of IgnitePredicate in org.apache.ignite

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

Modifier and Type	Method and Description
void	IgniteEvents.localListen(IgnitePredicate<? extends Event> lsnr, int... types) Adds an event listener for local events.
<T extends Event> Collection<T>	IgniteEvents.localQuery(IgnitePredicate<T> p, int... types) Queries local node for events using passed-in predicate filter for event selection.
<T extends Event> UUID	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> UUID	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).
<T extends Event> IgniteFuture<UUID>	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> IgniteFuture<UUID>	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).
<T extends Event> List<T>	IgniteEvents.remoteQuery(IgnitePredicate<T> p, long timeout, int... types) Queries nodes in this cluster group for events using passed in predicate filter for event selection.
<T extends Event> IgniteFuture<List<T>>	IgniteEvents.remoteQueryAsync(IgnitePredicate<T> p, long timeout, int... types) Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.
boolean	IgniteEvents.stopLocalListen(IgnitePredicate<? extends Event> lsnr, int... types) Removes local event listener.
<T extends Event> T	IgniteEvents.waitForLocal(IgnitePredicate<T> filter, int... types) Waits for the specified events.
<T extends Event> IgniteFuture<T>	IgniteEvents.waitForLocalAsync(IgnitePredicate<T> filter, int... types) Create future to wait for the specified events.

Uses of IgnitePredicate in org.apache.ignite.cluster

Methods in org.apache.ignite.cluster that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<ClusterNode>	ClusterGroup.predicate() Gets predicate that defines a subset of nodes for this cluster group.

Methods in org.apache.ignite.cluster with parameters of type IgnitePredicate

Modifier and Type	Method and Description
ClusterGroup	ClusterGroup.forPredicate(IgnitePredicate<ClusterNode> p) Creates a new cluster group which includes all nodes that pass the given predicate filter.

Uses of IgnitePredicate in org.apache.ignite.configuration

Classes in org.apache.ignite.configuration that implement IgnitePredicate

Modifier and Type	Class and Description
static class	CacheConfiguration.IgniteAllNodesPredicate Filter that accepts all nodes.

Fields in org.apache.ignite.configuration declared as IgnitePredicate

Modifier and Type	Field and Description
static IgnitePredicate<ClusterNode>	CacheConfiguration.ALL_NODES Filter that accepts all nodes.

Methods in org.apache.ignite.configuration that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<ClusterNode>	CacheConfiguration.getNodeFilter() Gets filter which determines on what nodes the cache should be started.
IgnitePredicate<ClusterNode>	CollectionConfiguration.getNodeFilter()

Methods in org.apache.ignite.configuration that return types with arguments of type IgnitePredicate

Modifier and Type	Method and Description
Map<IgnitePredicate<? extends Event>,int[]>	IgniteConfiguration.getLocalEventListeners() Gets map of pre-configured local event listeners.

Methods in org.apache.ignite.configuration with parameters of type IgnitePredicate

Modifier and Type	Method and Description
CacheConfiguration<K,V>	CacheConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter) Sets filter which determines on what nodes the cache should be started.
CollectionConfiguration	CollectionConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)

Method parameters in org.apache.ignite.configuration with type arguments of type IgnitePredicate

Modifier and Type	Method and Description
IgniteConfiguration	IgniteConfiguration.setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs) Sets map of pre-configured local event listeners.

Uses of IgnitePredicate in org.apache.ignite.internal

Methods in org.apache.ignite.internal that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<String>	MarshallerContextImpl.classNameFilter() Returns class name filter.
IgnitePredicate<ClusterNode>	GridTaskSessionImpl.getTopologyPredicate()
IgnitePredicate<ClusterNode>	GridJobExecuteRequest.getTopologyPredicate()

Methods in org.apache.ignite.internal with parameters of type IgnitePredicate

Modifier and Type	Method and Description
Collection<IgniteInternalCache<?,?>>	IgniteEx.cachesx(IgnitePredicate<? super IgniteInternalCache<?,?>>... p) Gets configured cache instance that satisfy all provided predicates including non-public caches.
Collection<IgniteInternalCache<?,?>>	IgniteKernal.cachesx(IgnitePredicate<? super IgniteInternalCache<?,?>>[] p) Gets configured cache instance that satisfy all provided predicates including non-public caches.
void	IgniteEventsImpl.localListen(IgnitePredicate<? extends Event> lsnr, int[] types) Adds an event listener for local events.
<T extends Event> Collection<T>	IgniteEventsImpl.localQuery(IgnitePredicate<T> p, int... types) Queries local node for events using passed-in predicate filter for event selection.
<T extends Event> UUID	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> UUID	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).
<T extends Event> IgniteFuture<UUID>	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> IgniteFuture<UUID>	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).
<T extends Event> List<T>	IgniteEventsImpl.remoteQuery(IgnitePredicate<T> p, long timeout, int... types) Queries nodes in this cluster group for events using passed in predicate filter for event selection.
<T extends Event> IgniteFuture<List<T>>	IgniteEventsImpl.remoteQueryAsync(IgnitePredicate<T> p, long timeout, int... types) Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.
boolean	IgniteEventsImpl.stopLocalListen(IgnitePredicate<? extends Event> lsnr, int... types) Removes local event listener.
<T extends Event> T	IgniteEventsImpl.waitForLocal(IgnitePredicate<T> filter, int... types) Waits for the specified events.
<T extends Event> IgniteFuture<T>	IgniteEventsImpl.waitForLocalAsync(IgnitePredicate<T> filter, int... types) Create future to wait for the specified events.

Constructors in org.apache.ignite.internal with parameters of type IgnitePredicate

Constructor and Description
GridJobExecuteRequest(IgniteUuid sesId, IgniteUuid jobId, String taskName, String userVer, String taskClsName, byte[] jobBytes, ComputeJob job, long startTaskTime, long timeout, Collection<UUID> top, IgnitePredicate<ClusterNode> topPred, byte[] topPredBytes, byte[] siblingsBytes, Collection<ComputeJobSibling> siblings, byte[] sesAttrsBytes, Map<Object,Object> sesAttrs, byte[] jobAttrsBytes, Map<? extends Serializable,? extends Serializable> jobAttrs, String cpSpi, IgniteUuid clsLdrId, DeploymentMode depMode, boolean dynamicSiblings, Map<UUID,IgniteUuid> ldrParticipants, boolean forceLocDep, boolean sesFullSup, boolean internal, UUID subjId, int[] cacheIds, int part, AffinityTopologyVersion topVer, String execName)
GridKernalContextImpl(GridLoggerProxy log, IgniteEx grid, IgniteConfiguration cfg, GridKernalGateway gw, ExecutorService utilityCachePool, ExecutorService execSvc, ExecutorService svcExecSvc, ExecutorService sysExecSvc, StripedExecutor stripedExecSvc, ExecutorService p2pExecSvc, ExecutorService mgmtExecSvc, ExecutorService igfsExecSvc, StripedExecutor dataStreamExecSvc, ExecutorService restExecSvc, ExecutorService affExecSvc, ExecutorService idxExecSvc, IgniteStripedThreadPoolExecutor callbackExecSvc, ExecutorService qryExecSvc, ExecutorService schemaExecSvc, Map<String,? extends ExecutorService> customExecSvcs, List<PluginProvider> plugins, IgnitePredicate<String> clsFilter) Creates new kernal context.
GridTaskSessionImpl(UUID taskNodeId, String taskName, GridDeployment dep, String taskClsName, IgniteUuid sesId, Collection<UUID> top, IgnitePredicate<ClusterNode> topPred, long startTime, long endTime, Collection<ComputeJobSibling> siblings, Map<Object,Object> attrs, GridKernalContext ctx, boolean fullSup, boolean internal, UUID subjId, String execName)
MarshallerContextImpl(Collection<PluginProvider> plugins, IgnitePredicate<String> clsFilter) Initializes context.

Uses of IgnitePredicate in org.apache.ignite.internal.client.marshaller.jdk

Constructors in org.apache.ignite.internal.client.marshaller.jdk with parameters of type IgnitePredicate

Constructor and Description
GridClientJdkMarshaller(IgnitePredicate<String> clsFilter)

Uses of IgnitePredicate in org.apache.ignite.internal.cluster

Fields in org.apache.ignite.internal.cluster declared as IgnitePredicate

Modifier and Type	Field and Description
protected IgnitePredicate<ClusterNode>	ClusterGroupAdapter.p Cluster group predicate.

Methods in org.apache.ignite.internal.cluster that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<ClusterNode>	ClusterGroupAdapter.predicate() Gets predicate that defines a subset of nodes for this cluster group.
IgnitePredicate<ClusterNode>	IgniteClusterAsyncImpl.predicate() Gets predicate that defines a subset of nodes for this cluster group.

Methods in org.apache.ignite.internal.cluster with parameters of type IgnitePredicate

Modifier and Type	Method and Description
ClusterGroup	ClusterGroupAdapter.forPredicate(IgnitePredicate<ClusterNode> p) Creates a new cluster group which includes all nodes that pass the given predicate filter.
ClusterGroup	IgniteClusterAsyncImpl.forPredicate(IgnitePredicate<ClusterNode> p) Creates a new cluster group which includes all nodes that pass the given predicate filter.

Constructors in org.apache.ignite.internal.cluster with parameters of type IgnitePredicate

Constructor and Description
ClusterGroupAdapter(GridKernalContext ctx, UUID subjId, IgnitePredicate<ClusterNode> p)

Uses of IgnitePredicate in org.apache.ignite.internal.managers.deployment

Methods in org.apache.ignite.internal.managers.deployment with parameters of type IgnitePredicate

Modifier and Type	Method and Description
Map<String,Class<? extends ComputeTask<?,?>>>	GridDeploymentManager.findAllTasks(IgnitePredicate<? super Class<? extends ComputeTask<?,?>>>... p)
GridDeployment	GridDeploymentManager.getGlobalDeployment(DeploymentMode depMode, String rsrcName, String clsName, String userVer, UUID sndNodeId, IgniteUuid clsLdrId, Map<UUID,IgniteUuid> participants, IgnitePredicate<ClusterNode> nodeFilter)

Uses of IgnitePredicate in org.apache.ignite.internal.managers.discovery

Methods in org.apache.ignite.internal.managers.discovery with parameters of type IgnitePredicate

Modifier and Type	Method and Description
void	GridDiscoveryManager.addCacheGroup(CacheGroupDescriptor grpDesc, IgnitePredicate<ClusterNode> filter, CacheMode cacheMode)
Collection<ClusterNode>	GridDiscoveryManager.nodes(Collection<UUID> ids, IgnitePredicate<UUID>... p) Gets collection of node for given node IDs and predicates.

Uses of IgnitePredicate in org.apache.ignite.internal.managers.eventstorage

Methods in org.apache.ignite.internal.managers.eventstorage with parameters of type IgnitePredicate

Modifier and Type	Method and Description
void	GridEventStorageManager.addLocalEventListener(IgnitePredicate<? extends Event> lsnr, int[] types) Adds local user event listener.
<T extends Event> Collection<T>	GridEventStorageManager.localEvents(IgnitePredicate<T> p)
<T extends Event> IgniteInternalFuture<List<T>>	GridEventStorageManager.remoteEventsAsync(IgnitePredicate<T> p, Collection<? extends ClusterNode> nodes, long timeout)
boolean	GridEventStorageManager.removeLocalEventListener(IgnitePredicate<? extends Event> lsnr, int... types) Removes user listener for specified events, if any.
<T extends Event> IgniteInternalFuture<T>	GridEventStorageManager.waitForEvent(IgnitePredicate<T> p, int... types)

Uses of IgnitePredicate in org.apache.ignite.internal.processors.affinity

Methods in org.apache.ignite.internal.processors.affinity with parameters of type IgnitePredicate

Modifier and Type	Method and Description
Object	GridAffinityProcessor.similaryAffinityKey(AffinityFunction aff, IgnitePredicate<ClusterNode> nodeFilter, int backups, int parts)

Constructors in org.apache.ignite.internal.processors.affinity with parameters of type IgnitePredicate

Constructor and Description
GridAffinityAssignmentCache(GridKernalContext ctx, String cacheOrGrpName, int grpId, AffinityFunction aff, IgnitePredicate<ClusterNode> nodeFilter, int backups, boolean locCache, boolean persistentCache) Constructs affinity cached calculations.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.cache

Subinterfaces of IgnitePredicate in org.apache.ignite.internal.processors.cache

Modifier and Type	Interface and Description
interface	CacheEntryPredicate

Classes in org.apache.ignite.internal.processors.cache that implement IgnitePredicate

Modifier and Type	Class and Description
class	CacheEntryPredicateAdapter
class	CacheEntryPredicateContainsValue
class	CacheEntryPredicateHasValue
class	CacheEntryPredicateNoValue
class	CacheEntrySerializablePredicate

Fields in org.apache.ignite.internal.processors.cache declared as IgnitePredicate

Modifier and Type	Field and Description
static IgnitePredicate	GridCacheUtils.FILTER_NEAR_CACHE_ENTRY Write filter.
protected IgnitePredicate<GridCacheEntryInfo>	GridCachePreloaderAdapter.preloadPred Preload predicate.
static IgnitePredicate	GridCacheUtils.READ_FILTER Read filter.
static IgnitePredicate	GridCacheUtils.READ_FILTER_COLOCATED Read filter.
static IgnitePredicate	GridCacheUtils.READ_FILTER_NEAR Read filter.
static IgnitePredicate	GridCacheUtils.WRITE_FILTER Write filter.
static IgnitePredicate	GridCacheUtils.WRITE_FILTER_COLOCATED Write filter.
static IgnitePredicate	GridCacheUtils.WRITE_FILTER_NEAR Write filter.

Methods in org.apache.ignite.internal.processors.cache that return IgnitePredicate

Modifier and Type	Method and Description
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]	GridCacheUtils.empty()
IgnitePredicate<ClusterNode>	CacheGroupContext.nodeFilter()
IgnitePredicate<GridCacheEntryInfo>	GridCachePreloaderAdapter.preloadPredicate()
IgnitePredicate<GridCacheEntryInfo>	GridCachePreloader.preloadPredicate()
static IgnitePredicate<IgniteTxEntry>	GridCacheUtils.reads()
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]	GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p)
static IgnitePredicate<IgniteTxEntry>	GridCacheUtils.writes()

Methods in org.apache.ignite.internal.processors.cache with parameters of type IgnitePredicate

Modifier and Type	Method and Description
static boolean	GridCacheUtils.affinityNode(ClusterNode node, IgnitePredicate<ClusterNode> filter)
<E> boolean	GridCacheContext.isAll(E e, IgnitePredicate<? super E>[] p) Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
<K1,V1> boolean	GridCacheContext.isAll(GridCacheEntryEx e, IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p) Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
void	GridCachePreloaderAdapter.preloadPredicate(IgnitePredicate<GridCacheEntryInfo> preloadPred)
void	GridCachePreloader.preloadPredicate(IgnitePredicate<GridCacheEntryInfo> p)
protected boolean	GridCacheMapEntry.storeValue(CacheObject val, long expireTime, GridCacheVersion ver, CacheDataRow oldRow, IgnitePredicate<CacheDataRow> predicate) Stores value in offheap.
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]	GridCacheContext.vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p)

Constructors in org.apache.ignite.internal.processors.cache with parameters of type IgnitePredicate

Constructor and Description
GridCacheIterator(GridCacheContext<K,V> cctx, Iterable<? extends javax.cache.Cache.Entry<K,V>> c, IgniteClosure<javax.cache.Cache.Entry<K,V>,T> trans, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
GridCacheValueCollection(GridCacheContext<K,V> ctx, Collection<? extends javax.cache.Cache.Entry<K,V>> c, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)

Uses of IgnitePredicate in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type IgnitePredicate

Modifier and Type	Method and Description
void	GridDhtPreloader.preloadPredicate(IgnitePredicate<GridCacheEntryInfo> preloadPred)

Uses of IgnitePredicate in org.apache.ignite.internal.processors.cache.persistence

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type IgnitePredicate

Modifier and Type	Method and Description
void	GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(WALIterator it, IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate, IgnitePredicate<DataEntry> entryPredicate, Map<T2<Integer,Integer>,T2<Integer,Long>> partStates) Apply update from some iterator and with specific filters.
void	GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(WALIterator it, IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate, IgnitePredicate<DataEntry> entryPredicate, Map<T2<Integer,Integer>,T2<Integer,Long>> partStates) Apply update from some iterator and with specific filters.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.cache.persistence.metastorage

Methods in org.apache.ignite.internal.processors.cache.persistence.metastorage with parameters of type IgnitePredicate

Modifier and Type	Method and Description
Map<String,? extends Serializable>	ReadOnlyMetastorage.readForPredicate(IgnitePredicate<String> keyPred) Read all keys matching provided predicate.
Map<String,? extends Serializable>	MetaStorage.readForPredicate(IgnitePredicate<String> keyPred) Read all keys matching provided predicate.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.cache.transactions

Constructors in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgnitePredicate

Constructor and Description
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap, IgnitePredicate<IgniteTxEntry> filter)

Uses of IgnitePredicate in org.apache.ignite.internal.processors.cluster

Methods in org.apache.ignite.internal.processors.cluster with parameters of type IgnitePredicate

Modifier and Type	Method and Description
List<ClusterNode>	BaselineTopology.createBaselineView(List<ClusterNode> aliveNodes, IgnitePredicate<ClusterNode> nodeFilter)

Uses of IgnitePredicate in org.apache.ignite.internal.processors.continuous

Methods in org.apache.ignite.internal.processors.continuous with parameters of type IgnitePredicate

Modifier and Type	Method and Description
UUID	GridContinuousProcessor.registerStaticRoutine(String cacheName, javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr, CacheEntryEventSerializableFilter rmtFilter, IgnitePredicate<ClusterNode> prjPred) Registers routine info to be sent in discovery data during this node join (to be used for internal queries started from client nodes).
IgniteInternalFuture<UUID>	GridContinuousProcessor.startRoutine(GridContinuousHandler hnd, boolean locOnly, int bufSize, long interval, boolean autoUnsubscribe, IgnitePredicate<ClusterNode> prjPred)

Uses of IgnitePredicate in org.apache.ignite.internal.processors.igfs

Classes in org.apache.ignite.internal.processors.igfs that implement IgnitePredicate

Modifier and Type	Class and Description
class	IgfsNodePredicate IGFS node predicate.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.platform

Subinterfaces of IgnitePredicate in org.apache.ignite.internal.processors.platform

Modifier and Type	Interface and Description
interface	PlatformEventFilterListener Platform event filter and listener.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.platform.cluster

Subinterfaces of IgnitePredicate in org.apache.ignite.internal.processors.platform.cluster

Modifier and Type	Interface and Description
interface	PlatformClusterNodeFilter Platform cluster node filter marker interface.

Classes in org.apache.ignite.internal.processors.platform.cluster that implement IgnitePredicate

Modifier and Type	Class and Description
class	PlatformClusterNodeFilterImpl Interop cluster node filter.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.platform.events

Classes in org.apache.ignite.internal.processors.platform.events that implement IgnitePredicate

Modifier and Type	Class and Description
class	PlatformEventFilterListenerImpl Platform event filter.
class	PlatformLocalEventListener Platform local event filter.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.platform.utils

Methods in org.apache.ignite.internal.processors.platform.utils with parameters of type IgnitePredicate

Modifier and Type	Method and Description
static <T> void	PlatformUtils.writeCollection(BinaryRawWriterEx writer, Collection<T> col, PlatformWriterClosure<T> writeClo, IgnitePredicate<T> filter) Write collection to the writer.
static <T> void	PlatformUtils.writeNullableCollection(BinaryRawWriterEx writer, Collection<T> col, PlatformWriterClosure<T> writeClo, IgnitePredicate<T> filter) Write collection to the writer.

Uses of IgnitePredicate in org.apache.ignite.internal.processors.service

Methods in org.apache.ignite.internal.processors.service that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<ClusterNode>	GridServiceAssignments.nodeFilter()

Uses of IgnitePredicate in org.apache.ignite.internal.processors.session

Methods in org.apache.ignite.internal.processors.session with parameters of type IgnitePredicate

Modifier and Type	Method and Description
GridTaskSessionImpl	GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId, UUID taskNodeId, String taskName, GridDeployment dep, String taskClsName, Collection<UUID> top, IgnitePredicate<ClusterNode> topPred, long startTime, long endTime, Collection<ComputeJobSibling> siblings, Map<Object,Object> attrs, boolean fullSup, boolean internal, UUID subjId, String execName)

Uses of IgnitePredicate in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util that return IgnitePredicate

Modifier and Type	Method and Description
static <T> IgnitePredicate<T>	F0.and(IgnitePredicate<? super T>[] p1, IgnitePredicate<? super T>... p2) Get a predicate (non peer-deployable) that evaluates to true if each of its component predicates evaluates to true.
static <T> IgnitePredicate<T>	F0.and(IgnitePredicate<? super T> p, IgnitePredicate<? super T>... ps) Get a predicate (not peer-deployable) that evaluates to true if each of its component predicates evaluates to true.
static <T> IgnitePredicate<T>	F0.contains(Collection<T> c) Provides predicate (not peer-deployable) which returns true if it receives an element that is contained in the passed in collection.
static <T> IgnitePredicate<T>	F0.equalTo(T target) Gets predicate (not perr-deployable) that evaluates to true if its free variable is equal to target or both are null.
static <T> IgnitePredicate<T>	F0.in(Collection<? extends T> c) Gets predicate (not peer-deployable) that returns true if its free variable is contained in given collection.
static <T> IgnitePredicate<T>	F0.not(IgnitePredicate<? super T>... p) Negates given predicates.
static <T> IgnitePredicate<T>	F0.notContains(Collection<T> c) Provides predicate (not peer-deployable) which returns true if it receives an element that is not contained in the passed in collection.
static <T> IgnitePredicate<T>	F0.notEqualTo(T target) Gets predicate (not peer-deployable) that evaluates to true if its free variable is not equal to target or both are null.
static <T> IgnitePredicate<T>	F0.notIn(Collection<? extends T> c) Gets predicate (not peer-deployable) that returns true if its free variable is not contained in given collection.

Methods in org.apache.ignite.internal.util with parameters of type IgnitePredicate

Modifier and Type	Method and Description
static <T> IgnitePredicate<T>	F0.and(IgnitePredicate<? super T>[] p1, IgnitePredicate<? super T>... p2) Get a predicate (non peer-deployable) that evaluates to true if each of its component predicates evaluates to true.
static <T> IgnitePredicate<T>	F0.and(IgnitePredicate<? super T>[] p1, IgnitePredicate<? super T>... p2) Get a predicate (non peer-deployable) that evaluates to true if each of its component predicates evaluates to true.
static <T> IgnitePredicate<T>	F0.and(IgnitePredicate<? super T> p, IgnitePredicate<? super T>... ps) Get a predicate (not peer-deployable) that evaluates to true if each of its component predicates evaluates to true.
static <T> IgnitePredicate<T>	F0.and(IgnitePredicate<? super T> p, IgnitePredicate<? super T>... ps) Get a predicate (not peer-deployable) that evaluates to true if each of its component predicates evaluates to true.
static <T extends R,R> List<R>	IgniteUtils.arrayList(Collection<T> c, IgnitePredicate<? super T>... p)
static <T extends R,R> List<R>	IgniteUtils.arrayList(Iterable<T> c, int cap, IgnitePredicate<? super T>... p)
boolean	GridAtomicInteger.checkAndSet(IgnitePredicate<Integer> p, int update) Atomically updates value only if passed in predicate returns true.
boolean	GridAtomicLong.checkAndSet(IgnitePredicate<Long> p, long update) Atomically updates value only if passed in predicate returns true.
static String	GridDebug.dumpWithReset(ConcurrentLinkedQueue<GridDebug.Item> q2, IgnitePredicate<GridDebug.Item> filter) Dump existing queue to stdout and atomically replace it with given.
static Class<?>	IgniteUtils.forName(String clsName, ClassLoader ldr, IgnitePredicate<String> clsFilter) Gets class for provided name.
static boolean	F0.isAllNodePredicates(IgnitePredicate<?>... ps) Tests if all passed in predicates are instances of GridNodePredicate class.
N	GridConsistentHash.node(Object key, IgnitePredicate<N>... p) Gets node for a given key.
List<N>	GridConsistentHash.nodes(Object key, int cnt, IgnitePredicate<N>... p) Gets specified count of adjacent nodes for a given key.
static <T> IgnitePredicate<T>	F0.not(IgnitePredicate<? super T>... p) Negates given predicates.
static ClusterNode	IgniteUtils.oldest(Collection<ClusterNode> c, IgnitePredicate<ClusterNode> p) Gets oldest node out of collection of nodes.
static List<Integer>	IgniteUtils.toIntList(int[] arr, IgnitePredicate<Integer>... p) Converts array of integers into list.
static ClusterNode	IgniteUtils.youngest(Collection<ClusterNode> c, IgnitePredicate<ClusterNode> p) Gets youngest node out of collection of nodes.

Constructors in org.apache.ignite.internal.util with parameters of type IgnitePredicate

Constructor and Description
GridReflectionCache(IgnitePredicate<Field> fp, IgnitePredicate<Method> mp) Reflection cache with specified field and method predicates.
GridReflectionCache(IgnitePredicate<Field> fp, IgnitePredicate<Method> mp) Reflection cache with specified field and method predicates.

Uses of IgnitePredicate in org.apache.ignite.internal.util.lang

Classes in org.apache.ignite.internal.util.lang that implement IgnitePredicate

Modifier and Type	Class and Description
class	GridNodePredicate Convenient node predicate as a separate class.
class	IgnitePredicateX<E1> Convenient predicate subclass that allows for thrown grid exception.

Methods in org.apache.ignite.internal.util.lang that return IgnitePredicate

Modifier and Type	Method and Description
static <T> IgnitePredicate<T>	GridFunc.alwaysFalse() Gets predicate that always returns false.
static <T> IgnitePredicate<T>	GridFunc.alwaysTrue() Gets predicate that always returns true.
static <T> IgnitePredicate<T>	GridFunc.and(IgnitePredicate<? super T>... ps) Get a predicate that evaluates to true if each of its component predicates evaluates to true.
static <K,V> IgnitePredicate<javax.cache.Cache.Entry<K,V>>	GridFunc.cacheHasPeekValue() Gets predicate which returns true if entry has peek value.
static <T> IgnitePredicate<T>	GridFunc.contains(Collection<T> c) Provides predicate which returns true if it receives an element that is contained in the passed in collection.
static <T> IgnitePredicate<T>	GridFunc.equalTo(T target) Deprecated.
static IgnitePredicate<UUID>	GridFunc.idForNodeId(UUID nodeId) Creates UUID predicate evaluating on the given node ID.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.localNode(UUID locNodeId) Gets predicate that evaluates to true only for given local node ID.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.nodeForNodeId(UUID nodeId) Creates grid node predicate evaluating on the given node ID.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.nodeForNodeIds(Collection<UUID> nodeIds) Creates grid node predicate evaluating on the given node IDs.
static IgnitePredicate<ClusterNode>	GridFunc.nodeForNodes(ClusterNode... nodes) Creates predicates that evaluates to true for each node in given collection.
static <T> IgnitePredicate<T>	GridFunc.not(IgnitePredicate<? super T>... p) Negates given predicates.
static <T> IgnitePredicate<T>	GridFunc.notContains(Collection<T> c) Provides predicate which returns true if it receives an element that is not contained in the passed in collection.
static <T> IgnitePredicate<T>	GridFunc.notEqualTo(T target) Gets predicate that evaluates to true if its free variable is not equal to target or both are null.
static <T> IgnitePredicate<T>	GridFunc.notIn(Collection<? extends T> c) Gets predicate that returns true if its free variable is not contained in given collection.
static <T> IgnitePredicate<T>	GridFunc.notNull() Gets predicate that evaluates to true if its free variable is not null.
static <T extends ClusterNode> IgnitePredicate<T>	GridFunc.remoteNodes(UUID locNodeId) Gets predicate that evaluates to false for given local node ID.

Methods in org.apache.ignite.internal.util.lang with parameters of type IgnitePredicate

Modifier and Type	Method and Description
static <T> IgnitePredicate<T>	GridFunc.and(IgnitePredicate<? super T>... ps) Get a predicate that evaluates to true if each of its component predicates evaluates to true.
static <T> Collection<T>	GridFunc.copy(Collection<T> to, Iterable<? extends T> from, IgnitePredicate<? super T>... p) Deprecated.
static <V> boolean	GridFunc.exist(Iterable<? extends V> c, IgnitePredicate<? super V>... p) Checks for existence of the element in input collection for which all provided predicates evaluate to true.
static <T> List<T>	GridFunc.filterList(List<T> c, boolean cp, IgnitePredicate<T>... p) Deprecated.
static <V> V	GridFunc.find(Iterable<? extends V> c, V dfltVal, IgnitePredicate<? super V>... p) Finds and returns first element in given collection for which any of the provided predicates evaluates to true.
static <V,Y> Y	GridFunc.find(Iterable<? extends V> c, Y dfltVal, IgniteClosure<? super V,Y> f, IgnitePredicate<? super V>... p) Deprecated.
static <V> boolean	GridFunc.forAll(Iterable<? extends V> c, IgnitePredicate<? super V>... p) Deprecated.
static <K1,K extends K1,V1,V extends V1> boolean	GridFunc.forAll(Map<K,V> m, IgnitePredicate<? super Map.Entry<K,V>>... p) Deprecated.
static <V> boolean	GridFunc.forAny(Iterable<? extends V> c, IgnitePredicate<? super V>... p) Deprecated.
static <X> void	GridFunc.forEach(Iterable<? extends X> c, IgniteInClosure<? super X> f, IgnitePredicate<? super X>... p) Deprecated.
static <X> void	GridFunc.forEach(X[] c, IgniteInClosure<? super X> f, IgnitePredicate<? super X>... p) Deprecated.
static <T> boolean	GridFunc.isAll(T t, IgnitePredicate<? super T>... p) Tests if all provided predicates evaluate to true for given value.
static boolean	GridFunc.isAlwaysFalse(IgnitePredicate p) Deprecated.
static boolean	GridFunc.isAlwaysFalse(IgnitePredicate[] p) Deprecated.
static boolean	GridFunc.isAlwaysTrue(IgnitePredicate p) Deprecated.
static boolean	GridFunc.isAlwaysTrue(IgnitePredicate[] p) Tests whether or not given set of predicates consists only of one predicate returned from GridFunc.alwaysTrue() method.
static <T> boolean	GridFunc.isAny(T t, IgnitePredicate<? super T>... p) Deprecated.
static <T1,T2> GridIterator<T2>	GridFunc.iterator(Iterable<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, IgnitePredicate<? super T1>... p) Creates and returns transforming iterator from given collection and optional filtering predicates.
static <T1,T2> Iterator<T2>	GridFunc.iterator(Iterator<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, IgnitePredicate<? super T1>... p)
static <T> GridIterator<T>	GridFunc.iterator0(Iterable<? extends T> c, boolean readOnly, IgnitePredicate<? super T>... p) Creates and returns iterator from given collection and optional filtering predicates.
static <T> Collection<T>	GridFunc.lose(Collection<T> c, boolean cp, IgnitePredicate<? super T>... p) Deprecated.
static <K,V> Map<K,V>	GridFunc.lose(Map<K,V> m, boolean cp, IgnitePredicate<? super Map.Entry<K,V>>... p) Deprecated.
static <T> IgnitePredicate<T>	GridFunc.not(IgnitePredicate<? super T>... p) Negates given predicates.
static <V> IgniteBiTuple<Collection<V>,Collection<V>>	GridFunc.partition(Iterable<? extends V> c, IgnitePredicate<? super V> p) Deprecated.
static <T> Collection<T>	GridFunc.retain(Collection<T> c, boolean cp, IgnitePredicate<? super T>... p) Retains all elements in input collection that are evaluated to true by all given predicates.
static <T> int	GridFunc.size(Collection<? extends T> c, IgnitePredicate<? super T>... p) Gets size of the given collection with provided optional predicates.
static <T> int	GridFunc.size(Iterator<? extends T> it, IgnitePredicate<? super T>... p) Gets size of the given iterator with provided optional predicates.
static <T1,T2> List<T2>	GridFunc.transformList(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, IgnitePredicate<? super T1>... p) Deprecated.
static <T> Collection<T>	GridFunc.view(Collection<T> c, IgnitePredicate<? super T>... p) Creates write-through light-weight view on given collection with provided predicates.
static <K0,K extends K0,V0,V extends V0> Map<K,V>	GridFunc.view(Map<K,V> m, IgnitePredicate<? super K>... p) Creates light-weight view on given map with provided predicates.
static <K0,K extends K0,V0,V extends V0> Map<K,V>	GridFunc.viewAsMap(Set<K> c, IgniteClosure<? super K,V> mapClo, IgnitePredicate<? super K>... p) Read-only map view of a collection.
static <T1,T2> Collection<T2>	GridFunc.viewReadOnly(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, IgnitePredicate<? super T1>... p) Creates read-only light-weight view on given collection with transformation and provided predicates.
static <K0,K extends K0,V0,V extends V0,V1> Map<K,V1>	GridFunc.viewReadOnly(Map<K,V> m, IgniteBiClosure<K,V,V1> trans, IgnitePredicate<? super K>... p) Deprecated.
static <K0,K extends K0,V0,V extends V0,V1> Map<K,V1>	GridFunc.viewReadOnly(Map<K,V> m, IgniteClosure<V,V1> trans, IgnitePredicate<? super K>... p) Read-only view on map that supports transformation of values and key filtering.

Uses of IgnitePredicate in org.apache.ignite.internal.util.lang.gridfunc

Classes in org.apache.ignite.internal.util.lang.gridfunc that implement IgnitePredicate

Modifier and Type	Class and Description
class	AlwaysFalsePredicate<E> Defines a predicate which accepts a parameter and always returns false
class	AlwaysTruePredicate<E> Defines a predicate which accepts a parameter and always returns true
class	CacheEntryHasPeekPredicate Cache entry has-peek-value predicate.
class	ContainsNodeIdsPredicate<T extends ClusterNode> Grid node predicate evaluating on the given node IDs.
class	ContainsPredicate<T> Predicate which returns true if it receives an element that is contained in the passed in collection.
class	EntryByKeyEvaluationPredicate<K,V> Predicate evaluates to true for given value.
class	EqualsClusterNodeIdPredicate<T extends ClusterNode> Creates grid node predicate evaluating on the given node ID.
class	EqualsUuidPredicate UUID equals predicate.
class	HasEqualIdPredicate<T extends ClusterNode> ClusterNode has equal id predicate.
class	HasNotEqualIdPredicate<T extends ClusterNode> ClusterNode node has NOT equal id predicate.
class	IsAllPredicate<T> Predicate that evaluates to true if each of its component preds evaluates to true.
class	IsNotAllPredicate<T> Negated predicate.
class	IsNotNullPredicate<E> Defines a predicate which checks a parameter on null.
class	NotContainsPredicate<T> Predicate that returns true if its free variable is not contained in given collection.
class	NotEqualPredicate<T> Predicate that evaluates to true if its free variable is equal to target or both are null.

Constructors in org.apache.ignite.internal.util.lang.gridfunc with parameters of type IgnitePredicate

Constructor and Description
EntryByKeyEvaluationPredicate(IgnitePredicate<? super K>... preds)
IsAllPredicate(IgnitePredicate<? super T>... preds)
IsNotAllPredicate(IgnitePredicate<? super T>... preds)
PredicateCollectionView(Collection<T> col, IgnitePredicate<? super T>... preds)
PredicateMapView(Map<K,V> map, IgnitePredicate<? super K>... preds)
PredicateSetView(Set<K> set, IgniteClosure<? super K,V> clo, IgnitePredicate<? super K>... preds)
TransformCollectionView(Collection<? extends T2> col, IgniteClosure<? super T2,T1> clos, IgnitePredicate<? super T2>... preds)
TransformFilteringIterator(Iterator<? extends T1> iter, IgniteClosure<? super T1,T2> clos, boolean readOnly, IgnitePredicate<? super T1>... preds)
TransformMapView(Map<K,V> map, IgniteClosure<V,V1> clos, IgnitePredicate<? super K>... preds)
TransformMapView2(Map<K,V> map, IgniteBiClosure<K,V,V1> clos, IgnitePredicate<? super K>... preds)

Uses of IgnitePredicate in org.apache.ignite.internal.util.nio

Methods in org.apache.ignite.internal.util.nio with parameters of type IgnitePredicate

Modifier and Type	Method and Description
IgniteInternalFuture<String>	GridNioServer.dumpNodeStats(String msg, IgnitePredicate<GridNioSession> p)
IgniteInternalFuture<String>	GridNioServer.dumpStats(String msg, IgnitePredicate<GridNioSession> p)
GridNioServer.Builder<T>	GridNioServer.Builder.skipRecoveryPredicate(IgnitePredicate<Message> skipRecoveryPred)

Uses of IgnitePredicate in org.apache.ignite.internal.util.typedef

Subinterfaces of IgnitePredicate in org.apache.ignite.internal.util.typedef

Modifier and Type	Interface and Description
interface	P1<E1> Defines alias for IgnitePredicate by extending it.
interface	PCE<K,V> Defines alias for GridPredicate<Entry<K, V>> by extending IgnitePredicate.
interface	PE Defines alias for GridPredicate<GridEvent> by extending IgnitePredicate.
interface	PN Defines alias for GridPredicate<ClusterNode> by extending IgnitePredicate.

Classes in org.apache.ignite.internal.util.typedef that implement IgnitePredicate

Modifier and Type	Class and Description
class	PX1<E1> Defines alias for IgnitePredicateX by extending it.

Uses of IgnitePredicate in org.apache.ignite.marshaller

Methods in org.apache.ignite.marshaller that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<String>	MarshallerContext.classNameFilter() Returns class name filter.
static IgnitePredicate<String>	MarshallerUtils.classNameFilter(ClassLoader clsLdr) Returns class name filter for marshaller.

Uses of IgnitePredicate in org.apache.ignite.marshaller.jdk

Constructors in org.apache.ignite.marshaller.jdk with parameters of type IgnitePredicate

Constructor and Description
JdkMarshaller(IgnitePredicate<String> clsFilter)

Uses of IgnitePredicate in org.apache.ignite.services

Fields in org.apache.ignite.services declared as IgnitePredicate

Modifier and Type	Field and Description
protected IgnitePredicate<ClusterNode>	ServiceConfiguration.nodeFilter Node filter.

Methods in org.apache.ignite.services that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<ClusterNode>	ServiceConfiguration.getNodeFilter() Gets node filter used to filter nodes on which the service will be deployed.

Methods in org.apache.ignite.services with parameters of type IgnitePredicate

Modifier and Type	Method and Description
ServiceConfiguration	ServiceConfiguration.setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter) Sets node filter used to filter nodes on which the service will be deployed.

Uses of IgnitePredicate in org.apache.ignite.spi.discovery.tcp.internal

Fields in org.apache.ignite.spi.discovery.tcp.internal declared as IgnitePredicate

Modifier and Type	Field and Description
static IgnitePredicate<TcpDiscoveryNode>	TcpDiscoveryNodesRing.VISIBLE_NODES Visible nodes filter.

Uses of IgnitePredicate in org.apache.ignite.spi.eventstorage

Methods in org.apache.ignite.spi.eventstorage with parameters of type IgnitePredicate

Modifier and Type	Method and Description
<T extends Event> Collection<T>	NoopEventStorageSpi.localEvents(IgnitePredicate<T> p) Queries locally-stored events only.
<T extends Event> Collection<T>	EventStorageSpi.localEvents(IgnitePredicate<T> p) Queries locally-stored events only.

Uses of IgnitePredicate in org.apache.ignite.spi.eventstorage.memory

Methods in org.apache.ignite.spi.eventstorage.memory that return IgnitePredicate

Modifier and Type	Method and Description
IgnitePredicate<Event>	MemoryEventStorageSpi.getFilter() Gets filter for events to be recorded.

Methods in org.apache.ignite.spi.eventstorage.memory with parameters of type IgnitePredicate

Modifier and Type	Method and Description
<T extends Event> Collection<T>	MemoryEventStorageSpi.localEvents(IgnitePredicate<T> p) Queries locally-stored events only.
MemoryEventStorageSpi	MemoryEventStorageSpi.setFilter(IgnitePredicate<Event> filter) Sets filter for events to be recorded.

Uses of IgnitePredicate in org.apache.ignite.util

Classes in org.apache.ignite.util that implement IgnitePredicate

Modifier and Type	Class and Description
class	AttributeNodeFilter Implementation of IgnitePredicate<ClusterNode> based on user attributes.