Package | Description |
---|---|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.query |
Contains interfaces/classes related to Hazelcast query and indexing support.
|
com.hazelcast.replicatedmap |
Classes for replicated map.
|
com.hazelcast.transaction |
Provides interfaces/classes for Hazelcast transaction support.
|
Modifier and Type | Field and Description |
---|---|
protected Predicate |
PredicateConfig.implementation |
Modifier and Type | Method and Description |
---|---|
Predicate |
PredicateConfig.getImplementation()
Returns the Predicate implementation.
|
Modifier and Type | Method and Description |
---|---|
PredicateConfig |
PredicateConfig.setImplementation(Predicate implementation)
Sets the Predicate implementation.
|
Constructor and Description |
---|
PredicateConfig(Predicate implementation)
Creates a PredicateConfig with the given implementation.
|
Modifier and Type | Method and Description |
---|---|
static <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 for
Sources.map(String, Predicate, Projection) . |
static <T,K,V> ProcessorSupplier |
SourceProcessors.readRemoteMapP(String mapName,
ClientConfig clientConfig,
Predicate<K,V> predicate,
Projection<? super Map.Entry<K,V>,? extends T> projection)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig, Predicate, Projection) . |
Modifier and Type | Method and Description |
---|---|
static <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 Hazelcast
IMap . |
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 Hazelcast
IMap with the specified name. |
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 Hazelcast
IMap with the specified name in a remote cluster identified by the
supplied ClientConfig . |
Modifier and Type | Method and Description |
---|---|
UUID |
QueryCache.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
UUID |
IMap.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue)
Adds a
MapListener for this map. |
UUID |
QueryCache.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
UUID |
IMap.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue)
Adds a
MapListener for this map. |
UUID |
IMap.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue)
Adds a
MapListener for this map. |
UUID |
IMap.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue)
Adds a local entry listener for this map.
|
<R> R |
IMap.aggregate(Aggregator<? super Map.Entry<K,V>,R> aggregator,
Predicate<K,V> predicate)
Applies the aggregation logic on map entries filtered with the Predicated and returns the result
|
Set<Map.Entry<K,V>> |
QueryCache.entrySet(Predicate<K,V> predicate) |
Set<Map.Entry<K,V>> |
IMap.entrySet(Predicate<K,V> predicate)
Queries the map based on the specified predicate and returns an immutable set of the matching entries.
|
<R> Map<K,R> |
IMap.executeOnEntries(EntryProcessor<K,V,R> entryProcessor,
Predicate<K,V> predicate)
Applies the user defined
EntryProcessor 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 this
IMap 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 this
IMap according to the supplied parameters. |
Set<K> |
QueryCache.keySet(Predicate<K,V> predicate) |
Set<K> |
IMap.keySet(Predicate<K,V> predicate)
Queries the map based on the specified predicate and
returns an immutable
Set clone of the keys of matching entries. |
Set<K> |
BaseMap.keySet(Predicate<K,V> predicate)
Queries the map based on the specified predicate and
returns the keys of matching entries.
|
Set<K> |
IMap.localKeySet(Predicate<K,V> predicate)
Returns an immutable set of the keys of matching locally owned entries.
|
<R> Collection<R> |
IMap.project(Projection<? super Map.Entry<K,V>,R> projection,
Predicate<K,V> predicate)
Applies the projection logic on map entries filtered with the Predicated and returns the result
|
void |
IMap.removeAll(Predicate<K,V> predicate)
Removes all entries which match with the supplied predicate.
|
Collection<V> |
QueryCache.values(Predicate<K,V> predicate) |
Collection<V> |
IMap.values(Predicate<K,V> predicate)
Queries the map based on the specified predicate and returns an immutable
collection of the values of matching entries.
|
Collection<V> |
BaseMap.values(Predicate<K,V> predicate)
Queries the map based on the specified predicate and
returns the values of matching entries.
|
Modifier and Type | Interface and Description |
---|---|
interface |
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 |
PredicateBuilder
This interface provides functionality to build a predicate.
|
Modifier and Type | Method and Description |
---|---|
static <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> |
Predicates.and(Predicate... predicates)
Creates an and predicate that will perform the logical and operation on the given
predicates . |
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 item
attribute
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 given
value and the value stored under
the given item attribute are equal. |
Predicate<K,V> |
PartitionPredicate.getTarget()
Returns the target
Predicate . |
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
item
attribute is greater than or equal to the given value . |
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
item
attribute is greater than the given value . |
static <K,V> Predicate<K,V> |
Predicates.ilike(String attribute,
String pattern)
Creates a case-insensitive like predicate that will pass items if the given
pattern matches the value
stored under the given item attribute 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 item
attribute
is a member of the given values 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 an
instanceof the given klass . |
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
item
attribute is less than or equal to the given value . |
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 item
attribute
is less than the given value . |
static <K,V> Predicate<K,V> |
Predicates.like(String attribute,
String pattern)
Creates a like predicate that will pass items if the given
pattern matches the value stored under
the given item attribute . |
static <K,V> Predicate<K,V> |
Predicates.not(Predicate predicate)
Creates a not predicate that will negate the result of the given
predicate . |
static <K,V> Predicate<K,V> |
Predicates.notEqual(String attribute,
Comparable value)
Creates a not equal predicate that will pass items if the given
value and the value stored under
the given item attribute are not equal. |
static <K,V> Predicate<K,V> |
Predicates.or(Predicate... predicates)
Creates an or predicate that will perform the logical or operation on the given
predicates . |
static <K,V> Predicate<K,V> |
Predicates.regex(String attribute,
String pattern)
Creates a regex predicate that will pass items if the given
pattern matches the value stored under
the given item attribute . |
static <K,V> Predicate<K,V> |
Predicates.sql(String expression)
Creates a predicate that will pass items that match the given SQL 'where' expression.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> Predicate<K,V> |
Predicates.and(Predicate... predicates)
Creates an and predicate that will perform the logical and operation on the given
predicates . |
PredicateBuilder |
PredicateBuilder.and(Predicate predicate) |
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> |
Predicates.not(Predicate predicate)
Creates a not predicate that will negate the result of the given
predicate . |
static <K,V> Predicate<K,V> |
Predicates.or(Predicate... predicates)
Creates an or predicate that will perform the logical or operation on the given
predicates . |
PredicateBuilder |
PredicateBuilder.or(Predicate predicate) |
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.
|
Modifier and Type | Method and Description |
---|---|
UUID |
ReplicatedMap.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate)
Adds an continuous entry listener for this map.
|
UUID |
ReplicatedMap.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate,
K key)
Adds an continuous entry listener for this map.
|
Modifier and Type | Method and Description |
---|---|
Set<K> |
TransactionalMap.keySet(Predicate<K,V> predicate)
Transactional implementation of
IMap.keySet(com.hazelcast.query.Predicate) . |
Collection<V> |
TransactionalMap.values(Predicate<K,V> predicate)
Transactional implementation of
IMap.values(com.hazelcast.query.Predicate) . |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.