Uses of Interface
com.hazelcast.query.Predicate
Package
Description
Provides classes for configuring HazelcastInstance.
Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Contains Hazelcast map module classes.
Contains interfaces/classes related to Hazelcast query and indexing support.
Classes for replicated map.
Provides interfaces/classes for Hazelcast transaction support.
-
Uses of Predicate in com.hazelcast.config
Modifier and TypeMethodDescriptionPredicateConfig.getImplementation()
Returns the Predicate implementation.Modifier and TypeMethodDescriptionPredicateConfig.setImplementation
(Predicate implementation) Sets the Predicate implementation.ModifierConstructorDescriptionPredicateConfig
(Predicate implementation) Creates a PredicateConfig with the given implementation. -
Uses of Predicate in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <T,
K, V> ProcessorMetaSupplier SourceProcessors.readMapP
(String mapName, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a supplier of processors forSources.map(String, Predicate, Projection)
. -
Uses of Predicate in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic <T,
K, V> BatchSource<T> Sources.map
(IMap<? extends K, ? extends V> map, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from the given HazelcastIMap
.static <T,
K, V> BatchSource<T> Sources.map
(String mapName, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from a local HazelcastIMap
with the specified name.Set the predicate to apply at the source.static <T,
K, V> BatchSource<T> Sources.remoteMap
(String mapName, ClientConfig clientConfig, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from a remote HazelcastIMap
with the specified name in a remote cluster identified by the suppliedClientConfig
.static <T,
K, V> BatchSource<T> Sources.remoteMap
(String mapName, DataConnectionRef dataConnectionRef, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) The same as theSources.remoteMap(String, ClientConfig, Predicate, Projection)
method. -
Uses of Predicate in com.hazelcast.map
Modifier and TypeMethodDescriptionIMap.addEntryListener
(MapListener listener, Predicate<K, V> predicate, boolean includeValue) Adds aMapListener
for this map.IMap.addEntryListener
(MapListener listener, Predicate<K, V> predicate, K key, boolean includeValue) Adds aMapListener
for this map.QueryCache.addEntryListener
(MapListener listener, Predicate<K, V> predicate, boolean includeValue) QueryCache.addEntryListener
(MapListener listener, Predicate<K, V> predicate, K key, boolean includeValue) IMap.addLocalEntryListener
(MapListener listener, Predicate<K, V> predicate, boolean includeValue) Adds aMapListener
for this map.IMap.addLocalEntryListener
(MapListener listener, Predicate<K, V> predicate, K key, boolean includeValue) Adds a local entry listener for this map.<R> R
Applies the aggregation logic on map entries filtered with the Predicated and returns the resultQueries the map based on the specified predicate and returns an immutable set of the matching entries.IMap.executeOnEntries
(EntryProcessor<K, V, R> entryProcessor, Predicate<K, V> predicate) Applies the user definedEntryProcessor
to the entries in the map which satisfy provided predicate.QueryCache<K,
V> IMap.getQueryCache
(String name, MapListener listener, Predicate<K, V> predicate, boolean includeValue) Creates an always up-to-date snapshot of thisIMap
according to the supplied parameters.QueryCache<K,
V> IMap.getQueryCache
(String name, Predicate<K, V> predicate, boolean includeValue) Creates an always up-to-date snapshot of thisIMap
according to the supplied parameters.Queries the map based on the specified predicate and returns the keys of matching entries.Queries the map based on the specified predicate and returns an immutableSet
clone of the keys of matching entries.IMap.localKeySet
(Predicate<K, V> predicate) Returns an immutable set of the keys of matching locally owned entries.IMap.localValues
(Predicate<K, V> predicate) Queries the map of locally owned keys based on the specified predicate and returns an immutable collection of the values of matching entries.<R> Collection<R>
Applies the projection logic on map entries filtered with the Predicated and returns the resultvoid
Removes all entries which match with the supplied predicate.Queries the map based on the specified predicate and returns the values of matching entries.Queries the map based on the specified predicate and returns an immutable collection of the values of matching entries. -
Uses of Predicate in com.hazelcast.query
Modifier and TypeInterfaceDescriptioninterface
PagingPredicate<K,
V> This interface is a special Predicate which helps to get a page-by-page result of a query.interface
PartitionPredicate<K,
V> interface
This interface provides functionality to build a predicate.Modifier and TypeMethodDescriptionstatic <K,
V> Predicate<K, V> Predicates.alwaysFalse()
Creates an always false predicate that will filter out all items.static <K,
V> Predicate<K, V> Predicates.alwaysTrue()
Creates an always true predicate that will pass all items.static <K,
V> Predicate<K, V> Creates an and predicate that will perform the logical and operation on the givenpredicates
.static <K,
V> Predicate<K, V> Predicates.between
(String attribute, Comparable from, Comparable to) Creates a between predicate that will pass items if the value stored under the given itemattribute
is contained inside the given range.static <K,
V> Predicate<K, V> Predicates.equal
(String attribute, Comparable value) Creates an equal predicate that will pass items if the givenvalue
and the value stored under the given itemattribute
are equal.PartitionPredicate.getTarget()
Returns the targetPredicate
.static <K,
V> Predicate<K, V> Predicates.greaterEqual
(String attribute, Comparable value) Creates a greater than or equal to predicate that will pass items if the value stored under the given itemattribute
is greater than or equal to the givenvalue
.static <K,
V> Predicate<K, V> Predicates.greaterThan
(String attribute, Comparable value) Creates a greater than predicate that will pass items if the value stored under the given itemattribute
is greater than the givenvalue
.static <K,
V> Predicate<K, V> Creates a case-insensitive like predicate that will pass items if the givenpattern
matches the value stored under the given itemattribute
in a case-insensitive manner.static <K,
V> Predicate<K, V> Predicates.in
(String attribute, Comparable... values) Creates a in predicate that will pass items if the value stored under the given itemattribute
is a member of the givenvalues
set.static <K,
V> Predicate<K, V> Predicates.instanceOf
(Class<?> klass) Creates an instance of predicate that will pass entries for which the value class is aninstanceof
the givenklass
.static <K,
V> Predicate<K, V> Predicates.lessEqual
(String attribute, Comparable value) Creates a less than or equal to predicate that will pass items if the value stored under the given itemattribute
is less than or equal to the givenvalue
.static <K,
V> Predicate<K, V> Predicates.lessThan
(String attribute, Comparable value) Creates a less than predicate that will pass items if the value stored under the given itemattribute
is less than the givenvalue
.static <K,
V> Predicate<K, V> Creates a like predicate that will pass items if the givenpattern
matches the value stored under the given itemattribute
.static <K,
V> Predicate<K, V> Creates a not predicate that will negate the result of the givenpredicate
.static <K,
V> Predicate<K, V> Predicates.notEqual
(String attribute, Comparable value) Creates a not equal predicate that will pass items if the givenvalue
and the value stored under the given itemattribute
are not equal.static <K,
V> Predicate<K, V> Creates an or predicate that will perform the logical or operation on the givenpredicates
.static <K,
V> Predicate<K, V> Creates a regex predicate that will pass items if the givenpattern
matches the value stored under the given itemattribute
.static <K,
V> Predicate<K, V> Creates a predicate that will pass items that match the given SQL 'where' expression.Modifier and TypeMethodDescriptionstatic <K,
V> Predicate<K, V> Creates an and predicate that will perform the logical and operation on the givenpredicates
.static <K,
V> PartitionPredicate<K, V> Predicates.multiPartitionPredicate
(Set<? extends Object> partitionKeys, Predicate<K, V> target) Creates a new partition predicate that restricts the execution of the target predicate to a subset of partitions.static <K,
V> Predicate<K, V> Creates a not predicate that will negate the result of the givenpredicate
.static <K,
V> Predicate<K, V> Creates an or predicate that will perform the logical or operation on the givenpredicates
.static <K,
V> PagingPredicate<K, V> Predicates.pagingPredicate
(Predicate<K, V> predicate, Comparator<Map.Entry<K, V>> comparator, int pageSize) Creates a paging predicate with an inner predicate, comparator and page size.static <K,
V> PagingPredicate<K, V> Predicates.pagingPredicate
(Predicate predicate, int pageSize) Creates a paging predicate with an inner predicate and page size.static <K,
V> PartitionPredicate<K, V> Predicates.partitionPredicate
(Object partitionKey, Predicate<K, V> target) Creates a new partition predicate that restricts the execution of the target predicate to a single partition. -
Uses of Predicate in com.hazelcast.replicatedmap
Modifier and TypeMethodDescriptionReplicatedMap.addEntryListener
(EntryListener<K, V> listener, Predicate<K, V> predicate) Adds a continuous entry listener for this map.ReplicatedMap.addEntryListener
(EntryListener<K, V> listener, Predicate<K, V> predicate, K key) Adds a continuous entry listener for this map. -
Uses of Predicate in com.hazelcast.transaction
Modifier and TypeMethodDescriptionTransactional implementation ofIMap.keySet(com.hazelcast.query.Predicate)
.Transactional implementation ofIMap.values(com.hazelcast.query.Predicate)
.