Package | Description |
---|---|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.proxy.txn |
Contains classes related to proxy for client transactions
|
com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
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.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.mapreduce.aggregation |
This package contains the aggregation API and the convenience helper classes
to retrieve predefined aggregation implementations.
|
com.hazelcast.query |
Contains interfaces/classes related to Hazelcast query and indexing support.
|
Modifier and Type | Method and Description |
---|---|
String |
ClientReplicatedMapProxy.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate) |
String |
ClientReplicatedMapProxy.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate,
K key) |
String |
ClientMapProxy.addEntryListener(EntryListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
ClientMapProxy.addEntryListener(EntryListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
String |
ClientMapProxy.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
ClientMapProxy.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
String |
ClientMapProxy.addLocalEntryListener(EntryListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
ClientMapProxy.addLocalEntryListener(EntryListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
String |
ClientMapProxy.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
ClientMapProxy.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
<R> R |
ClientMapProxy.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator,
Predicate<K,V> predicate) |
Set<Map.Entry<K,V>> |
ClientMapProxy.entrySet(Predicate predicate) |
Map<K,Object> |
ClientMapProxy.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
QueryCache<K,V> |
ClientMapProxy.getQueryCache(String name,
MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
QueryCache<K,V> |
ClientMapProxy.getQueryCache(String name,
Predicate<K,V> predicate,
boolean includeValue) |
<R> Iterator<R> |
ClientMapProxy.iterator(int fetchSize,
int partitionId,
Projection<Map.Entry<K,V>,R> projection,
Predicate<K,V> predicate)
Returns an iterator for iterating the result of the projection on entries in the
partitionId which
satisfy the predicate . |
Set<K> |
ClientMapProxy.keySet(Predicate predicate) |
Set<K> |
ClientMapProxy.localKeySet(Predicate predicate) |
<R> Collection<R> |
ClientMapProxy.project(Projection<Map.Entry<K,V>,R> projection,
Predicate<K,V> predicate) |
void |
ClientMapProxy.removeAll(Predicate<K,V> predicate) |
protected void |
NearCachedClientMapProxy.removeAllInternal(Predicate predicate) |
protected void |
ClientMapProxy.removeAllInternal(Predicate predicate) |
Collection<V> |
ClientMapProxy.values(Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
Set<K> |
ClientTxnMapProxy.keySet(Predicate predicate) |
Collection<V> |
ClientTxnMapProxy.values(Predicate predicate) |
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 |
---|---|
String |
ReplicatedMap.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate)
Adds an continuous entry listener for this map.
|
String |
ReplicatedMap.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate,
K key)
Adds an continuous entry listener for this map.
|
String |
IMap.addEntryListener(EntryListener listener,
Predicate<K,V> predicate,
boolean includeValue)
Deprecated.
please use
IMap.addEntryListener(MapListener, com.hazelcast.query.Predicate, boolean) instead |
String |
IMap.addEntryListener(EntryListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue)
Deprecated.
|
String |
IMap.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue)
Adds a
MapListener for this map. |
String |
IMap.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue)
Adds a
MapListener for this map. |
String |
IMap.addLocalEntryListener(EntryListener listener,
Predicate<K,V> predicate,
boolean includeValue)
Deprecated.
|
String |
IMap.addLocalEntryListener(EntryListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue)
Deprecated.
|
String |
IMap.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue)
Adds a
MapListener for this map. |
String |
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<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>> |
IMap.entrySet(Predicate predicate)
Queries the map based on the specified predicate and returns the matching entries.
|
Map<K,Object> |
IMap.executeOnEntries(EntryProcessor entryProcessor,
Predicate 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> |
TransactionalMap.keySet(Predicate predicate)
Transactional implementation of
IMap.keySet(com.hazelcast.query.Predicate) . |
Set<K> |
IMap.keySet(Predicate predicate)
Queries the map based on the specified predicate and
returns the keys of matching entries.
|
Set<K> |
BaseMap.keySet(Predicate predicate)
Queries the map based on the specified predicate and
returns the keys of matching entries.
|
Set<K> |
IMap.localKeySet(Predicate predicate)
Returns the keys of matching locally owned entries.
|
<R> Collection<R> |
IMap.project(Projection<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> |
TransactionalMap.values(Predicate predicate)
Transactional implementation of
IMap.values(com.hazelcast.query.Predicate) . |
Collection<V> |
IMap.values(Predicate predicate)
Queries the map based on the specified predicate and returns the values of matching entries.
|
Collection<V> |
BaseMap.values(Predicate predicate)
Queries the map based on the specified predicate and
returns the values of matching entries.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> Predicate<K,V> |
GenericPredicates.alwaysFalse()
|
static <K,V> Predicate<K,V> |
GenericPredicates.alwaysTrue()
|
static <K,V> Predicate<K,V> |
GenericPredicates.and(Predicate<K,V>... predicates)
|
static <K,V> Predicate<K,V> |
GenericPredicates.between(String attribute,
Comparable from,
Comparable to)
|
static <K,V> Predicate<K,V> |
GenericPredicates.equal(String attribute,
Comparable value)
|
static <K,V> Predicate<K,V> |
GenericPredicates.greaterEqual(String attribute,
Comparable value)
|
static <K,V> Predicate<K,V> |
GenericPredicates.greaterThan(String attribute,
Comparable value)
|
static <K,V> Predicate<K,V> |
GenericPredicates.ilike(String attribute,
String pattern)
|
static <K,V> Predicate<K,V> |
GenericPredicates.in(String attribute,
Comparable... values)
|
static <K,V> Predicate<K,V> |
GenericPredicates.instanceOf(Class<? extends V> klass)
|
static <K,V> Predicate<K,V> |
GenericPredicates.lessEqual(String attribute,
Comparable value)
|
static <K,V> Predicate<K,V> |
GenericPredicates.lessThan(String attribute,
Comparable value)
|
static <K,V> Predicate<K,V> |
GenericPredicates.like(String attribute,
String pattern)
|
static <K,V> Predicate<K,V> |
GenericPredicates.not(Predicate<K,V> predicate)
|
static <K,V> Predicate<K,V> |
GenericPredicates.notEqual(String attribute,
Comparable value)
|
static <K,V> Predicate<K,V> |
GenericPredicates.or(Predicate<K,V>... predicates)
|
static <K,V> Predicate<K,V> |
GenericPredicates.regex(String attribute,
String pattern)
|
Modifier and Type | Method and Description |
---|---|
static <K,V> Predicate<K,V> |
GenericPredicates.and(Predicate<K,V>... predicates)
|
static <K,V> Predicate<K,V> |
GenericPredicates.not(Predicate<K,V> predicate)
|
static <K,V> Predicate<K,V> |
GenericPredicates.or(Predicate<K,V>... predicates)
|
Modifier and Type | Method and Description |
---|---|
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readMapP(String mapName,
Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a supplier of processors for
Sources.map(String, Predicate, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readMapP(String mapName,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,T> projectionFn)
Returns a supplier of processors for
Sources.map(String, Predicate, Projection) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readRemoteMapP(String mapName,
ClientConfig clientConfig,
Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a supplier of processors for
Sources.remoteMap(String, ClientConfig, Predicate, DistributedFunction) . |
static <T,K,V> ProcessorMetaSupplier |
SourceProcessors.readRemoteMapP(String mapName,
ClientConfig clientConfig,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,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(String mapName,
Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Convenience for
Sources.map(String, Predicate, Projection)
which uses a DistributedFunction as the projection function. |
static <T,K,V> BatchSource<T> |
Sources.map(String mapName,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,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,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Convenience for
Sources.remoteMap(String, ClientConfig, Predicate, Projection)
which use a DistributedFunction as the projection function. |
static <T,K,V> BatchSource<T> |
Sources.remoteMap(String mapName,
ClientConfig clientConfig,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,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 |
---|---|
static <K,V,T> DistributedStream<T> |
DistributedStream.fromMap(IMapJet<K,V> map,
Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a
DistributedStream with this map as its source. |
Modifier and Type | Method and Description |
---|---|
String |
QueryCache.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
QueryCache.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
Set<Map.Entry<K,V>> |
QueryCache.entrySet(Predicate predicate) |
Set<K> |
QueryCache.keySet(Predicate predicate) |
Collection<V> |
QueryCache.values(Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromPredicate(Predicate<KeyIn,ValueIn> predicate)
Deprecated.
The predefined Supplier selects values using the given
Predicate
and does not perform any kind of data transformation. |
static <KeyIn,ValueIn,ValueOut> |
Supplier.fromPredicate(Predicate<KeyIn,ValueIn> predicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier)
Deprecated.
The predefined Supplier selects values using the given
Predicate
and chains the filtered value to the given Supplier which might perform data transformation. |
Modifier and Type | Interface and Description |
---|---|
interface |
IndexAwarePredicate<K,V>
Extends the
Predicate interface with the ability to support indexes. |
Modifier and Type | Class and Description |
---|---|
class |
PagingPredicate<K,V>
This class is a special Predicate which helps to get a page-by-page result of a query.
|
class |
PartitionPredicate<K,V>
A
Predicate that restricts the execution of a Predicate to a single Partition. |
class |
PredicateBuilder
This class provides functionality to build predicate.
|
class |
SqlPredicate
This class contains methods related to conversion of sql query to predicate.
|
class |
TruePredicate<K,V>
A
Predicate which always returns true. |
Modifier and Type | Method and Description |
---|---|
Predicate |
VisitablePredicate.accept(com.hazelcast.query.impl.predicates.Visitor visitor,
com.hazelcast.query.impl.Indexes indexes)
Accept visitor.
|
Predicate |
SqlPredicate.accept(com.hazelcast.query.impl.predicates.Visitor visitor,
com.hazelcast.query.impl.Indexes indexes) |
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 Predicate |
Predicates.and(Predicate... predicates)
Creates an and predicate that will perform the logical and operation on the given
predicates . |
static Predicate |
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 Predicate |
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 |
SqlPredicate.getPredicate() |
Predicate<K,V> |
PagingPredicate.getPredicate() |
Predicate<K,V> |
PartitionPredicate.getTarget()
Returns the target
Predicate . |
static Predicate |
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 Predicate |
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 Predicate |
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 Predicate |
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 Predicate |
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 Predicate |
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 Predicate |
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 Predicate |
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 Predicate |
Predicates.not(Predicate predicate)
Creates a not predicate that will negate the result of the given
predicate . |
static Predicate |
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 Predicate |
Predicates.or(Predicate... predicates)
Creates an or predicate that will perform the logical or operation on the given
predicates . |
static Predicate |
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 . |
Modifier and Type | Method and Description |
---|---|
static Predicate |
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 Predicate |
Predicates.not(Predicate predicate)
Creates a not predicate that will negate the result of the given
predicate . |
static Predicate |
Predicates.or(Predicate... predicates)
Creates an or predicate that will perform the logical or operation on the given
predicates . |
PredicateBuilder |
PredicateBuilder.or(Predicate predicate) |
Constructor and Description |
---|
PagingPredicate(Predicate<K,V> predicate,
Comparator<Map.Entry<K,V>> comparator,
int pageSize)
Construct with an inner predicate, comparator and pageSize
results will be filtered via inner predicate
results will be ordered via comparator
throws
IllegalArgumentException if pageSize is not greater than 0
throws IllegalArgumentException if inner predicate is also PagingPredicate |
PagingPredicate(Predicate predicate,
int pageSize)
Construct with an inner predicate and pageSize
results will be filtered via inner predicate
results will be natural ordered
throws
IllegalArgumentException if pageSize is not greater than 0
throws IllegalArgumentException if inner predicate is also PagingPredicate |
PartitionPredicate(Object partitionKey,
Predicate<K,V> target)
Creates a new PartitionPredicate.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.