Uses of Interface
org.apache.ignite.lang.IgnitePredicate
-
-
Uses of IgnitePredicate in org.apache.ignite
Methods in org.apache.ignite with parameters of type IgnitePredicate Modifier and Type Method Description voidIgniteEvents. localListen(IgnitePredicate<? extends Event> lsnr, int... types)Adds an event listener for local events.<T extends Event>
Collection<T>IgniteEvents. localQuery(IgnitePredicate<T> p, @org.jetbrains.annotations.Nullable int... types)Queries local node for events using passed-in predicate filter for event selection.<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).<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).<T extends Event>
List<T>IgniteEvents. remoteQuery(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable 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, @org.jetbrains.annotations.Nullable int... types)Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.booleanIgniteEvents. stopLocalListen(IgnitePredicate<? extends Event> lsnr, @org.jetbrains.annotations.Nullable int... types)Removes local event listener.<T extends Event>
TIgniteEvents. waitForLocal(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Waits for the specified events.<T extends Event>
IgniteFuture<T>IgniteEvents. waitForLocalAsync(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable 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 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 Description ClusterGroupClusterGroup. 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 Description static classCacheConfiguration.IgniteAllNodesPredicateFilter that accepts all nodes.Fields in org.apache.ignite.configuration declared as IgnitePredicate Modifier and Type Field Description static IgnitePredicate<ClusterNode>CacheConfiguration. ALL_NODESFilter that accepts all nodes.Methods in org.apache.ignite.configuration that return IgnitePredicate Modifier and Type Method 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 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 Description CacheConfiguration<K,V>CacheConfiguration. setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)Sets filter which determines on what nodes the cache should be started.CollectionConfigurationCollectionConfiguration. setNodeFilter(IgnitePredicate<ClusterNode> nodeFilter)Method parameters in org.apache.ignite.configuration with type arguments of type IgnitePredicate Modifier and Type Method Description IgniteConfigurationIgniteConfiguration. setLocalEventListeners(Map<IgnitePredicate<? extends Event>,int[]> lsnrs)Sets map of pre-configured local event listeners. -
Uses of IgnitePredicate in org.apache.ignite.internal
Classes in org.apache.ignite.internal that implement IgnitePredicate Modifier and Type Class Description classSecurityAwarePredicate<E>Security aware IgnitePredicate.classSecurityCredentialsAttrFilterPredicatePredicate to filter out security credentials attribute by its name.Methods in org.apache.ignite.internal that return IgnitePredicate Modifier and Type Method Description IgnitePredicate<String>MarshallerContextImpl. classNameFilter()Returns class name filter.IgnitePredicate<ClusterNode>GridJobExecuteRequest. getTopologyPredicate()@Nullable IgnitePredicate<ClusterNode>GridTaskSessionImpl. getTopologyPredicate()Methods in org.apache.ignite.internal with parameters of type IgnitePredicate Modifier and Type Method Description Collection<IgniteInternalCache<?,?>>IgniteEx. cachesx(@Nullable 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.voidIgniteEventsImpl. localListen(IgnitePredicate<? extends Event> lsnr, int[] types)Adds an event listener for local events.<T extends Event>
Collection<T>IgniteEventsImpl. localQuery(IgnitePredicate<T> p, @org.jetbrains.annotations.Nullable int... types)Queries local node for events using passed-in predicate filter for event selection.<T extends Event>
UUIDIgniteEventsImpl. 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>
UUIDIgniteEventsImpl. 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).<T extends Event>
IgniteFuture<UUID>IgniteEventsImpl. 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>IgniteEventsImpl. 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).<T extends Event>
List<T>IgniteEventsImpl. remoteQuery(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable 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, @org.jetbrains.annotations.Nullable int... types)Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.booleanIgniteEventsImpl. stopLocalListen(IgnitePredicate<? extends Event> lsnr, @org.jetbrains.annotations.Nullable int... types)Removes local event listener.<T extends Event>
TIgniteEventsImpl. waitForLocal(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Waits for the specified events.<T extends Event>
IgniteFuture<T>IgniteEventsImpl. waitForLocalAsync(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Create future to wait for the specified events.IgniteComputeHandlerIgniteComputeHandler. withProjectionPredicate(IgnitePredicate<ClusterNode> predicate)Constructors in org.apache.ignite.internal with parameters of type IgnitePredicate Constructor Description GridJobExecuteRequest(IgniteUuid sesId, IgniteUuid jobId, String taskName, String userVer, String taskClsName, byte[] jobBytes, ComputeJob job, long startTaskTime, long timeout, @Nullable Collection<UUID> top, @Nullable 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, @org.jetbrains.annotations.Nullable int[] cacheIds, int part, @Nullable AffinityTopologyVersion topVer, @Nullable String execName)GridKernalContextImpl(GridLoggerProxy log, IgniteEx grid, IgniteConfiguration cfg, GridKernalGateway gw, List<PluginProvider> plugins, IgnitePredicate<String> clsFilter, WorkersRegistry workerRegistry, Thread.UncaughtExceptionHandler hnd, LongJVMPauseDetector pauseDetector)Creates new kernal context.GridTaskSessionImpl(UUID taskNodeId, String taskName, @Nullable GridDeployment dep, String taskClsName, IgniteUuid sesId, @Nullable Collection<UUID> top, @Nullable IgnitePredicate<ClusterNode> topPred, long startTime, long endTime, Collection<ComputeJobSibling> siblings, @Nullable Map<Object,Object> attrs, GridKernalContext ctx, boolean fullSup, boolean internal, @Nullable String execName, @Nullable SecurityContext secCtx)Constructor.MarshallerContextImpl(@Nullable Collection<PluginProvider> plugins, IgnitePredicate<String> clsFilter)Initializes context.SecurityAwarePredicate(UUID subjectId, IgnitePredicate<E> original) -
Uses of IgnitePredicate in org.apache.ignite.internal.cdc
Methods in org.apache.ignite.internal.cdc with parameters of type IgnitePredicate Modifier and Type Method Description booleanWalRecordsConsumer. onRecords(Iterator<DataEntry> entries, IgniteClosure<DataEntry,CdcEvent> transform, @Nullable IgnitePredicate<? super DataEntry> filter)Handles data entries. -
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 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 Description protected IgnitePredicate<ClusterNode>ClusterGroupAdapter. pCluster group predicate.Methods in org.apache.ignite.internal.cluster that return IgnitePredicate Modifier and Type Method 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 Description ClusterGroupClusterGroupAdapter. forPredicate(IgnitePredicate<ClusterNode> p)Creates a new cluster group which includes all nodes that pass the given predicate filter.ClusterGroupIgniteClusterAsyncImpl. 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 Description ClusterGroupAdapter(@Nullable GridKernalContext ctx, @Nullable IgnitePredicate<ClusterNode> p) -
Uses of IgnitePredicate in org.apache.ignite.internal.managers.deployment
Methods in org.apache.ignite.internal.managers.deployment that return IgnitePredicate Modifier and Type Method Description IgnitePredicate<ClusterNode>GridDeploymentMetadata. nodeFilter()Methods in org.apache.ignite.internal.managers.deployment with parameters of type IgnitePredicate Modifier and Type Method Description Map<String,Class<? extends ComputeTask<?,?>>>GridDeploymentManager. findAllTasks(@Nullable IgnitePredicate<? super Class<? extends ComputeTask<?,?>>>... p)@Nullable GridDeploymentGridDeploymentManager. getGlobalDeployment(DeploymentMode depMode, String rsrcName, String clsName, String userVer, UUID sndNodeId, IgniteUuid clsLdrId, Map<UUID,IgniteUuid> participants, @Nullable IgnitePredicate<ClusterNode> nodeFilter)voidGridDeploymentMetadata. nodeFilter(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 Description voidGridDiscoveryManager. addCacheGroup(CacheGroupDescriptor grpDesc, IgnitePredicate<ClusterNode> filter, CacheMode cacheMode)Collection<ClusterNode>GridDiscoveryManager. nodes(@Nullable 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 Description voidGridEventStorageManager. 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)booleanGridEventStorageManager. removeLocalEventListener(IgnitePredicate<? extends Event> lsnr, @org.jetbrains.annotations.Nullable int... types)Removes user listener for specified events, if any.<T extends Event>
IgniteInternalFuture<T>GridEventStorageManager. waitForEvent(@Nullable IgnitePredicate<T> p, @org.jetbrains.annotations.Nullable 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 Description ObjectGridAffinityProcessor. similaryAffinityKey(AffinityFunction aff, IgnitePredicate<ClusterNode> nodeFilter, int backups, int parts) -
Uses of IgnitePredicate in org.apache.ignite.internal.processors.cache
Subinterfaces of IgnitePredicate in org.apache.ignite.internal.processors.cache Modifier and Type Interface Description interfaceCacheEntryPredicateClasses in org.apache.ignite.internal.processors.cache that implement IgnitePredicate Modifier and Type Class Description classCacheEntryPredicateAdapterclassCacheEntryPredicateContainsValueclassCacheEntryPredicateHasValueclassCacheEntryPredicateNoValueclassCacheEntrySerializablePredicateFields in org.apache.ignite.internal.processors.cache declared as IgnitePredicate Modifier and Type Field Description static IgnitePredicate<IgniteTxEntry>GridCacheUtils. FILTER_NEAR_CACHE_ENTRYWrite filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. READ_FILTERRead filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. READ_FILTER_COLOCATEDRead filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. READ_FILTER_NEARRead filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. WRITE_FILTERWrite filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. WRITE_FILTER_COLOCATEDWrite filter.static IgnitePredicate<IgniteTxEntry>GridCacheUtils. WRITE_FILTER_NEARWrite filter.Methods in org.apache.ignite.internal.processors.cache that return IgnitePredicate Modifier and Type Method Description static <K,V>
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]GridCacheUtils. empty()IgnitePredicate<ClusterNode>CacheGroupContext. nodeFilter()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 Description static booleanGridCacheUtils. affinityNode(ClusterNode node, IgnitePredicate<ClusterNode> filter)<E> booleanGridCacheContext. isAll(E e, @Nullable IgnitePredicate<? super E>[] p)Same asGridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.protected booleanGridCacheMapEntry. storeValue(@Nullable CacheObject val, long expireTime, GridCacheVersion ver, @Nullable IgnitePredicate<CacheDataRow> predicate, @Nullable CacheDataRow row)Stores value in off-heap.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 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, @Nullable IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) -
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 Description voidGridCacheDatabaseSharedManager. applyUpdatesOnRecovery(@Nullable WALIterator it, IgniteBiPredicate<WALPointer,WALRecord> recPredicate, IgnitePredicate<DataEntry> entryPredicate)Apply update from some iterator and with specific filters.Constructors in org.apache.ignite.internal.processors.cache.persistence with parameters of type IgnitePredicate Constructor Description RestoreBinaryState(CheckpointStatus status, WALIterator iterator, long lastArchivedSegment, IgnitePredicate<Integer> cacheGroupsPredicate)RestoreLogicalState(CheckpointStatus status, WALIterator iterator, long lastArchivedSegment, IgnitePredicate<Integer> cacheGroupsPredicate, Map<GroupPartitionId,Integer> partitionRecoveryStates) -
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 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 Description List<ClusterNode>BaselineTopology. createBaselineView(Collection<ClusterNode> aliveNodes, @Nullable 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 Description UUIDGridContinuousProcessor. registerStaticRoutine(String cacheName, javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr, CacheEntryEventSerializableFilter rmtFilter, @Nullable 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, @Nullable IgnitePredicate<ClusterNode> prjPred) -
Uses of IgnitePredicate in org.apache.ignite.internal.processors.platform
Subinterfaces of IgnitePredicate in org.apache.ignite.internal.processors.platform Modifier and Type Interface Description interfacePlatformEventFilterListenerPlatform 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 Description interfacePlatformClusterNodeFilterPlatform cluster node filter marker interface.Classes in org.apache.ignite.internal.processors.platform.cluster that implement IgnitePredicate Modifier and Type Class Description classPlatformClusterNodeFilterImplInterop 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 Description classPlatformEventFilterListenerImplPlatform event filter.classPlatformLocalEventListenerPlatform 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 Description static <T> voidPlatformUtils. writeCollection(BinaryRawWriterEx writer, Collection<T> col, @Nullable PlatformWriterClosure<T> writeClo, @Nullable IgnitePredicate<T> filter)Write collection to the writer.static <T> voidPlatformUtils. writeNullableCollection(BinaryRawWriterEx writer, @Nullable Collection<T> col, @Nullable PlatformWriterClosure<T> writeClo, @Nullable 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 Description IgnitePredicate<ClusterNode>LazyServiceConfiguration. getNodeFilter()Gets node filter used to filter nodes on which the service will be deployed.Methods in org.apache.ignite.internal.processors.service with parameters of type IgnitePredicate Modifier and Type Method Description ServiceConfigurationLazyServiceConfiguration. 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.internal.processors.session
Methods in org.apache.ignite.internal.processors.session with parameters of type IgnitePredicate Modifier and Type Method Description GridTaskSessionImplGridTaskSessionProcessor. createTaskSession(IgniteUuid sesId, UUID taskNodeId, String taskName, @Nullable GridDeployment dep, String taskClsName, @Nullable Collection<UUID> top, @Nullable IgnitePredicate<ClusterNode> topPred, long startTime, long endTime, Collection<ComputeJobSibling> siblings, Map<Object,Object> attrs, boolean fullSup, boolean internal, @Nullable String execName, @Nullable SecurityContext secCtx)Creates task session. -
Uses of IgnitePredicate in org.apache.ignite.internal.processors.task
Methods in org.apache.ignite.internal.processors.task that return IgnitePredicate Modifier and Type Method Description IgnitePredicate<ClusterNode>TaskExecutionOptions. projectionPredicate()Methods in org.apache.ignite.internal.processors.task with parameters of type IgnitePredicate Modifier and Type Method Description TaskExecutionOptionsTaskExecutionOptions. withProjectionPredicate(IgnitePredicate<ClusterNode> projectionPredicate) -
Uses of IgnitePredicate in org.apache.ignite.internal.util
Methods in org.apache.ignite.internal.util that return IgnitePredicate Modifier and Type Method Description static <T> IgnitePredicate<T>F0. and(@Nullable IgnitePredicate<? super T>[] p1, @Nullable IgnitePredicate<? super T>... p2)Get a predicate (non peer-deployable) that evaluates totrueif each of its component predicates evaluates totrue.static <T> IgnitePredicate<T>F0. and(@Nullable IgnitePredicate<? super T> p, @Nullable IgnitePredicate<? super T>... ps)Get a predicate (not peer-deployable) that evaluates totrueif each of its component predicates evaluates totrue.static <T> IgnitePredicate<T>F0. contains(@Nullable Collection<T> c)Provides predicate (not peer-deployable) which returnstrueif 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 totrueif its free variable is equal totargetor both arenull.static <T> IgnitePredicate<T>F0. in(@Nullable Collection<? extends T> c)Gets predicate (not peer-deployable) that returnstrueif its free variable is contained in given collection.static <T> IgnitePredicate<T>F0. not(@Nullable IgnitePredicate<? super T>... p)Negates given predicates.static <T> IgnitePredicate<T>F0. notContains(@Nullable Collection<T> c)Provides predicate (not peer-deployable) which returnstrueif 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 totrueif its free variable is not equal totargetor both arenull.static <T> IgnitePredicate<T>F0. notIn(@Nullable Collection<? extends T> c)Gets predicate (not peer-deployable) that returnstrueif 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 Description static <T> IgnitePredicate<T>F0. and(@Nullable IgnitePredicate<? super T>[] p1, @Nullable IgnitePredicate<? super T>... p2)Get a predicate (non peer-deployable) that evaluates totrueif each of its component predicates evaluates totrue.static <T> IgnitePredicate<T>F0. and(@Nullable IgnitePredicate<? super T> p, @Nullable IgnitePredicate<? super T>... ps)Get a predicate (not peer-deployable) that evaluates totrueif each of its component predicates evaluates totrue.static <T extends R,R>
List<R>IgniteUtils. arrayList(Collection<T> c, @Nullable IgnitePredicate<? super T>... p)static <T extends R,R>
List<R>IgniteUtils. arrayList(Iterator<T> c, int cap, @Nullable IgnitePredicate<? super T>... p)static IgniteFuture<Void>IgniteUtils. broadcastToNodesWithFilterAsync(GridKernalContext kctx, IgniteRunnable job, boolean srvrsOnly, IgnitePredicate<ClusterNode> nodeFilter)Broadcasts given job to nodes that match filter.booleanGridAtomicInteger. checkAndSet(IgnitePredicate<Integer> p, int update)Atomically updates value only if passed in predicate returnstrue.booleanGridAtomicLong. checkAndSet(IgnitePredicate<Long> p, long update)Atomically updates value only if passed in predicate returnstrue.static StringGridDebug. dumpWithReset(@Nullable ConcurrentLinkedQueue<GridDebug.Item> q2, @Nullable IgnitePredicate<GridDebug.Item> filter)Dump existing queue to stdout and atomically replace it with given.static Class<?>IgniteUtils. forName(String clsName, @Nullable ClassLoader ldr, IgnitePredicate<String> clsFilter)Gets class for provided name.static Class<?>IgniteUtils. forName(String clsName, @Nullable ClassLoader ldr, IgnitePredicate<String> clsFilter, boolean useCache)Gets class for provided name.static booleanF0. isAllNodePredicates(@Nullable IgnitePredicate<?>... ps)Tests if all passed in predicates are instances ofGridNodePredicateclass.NGridConsistentHash. node(@Nullable Object key, @Nullable IgnitePredicate<N>... p)Gets node for a given key.List<N>GridConsistentHash. nodes(@Nullable Object key, int cnt, @Nullable IgnitePredicate<N>... p)Gets specified count of adjacent nodes for a given key.static <T> IgnitePredicate<T>F0. not(@Nullable IgnitePredicate<? super T>... p)Negates given predicates.static ClusterNodeIgniteUtils. oldest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)Gets oldest node out of collection of nodes.static List<Integer>IgniteUtils. toIntList(@org.jetbrains.annotations.Nullable int[] arr, IgnitePredicate<Integer>... p)Converts array of integers into list.static ClusterNodeIgniteUtils. youngest(Collection<ClusterNode> c, @Nullable IgnitePredicate<ClusterNode> p)Gets youngest node out of collection of nodes.Constructors in org.apache.ignite.internal.util with parameters of type IgnitePredicate Constructor Description GridReflectionCache(@Nullable IgnitePredicate<Field> fp, @Nullable 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 Description classGridNodePredicateConvenient node predicate as a separate class.classIgnitePredicateX<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 Description static <T> IgnitePredicate<T>GridFunc. alwaysFalse()Gets predicate that always returnsfalse.static <T> IgnitePredicate<T>GridFunc. alwaysTrue()Gets predicate that always returnstrue.static <T> IgnitePredicate<T>GridFunc. and(@Nullable IgnitePredicate<? super T>... ps)Get a predicate that evaluates totrueif each of its component predicates evaluates totrue.static <K,V>
IgnitePredicate<javax.cache.Cache.Entry<K,V>>GridFunc. cacheHasPeekValue()Gets predicate which returnstrueif entry has peek value.static <T> IgnitePredicate<T>GridFunc. contains(@Nullable Collection<T> c)Provides predicate which returnstrueif 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)CreatesUUIDpredicate evaluating on the given node ID.static <T extends ClusterNode>
IgnitePredicate<T>GridFunc. localNode(UUID locNodeId)Gets predicate that evaluates totrueonly 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(@Nullable Collection<UUID> nodeIds)Creates grid node predicate evaluating on the given node IDs.static IgnitePredicate<ClusterNode>GridFunc. nodeForNodes(ClusterNode... nodes)Creates predicates that evaluates totruefor each node in given collection.static <T> IgnitePredicate<T>GridFunc. not(@Nullable IgnitePredicate<? super T>... p)Negates given predicates.static <T> IgnitePredicate<T>GridFunc. notContains(@Nullable Collection<T> c)Provides predicate which returnstrueif 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 totrueif its free variable is not equal totargetor both arenull.static <T> IgnitePredicate<T>GridFunc. notIn(@Nullable Collection<? extends T> c)Gets predicate that returnstrueif its free variable is not contained in given collection.static <T> IgnitePredicate<T>GridFunc. notNull()Gets predicate that evaluates totrueif its free variable is notnull.static <T extends ClusterNode>
IgnitePredicate<T>GridFunc. remoteNodes(UUID locNodeId)Gets predicate that evaluates tofalsefor given local node ID.Methods in org.apache.ignite.internal.util.lang with parameters of type IgnitePredicate Modifier and Type Method Description static <T> IgnitePredicate<T>GridFunc. and(@Nullable IgnitePredicate<? super T>... ps)Get a predicate that evaluates totrueif each of its component predicates evaluates totrue.static <T> Collection<T>GridFunc. copy(Collection<T> to, Iterable<? extends T> from, @Nullable IgnitePredicate<? super T>... p)Deprecated.static <V> booleanGridFunc. exist(Iterable<? extends V> c, @Nullable IgnitePredicate<? super V>... p)Checks for existence of the element in input collection for which all provided predicates evaluate totrue.static <T> List<T>GridFunc. filterList(List<T> c, boolean cp, @Nullable IgnitePredicate<T>... p)Deprecated.static <V> VGridFunc. find(Iterable<? extends V> c, V dfltVal, @Nullable IgnitePredicate<? super V>... p)Finds and returns first element in given collection for which any of the provided predicates evaluates totrue.static <V> booleanGridFunc. forAll(Iterable<? extends V> c, @Nullable IgnitePredicate<? super V>... p)Deprecated.static <K1,K extends K1,V1,V extends V1>
booleanGridFunc. forAll(Map<K,V> m, @Nullable IgnitePredicate<? super Map.Entry<K,V>>... p)Deprecated.static <V> booleanGridFunc. forAny(Iterable<? extends V> c, @Nullable IgnitePredicate<? super V>... p)Deprecated.static <X> voidGridFunc. forEach(Iterable<? extends X> c, IgniteInClosure<? super X> f, @Nullable IgnitePredicate<? super X>... p)Deprecated.static <X> voidGridFunc. forEach(X[] c, IgniteInClosure<? super X> f, @Nullable IgnitePredicate<? super X>... p)Deprecated.static <T> booleanGridFunc. isAll(T t, @Nullable IgnitePredicate<? super T>... p)Tests if all provided predicates evaluate totruefor given value.static booleanGridFunc. isAlwaysFalse(@Nullable IgnitePredicate[] p)Deprecated.static booleanGridFunc. isAlwaysFalse(IgnitePredicate p)Deprecated.static booleanGridFunc. isAlwaysTrue(@Nullable IgnitePredicate[] p)Tests whether or not given set of predicates consists only of one predicate returned fromGridFunc.alwaysTrue()method.static booleanGridFunc. isAlwaysTrue(IgnitePredicate p)Deprecated.static <T> booleanGridFunc. isAny(T t, @Nullable IgnitePredicate<? super T>... p)Deprecated.static <T1,T2>
GridIterator<T2>GridFunc. iterator(Iterable<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, @Nullable 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, @Nullable 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, @Nullable IgnitePredicate<? super T>... p)Deprecated.static <K,V>
Map<K,V>GridFunc. lose(Map<K,V> m, boolean cp, @Nullable IgnitePredicate<? super Map.Entry<K,V>>... p)Deprecated.static <T> IgnitePredicate<T>GridFunc. not(@Nullable 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, @Nullable IgnitePredicate<? super T>... p)Retains all elements in input collection that are evaluated totrueby all given predicates.static <T> intGridFunc. size(@Nullable Collection<? extends T> c, @Nullable IgnitePredicate<? super T>... p)Gets size of the given collection with provided optional predicates.static <T> intGridFunc. size(@Nullable Iterator<? extends T> it, @Nullable 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, @Nullable IgnitePredicate<? super T1>... p)Deprecated.static <T> Collection<T>GridFunc. view(@Nullable Collection<T> c, @Nullable 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(@Nullable Map<K,V> m, @Nullable 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(@Nullable Set<K> c, IgniteClosure<? super K,V> mapClo, @Nullable IgnitePredicate<? super K>... p)Read-only map view of a collection.static <T1,T2>
Collection<T2>GridFunc. viewReadOnly(@Nullable Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, @Nullable 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(@Nullable Map<K,V> m, IgniteBiClosure<K,V,V1> trans, @Nullable IgnitePredicate<? super K>... p)Deprecated.static <K0,K extends K0,V0,V extends V0,V1>
Map<K,V1>GridFunc. viewReadOnly(@Nullable Map<K,V> m, IgniteClosure<V,V1> trans, @Nullable 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 Description classAlwaysFalsePredicate<E>Defines a predicate which accepts a parameter and always returnsfalseclassAlwaysTruePredicate<E>Defines a predicate which accepts a parameter and always returnstrueclassCacheEntryHasPeekPredicateCache entry has-peek-value predicate.classContainsNodeIdsPredicate<T extends ClusterNode>Grid node predicate evaluating on the given node IDs.classContainsPredicate<T>Predicate which returnstrueif it receives an element that is contained in the passed in collection.classEntryByKeyEvaluationPredicate<K,V>Predicate evaluates to true for given value.classEqualsClusterNodeIdPredicate<T extends ClusterNode>Creates grid node predicate evaluating on the given node ID.classEqualsUuidPredicateUUID equals predicate.classHasEqualIdPredicate<T extends ClusterNode>ClusterNodehas equal id predicate.classHasNotEqualIdPredicate<T extends ClusterNode>ClusterNodenode has NOT equal id predicate.classIsAllPredicate<T>Predicate that evaluates totrueif each of its component preds evaluates totrue.classIsNotAllPredicate<T>Negated predicate.classIsNotNullPredicate<E>Defines a predicate which checks a parameter onnull.classNotContainsPredicate<T>Predicate that returnstrueif its free variable is not contained in given collection.classNotEqualPredicate<T>Predicate that evaluates totrueif its free variable is equal totargetor both arenull. -
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 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 Description interfaceP1<E1>DefinesaliasforIgnitePredicateby extending it.interfacePCE<K,V>Definesaliasfor GridPredicate<Entry<K, V>> by extendingIgnitePredicate.interfacePEDefinesaliasfor GridPredicate<GridEvent> by extendingIgnitePredicate.interfacePNDefinesaliasfor GridPredicate<ClusterNode> by extendingIgnitePredicate.Classes in org.apache.ignite.internal.util.typedef that implement IgnitePredicate Modifier and Type Class Description classPX1<E1>DefinesaliasforIgnitePredicateXby extending it. -
Uses of IgnitePredicate in org.apache.ignite.marshaller
Classes in org.apache.ignite.marshaller that implement IgnitePredicate Modifier and Type Class Description classIgniteMarshallerClassFilterMethods in org.apache.ignite.marshaller that return IgnitePredicate Modifier and Type Method Description IgnitePredicate<String>MarshallerContext. classNameFilter()Returns class name filter. -
Uses of IgnitePredicate in org.apache.ignite.marshaller.jdk
Constructors in org.apache.ignite.marshaller.jdk with parameters of type IgnitePredicate Constructor 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 Description protected IgnitePredicate<ClusterNode>ServiceConfiguration. nodeFilterNode filter.Methods in org.apache.ignite.services that return IgnitePredicate Modifier and Type Method 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 Description ServiceConfigurationServiceConfiguration. 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
Methods in org.apache.ignite.spi.discovery.tcp with parameters of type IgnitePredicate Modifier and Type Method Description TcpDiscoverySpiTcpDiscoverySpi. setAddressFilter(IgnitePredicate<InetSocketAddress> addressFilter)Sets filter for IP addresses. -
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 Description static IgnitePredicate<TcpDiscoveryNode>TcpDiscoveryNodesRing. VISIBLE_NODESVisible 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 Description <T extends Event>
Collection<T>EventStorageSpi. localEvents(IgnitePredicate<T> p)Queries locally-stored events only.<T extends Event>
Collection<T>NoopEventStorageSpi. 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 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 Description <T extends Event>
Collection<T>MemoryEventStorageSpi. localEvents(IgnitePredicate<T> p)Queries locally-stored events only.MemoryEventStorageSpiMemoryEventStorageSpi. 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 Description classAttributeNodeFilterImplementation ofIgnitePredicate<ClusterNode>based onuser attributes.
-