Package | Description |
---|---|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.impl.protocol.task.replicatedmap |
Client protocol tasks implementations for ReplicatedMap
|
com.hazelcast.client.map.impl | |
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.internal.adapter |
Data structure adapters for Near Cache.
|
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.map.impl.iterator | |
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
com.hazelcast.map.impl.query | |
com.hazelcast.map.impl.querycache.accumulator |
Contains
Accumulator
specific classes. |
com.hazelcast.map.impl.querycache.subscriber |
This package contains classes which are used for
QueryCache
event subscription side. |
com.hazelcast.map.impl.tx |
Contains implementation classes for
TransactionalMap |
com.hazelcast.mapreduce.aggregation |
This package contains the aggregation API and the convenience helper classes
to retrieve predefined aggregation implementations.
|
com.hazelcast.mapreduce.aggregation.impl |
This package contains a set of predefined aggregation implementations
|
com.hazelcast.query |
Contains interfaces/classes related to Hazelcast query and indexing support.
|
com.hazelcast.query.impl |
Contains the implementation classes of the query functionality.
|
com.hazelcast.query.impl.bitmap | |
com.hazelcast.query.impl.predicates | |
com.hazelcast.replicatedmap.impl |
This package contains the implementation of the replicated map service itself and some connection interfaces only used
internally.
|
com.hazelcast.replicatedmap.impl.record |
This package contains the implementation of the backing data storage for the replicated map implementation
|
Modifier and Type | Method and Description |
---|---|
protected Predicate |
MapEntriesWithPagingPredicateMessageTask.getPredicate() |
protected Predicate |
MapKeySetMessageTask.getPredicate() |
protected Predicate |
MapEntriesWithPredicateMessageTask.getPredicate() |
protected Predicate |
DefaultMapProjectMessageTask.getPredicate() |
protected Predicate |
MapValuesMessageTask.getPredicate() |
protected Predicate |
MapAggregateWithPredicateMessageTask.getPredicate() |
protected Predicate |
MapKeySetWithPagingPredicateMessageTask.getPredicate() |
protected abstract Predicate |
AbstractMapQueryMessageTask.getPredicate() |
protected Predicate |
DefaultMapAggregateMessageTask.getPredicate() |
protected Predicate |
MapKeySetWithPredicateMessageTask.getPredicate() |
protected Predicate |
MapEntrySetMessageTask.getPredicate() |
protected Predicate |
MapValuesWithPagingPredicateMessageTask.getPredicate() |
protected Predicate |
MapProjectionWithPredicateMessageTask.getPredicate() |
protected Predicate |
MapValuesWithPredicateMessageTask.getPredicate() |
Modifier and Type | Method and Description |
---|---|
Predicate |
ReplicatedMapAddNearCacheListenerMessageTask.getPredicate() |
Predicate |
ReplicatedMapAddEntryListenerMessageTask.getPredicate() |
Predicate |
ReplicatedMapAddEntryListenerToKeyMessageTask.getPredicate() |
abstract Predicate |
AbstractReplicatedMapAddEntryListenerMessageTask.getPredicate() |
Predicate |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.getPredicate() |
Predicate |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.getPredicate() |
Constructor and Description |
---|
ClientMapQueryPartitionIterator(ClientMapProxy<K,V> mapProxy,
ClientContext context,
int fetchSize,
int partitionId,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,R> projection) |
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> |
IMap.keySet(Predicate predicate)
Queries the map based on the specified predicate and
returns the keys of matching entries.
|
Set<K> |
TransactionalMap.keySet(Predicate predicate)
Transactional implementation of
IMap.keySet(com.hazelcast.query.Predicate) . |
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> |
IMap.values(Predicate predicate)
Queries the map based on the specified predicate and returns the values of matching entries.
|
Collection<V> |
TransactionalMap.values(Predicate predicate)
Transactional implementation of
IMap.values(com.hazelcast.query.Predicate) . |
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 |
---|---|
Map<K,Object> |
IMapDataStructureAdapter.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
Map<K,Object> |
TransactionalMapDataStructureAdapter.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
Map<K,Object> |
DataStructureAdapter.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
Map<K,Object> |
ReplicatedMapDataStructureAdapter.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
Map<K,Object> |
ICacheDataStructureAdapter.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
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) |
Constructor and Description |
---|
AbstractMapQueryPartitionIterator(IMap<K,V> map,
int fetchSize,
int partitionId,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,R> projection) |
MapQueryPartitionIterator(MapProxyImpl<K,V> mapProxy,
int fetchSize,
int partitionId,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,R> projection) |
Modifier and Type | Method and Description |
---|---|
protected Predicate |
MultipleEntryOperation.getPredicate() |
protected Predicate |
PartitionWideEntryWithPredicateOperation.getPredicate() |
protected Predicate |
PartitionWideEntryOperation.getPredicate() |
Predicate |
MultipleEntryWithPredicateBackupOperation.getPredicate() |
Predicate |
MultipleEntryWithPredicateOperation.getPredicate() |
protected Predicate |
PartitionWideEntryWithPredicateBackupOperation.getPredicate() |
Modifier and Type | Method and Description |
---|---|
OperationFactory |
WANAwareOperationProvider.createPartitionWideEntryWithPredicateOperationFactory(String name,
EntryProcessor entryProcessor,
Predicate predicate) |
OperationFactory |
MapOperationProvider.createPartitionWideEntryWithPredicateOperationFactory(String name,
EntryProcessor entryProcessor,
Predicate predicate) |
OperationFactory |
DefaultMapOperationProvider.createPartitionWideEntryWithPredicateOperationFactory(String name,
EntryProcessor entryProcessor,
Predicate predicate) |
static EntryOperator |
EntryOperator.operator(MapOperation mapOperation,
Object processor,
Predicate predicate) |
Constructor and Description |
---|
MultipleEntryWithPredicateBackupOperation(String name,
Set<Data> keys,
EntryBackupProcessor backupProcessor,
Predicate predicate) |
MultipleEntryWithPredicateOperation(String name,
Set<Data> keys,
EntryProcessor entryProcessor,
Predicate predicate) |
PartitionWideEntryWithPredicateBackupOperation(String name,
EntryBackupProcessor entryProcessor,
Predicate predicate) |
PartitionWideEntryWithPredicateOperation(String name,
EntryProcessor entryProcessor,
Predicate predicate) |
PartitionWideEntryWithPredicateOperationFactory(String name,
EntryProcessor entryProcessor,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
String |
MapProxyImpl.addEntryListener(EntryListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
MapProxyImpl.addEntryListener(EntryListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
String |
MapProxyImpl.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
MapProxyImpl.addEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
String |
MapProxyImpl.addLocalEntryListener(EntryListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
MapProxyImpl.addLocalEntryListener(EntryListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
String |
MapProxyImpl.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
String |
MapProxyImpl.addLocalEntryListener(MapListener listener,
Predicate<K,V> predicate,
K key,
boolean includeValue) |
<R> R |
MapProxyImpl.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator,
Predicate<K,V> predicate) |
Set<Map.Entry<K,V>> |
MapProxyImpl.entrySet(Predicate predicate) |
Map<K,Object> |
MapProxyImpl.executeOnEntries(EntryProcessor entryProcessor,
Predicate predicate) |
void |
NearCachedMapProxyImpl.executeOnEntriesInternal(EntryProcessor entryProcessor,
Predicate predicate,
List<Data> resultingKeyValuePairs) |
QueryCache<K,V> |
MapProxyImpl.getQueryCache(String name,
MapListener listener,
Predicate<K,V> predicate,
boolean includeValue) |
QueryCache<K,V> |
MapProxyImpl.getQueryCache(String name,
Predicate<K,V> predicate,
boolean includeValue) |
<R> Iterator<R> |
MapProxyImpl.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> |
MapProxyImpl.keySet(Predicate predicate) |
Set<K> |
MapProxyImpl.localKeySet(Predicate predicate) |
<R> Collection<R> |
MapProxyImpl.project(Projection<Map.Entry<K,V>,R> projection,
Predicate<K,V> predicate) |
void |
MapProxyImpl.removeAll(Predicate<K,V> predicate) |
protected void |
NearCachedMapProxyImpl.removeAllInternal(Predicate predicate) |
Collection<V> |
MapProxyImpl.values(Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
Predicate |
Query.getPredicate() |
Modifier and Type | Method and Description |
---|---|
void |
PartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
void |
CallerRunsPartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
void |
ParallelPartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
QueryableEntriesSegment |
PartitionScanExecutor.execute(String mapName,
Predicate predicate,
int partitionId,
int tableIndex,
int fetchSize)
Executes the predicate on a partition chunk.
|
QueryableEntriesSegment |
CallerRunsPartitionScanExecutor.execute(String mapName,
Predicate predicate,
int partitionId,
int tableIndex,
int fetchSize) |
QueryableEntriesSegment |
ParallelPartitionScanExecutor.execute(String mapName,
Predicate predicate,
int partitionId,
int tableIndex,
int fetchSize)
Executes the predicate on a partition chunk.
|
Query.QueryBuilder |
Query.QueryBuilder.predicate(Predicate predicate) |
QueryableEntriesSegment |
PartitionScanRunner.run(String mapName,
Predicate predicate,
int partitionId,
int tableIndex,
int fetchSize)
Executes the predicate on a partition chunk.
|
void |
PartitionScanRunner.run(String mapName,
Predicate predicate,
int partitionId,
Result result) |
protected Future<Result> |
ParallelPartitionScanExecutor.runPartitionScanForPartition(String name,
Predicate predicate,
int partitionId,
Result result) |
protected Collection<QueryableEntry> |
QueryRunner.runUsingGlobalIndexSafely(Predicate predicate,
MapContainer mapContainer,
int migrationStamp,
int ownedPartitionCount) |
protected Result |
QueryRunner.runUsingPartitionScanSafely(Query query,
Predicate predicate,
Collection<Integer> partitions,
int migrationStamp) |
protected void |
ParallelPartitionScanExecutor.runUsingPartitionScanWithoutPaging(String name,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
static Set |
QueryResultUtils.transformToSet(SerializationService ss,
QueryResult queryResult,
Predicate predicate,
IterationType iterationType,
boolean unique,
boolean binary) |
Constructor and Description |
---|
Query(String mapName,
Predicate predicate,
IterationType iterationType,
Aggregator aggregator,
Projection projection) |
QueryEventFilter(boolean includeValue,
Data key,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
Predicate |
AccumulatorInfo.getPredicate() |
Modifier and Type | Method and Description |
---|---|
static AccumulatorInfo |
AccumulatorInfo.toAccumulatorInfo(QueryCacheConfig config,
String mapName,
String cacheId,
Predicate predicate) |
static AccumulatorInfo |
AccumulatorInfo.toAccumulatorInfo(String mapName,
String cacheId,
Predicate predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean includeValue,
boolean populate,
boolean coalesce) |
Modifier and Type | Method and Description |
---|---|
Predicate |
QueryCacheRequest.getPredicate() |
Modifier and Type | Method and Description |
---|---|
String |
NullQueryCache.addEntryListener(MapListener listener,
Predicate predicate,
boolean includeValue) |
String |
NullQueryCache.addEntryListener(MapListener listener,
Predicate predicate,
Object key,
boolean includeValue) |
Set<Map.Entry> |
NullQueryCache.entrySet(Predicate predicate) |
Set |
NullQueryCache.keySet(Predicate predicate) |
Collection |
NullQueryCache.values(Predicate predicate) |
QueryCacheRequest |
QueryCacheRequest.withPredicate(Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
Set |
TransactionalMapProxy.keySet(Predicate predicate) |
Collection |
TransactionalMapProxy.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. |
Constructor and Description |
---|
PredicateSupplier(Predicate<KeyIn,ValueIn> predicate) |
PredicateSupplier(Predicate<KeyIn,ValueIn> predicate,
Supplier<KeyIn,ValueIn,ValueOut> chainedSupplier) |
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 |
PagingPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
VisitablePredicate.accept(Visitor visitor,
Indexes indexes)
Accept visitor.
|
Predicate |
SqlPredicate.accept(Visitor visitor,
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<K,V> |
PagingPredicate.getPredicate() |
Predicate |
SqlPredicate.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.
|
Modifier and Type | Class and Description |
---|---|
class |
FalsePredicate<K,V>
A
Predicate which always returns false. |
class |
SkipIndexPredicate
The
SkipIndexPredicate is a predicate that prevents
an index from being used on the wrapped predicate. |
Modifier and Type | Method and Description |
---|---|
Predicate |
SkipIndexPredicate.getTarget() |
Modifier and Type | Method and Description |
---|---|
Set<QueryableEntry> |
AbstractIndex.evaluate(Predicate predicate) |
Set<QueryableEntry> |
Index.evaluate(Predicate predicate)
Evaluates the given predicate using this index.
|
Set<QueryableEntry> |
UnorderedIndexStore.evaluate(Predicate predicate,
TypeConverter converter) |
Set<QueryableEntry> |
BitmapIndexStore.evaluate(Predicate predicate,
TypeConverter converter) |
Set<QueryableEntry> |
IndexStore.evaluate(Predicate predicate,
TypeConverter converter)
Evaluates the given predicate using this index store.
|
Set<QueryableEntry> |
OrderedIndexStore.evaluate(Predicate predicate,
TypeConverter converter) |
Set<QueryableEntry> |
Indexes.query(Predicate predicate,
int ownedPartitionCount)
Performs a query on this indexes instance using the given predicate.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractIndex.canEvaluate(Class<? extends Predicate> predicateClass) |
boolean |
Index.canEvaluate(Class<? extends Predicate> predicateClass) |
boolean |
UnorderedIndexStore.canEvaluate(Class<? extends Predicate> predicateClass) |
boolean |
BitmapIndexStore.canEvaluate(Class<? extends Predicate> predicateClass) |
boolean |
IndexStore.canEvaluate(Class<? extends Predicate> predicateClass) |
boolean |
OrderedIndexStore.canEvaluate(Class<? extends Predicate> predicateClass) |
InternalIndex |
Indexes.matchIndex(String pattern,
Class<? extends Predicate> predicateClass,
QueryContext.IndexMatchHint matchHint,
int ownedPartitionCount)
Matches an index for the given pattern and match hint that can evaluate
the given predicate class.
|
Constructor and Description |
---|
SkipIndexPredicate(Predicate target) |
Constructor and Description |
---|
AndResultSet(Set<QueryableEntry> setSmallest,
List<Set<QueryableEntry>> otherIndexedResults,
List<Predicate> lsNoIndexPredicates) |
Modifier and Type | Method and Description |
---|---|
Iterator<E> |
Bitmap.evaluate(Predicate predicate,
TypeConverter converter)
Evaluates the given predicate while converting the predicate arguments
using the given converter.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RangePredicate
Defines a common contract for range-like predicates.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractIndexAwarePredicate<K,V> |
class |
AbstractPredicate<K,V>
Provides base features for predicates, such as extraction and conversion of the attribute's value.
|
class |
AndPredicate
And Predicate
|
class |
BetweenPredicate
Between Predicate
|
class |
BoundedRangePredicate
Range predicate that is bounded on both sides.
|
class |
CompositeEqualPredicate
Does the same thing as
EqualPredicate but for composite indexes and
values. |
class |
CompositeRangePredicate
Does the same thing as
GreaterLessPredicate , BetweenPredicate
and BoundedRangePredicate but for composite indexes and values. |
class |
EqualPredicate
Equal Predicate
|
class |
EvaluatePredicate
Wraps a predicate for which
Index.canEvaluate(java.lang.Class<? extends com.hazelcast.query.Predicate>) returned true . |
class |
GreaterLessPredicate
Greater Less Predicate
|
class |
ILikePredicate
Ilike Predicate
|
class |
InPredicate
In Predicate
|
class |
InstanceOfPredicate
Predicate version of `instaceof` operator from Java.
|
class |
LikePredicate
Like Predicate
|
class |
NotEqualPredicate
Not Equal Predicate
|
class |
NotPredicate
Not Predicate
|
class |
OrPredicate
Or Predicate
|
class |
RegexPredicate
Regex Predicate
|
Modifier and Type | Field and Description |
---|---|
protected Predicate |
NotPredicate.predicate |
protected Predicate[] |
OrPredicate.predicates |
protected Predicate[] |
AndPredicate.predicates |
Modifier and Type | Method and Description |
---|---|
Predicate |
BetweenPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
EqualPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
InPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
NotEqualPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
OrPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
NotPredicate.accept(Visitor visitor,
Indexes indexes) |
Predicate |
AndPredicate.accept(Visitor visitor,
Indexes indexes) |
static Predicate[] |
VisitorUtils.acceptVisitor(Predicate[] predicates,
Visitor visitor,
Indexes indexes)
Accept visitor by all predicates.
|
Predicate |
EvaluatePredicate.getPredicate() |
Predicate |
NotPredicate.getPredicate() |
<K,V> Predicate<K,V>[] |
OrPredicate.getPredicates()
Visitable predicates are treated as effectively immutable, therefore callers should not make any changes to
the returned array.
|
<K,V> Predicate<K,V>[] |
AndPredicate.getPredicates()
Visitable predicates are treated as effectively immutable, therefore callers should not make any changes to
the returned array.
|
<K,V> Predicate<K,V>[] |
CompoundPredicate.getPredicates()
An array of predicates which compose this predicate.
|
Predicate |
EqualPredicate.negate() |
Predicate |
NotEqualPredicate.negate() |
Predicate |
GreaterLessPredicate.negate() |
Predicate |
OrPredicate.negate() |
Predicate |
NegatablePredicate.negate()
Create logical negation of itself.
|
Predicate |
NotPredicate.negate() |
Predicate |
AndPredicate.negate() |
<K,V> Predicate<K,V> |
EmptyOptimizer.optimize(Predicate<K,V> predicate,
Indexes indexes) |
<K,V> Predicate<K,V> |
QueryOptimizer.optimize(Predicate<K,V> predicate,
Indexes indexes) |
<K,V> Predicate<K,V> |
RuleBasedQueryOptimizer.optimize(Predicate<K,V> predicate,
Indexes indexes) |
Predicate |
CompositeIndexVisitor.visit(AndPredicate andPredicate,
Indexes indexes) |
Predicate |
FlatteningVisitor.visit(AndPredicate andPredicate,
Indexes indexes) |
Predicate |
RangeVisitor.visit(AndPredicate predicate,
Indexes indexes) |
Predicate |
EvaluateVisitor.visit(AndPredicate andPredicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(AndPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(AndPredicate predicate,
Indexes indexes) |
Predicate |
RangeVisitor.visit(BetweenPredicate predicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(BetweenPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(BetweenPredicate predicate,
Indexes indexes) |
Predicate |
EvaluateVisitor.visit(EqualPredicate predicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(EqualPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(EqualPredicate predicate,
Indexes indexes) |
Predicate |
EvaluateVisitor.visit(InPredicate predicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(InPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(InPredicate predicate,
Indexes indexes) |
Predicate |
EvaluateVisitor.visit(NotEqualPredicate predicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(NotEqualPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(NotEqualPredicate predicate,
Indexes indexes) |
Predicate |
FlatteningVisitor.visit(NotPredicate predicate,
Indexes indexes) |
Predicate |
EvaluateVisitor.visit(NotPredicate notPredicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(NotPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(NotPredicate predicate,
Indexes indexes) |
Predicate |
FlatteningVisitor.visit(OrPredicate orPredicate,
Indexes indexes) |
Predicate |
OrToInVisitor.visit(OrPredicate orPredicate,
Indexes indexes) |
Predicate |
EvaluateVisitor.visit(OrPredicate orPredicate,
Indexes indexes) |
Predicate |
AbstractVisitor.visit(OrPredicate predicate,
Indexes indexes) |
Predicate |
Visitor.visit(OrPredicate predicate,
Indexes indexes) |
Modifier and Type | Method and Description |
---|---|
static Predicate[] |
VisitorUtils.acceptVisitor(Predicate[] predicates,
Visitor visitor,
Indexes indexes)
Accept visitor by all predicates.
|
static boolean |
PredicateUtils.isEqualPredicate(Predicate predicate) |
static boolean |
PredicateUtils.isRangePredicate(Predicate predicate) |
<K,V> Predicate<K,V> |
EmptyOptimizer.optimize(Predicate<K,V> predicate,
Indexes indexes) |
<K,V> Predicate<K,V> |
QueryOptimizer.optimize(Predicate<K,V> predicate,
Indexes indexes) |
<K,V> Predicate<K,V> |
RuleBasedQueryOptimizer.optimize(Predicate<K,V> predicate,
Indexes indexes) |
<K,V> void |
OrPredicate.setPredicates(Predicate<K,V>[] predicates)
Visitable predicates are treated as effectively immutable, therefore callers should not make any changes to
the array passed as argument after is has been set.
|
<K,V> void |
AndPredicate.setPredicates(Predicate<K,V>[] predicates)
Visitable predicates are treated as effectively immutable, therefore callers should not make any changes to
the array passed as argument after is has been set.
|
<K,V> void |
CompoundPredicate.setPredicates(Predicate<K,V>[] predicates)
Set the sub-predicates of this
CompoundPredicate . |
Constructor and Description |
---|
AndPredicate(Predicate... predicates) |
EvaluatePredicate(Predicate predicate,
String indexName)
Constructs
EvaluatePredicate instance for the given predicate
which can be evaluated by the given index identified by its name. |
NotPredicate(Predicate predicate) |
OrPredicate(Predicate... predicates) |
Modifier and Type | Method and Description |
---|---|
String |
ReplicatedMapProxy.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate) |
String |
ReplicatedMapProxy.addEntryListener(EntryListener<K,V> listener,
Predicate<K,V> predicate,
K key) |
Constructor and Description |
---|
ReplicatedQueryEventFilter(Data key,
Predicate predicate) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.