Package | Description |
---|---|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.query | |
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.predicates | |
com.hazelcast.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
Modifier and Type | Class and Description |
---|---|
class |
LazyMapEntry<K,V>
A
Map.Entry implementation which serializes/de-serializes key and value objects on demand. |
class |
LockAwareLazyMapEntry
Specialization of the LazyMapEntry that is LockAware.
|
Modifier and Type | Method and Description |
---|---|
QueryableEntry |
MapContainer.newQueryEntry(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
QueryableEntry |
QueryEntryFactory.newEntry(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
protected Collection<QueryableEntry> |
QueryRunner.runUsingGlobalIndexSafely(Predicate predicate,
MapContainer mapContainer,
int migrationStamp,
int ownedPartitionCount) |
Modifier and Type | Method and Description |
---|---|
void |
AggregationResult.add(QueryableEntry entry) |
void |
QueryResult.add(QueryableEntry entry)
Adds the given entry to this result.
|
void |
Result.add(QueryableEntry entry)
Adds the given entry to this result.
|
Modifier and Type | Method and Description |
---|---|
protected Collection<Aggregator> |
ParallelAccumulationExecutor.accumulateParallel(Aggregator aggregator,
Collection<QueryableEntry> entries) |
AggregationResult |
CallerRunsAccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
AggregationResult |
ParallelAccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
AggregationResult |
AccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
protected Result |
QueryRunner.populateNonEmptyResult(Query query,
Collection<QueryableEntry> entries,
Collection<Integer> initialPartitions) |
QueryResult |
QueryResultProcessor.populateResult(Query query,
long resultLimit,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
AggregationResult |
AggregationResultProcessor.populateResult(Query query,
long resultLimit,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
T |
ResultProcessor.populateResult(Query query,
long resultLimit,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds)
Populate an non-empty result for the given query type.
|
Modifier and Type | Method and Description |
---|---|
Set<QueryableEntry<K,V>> |
PagingPredicate.filter(QueryContext queryContext)
Used if inner predicate is instanceof
IndexAwarePredicate for filtering. |
Set<QueryableEntry<K,V>> |
IndexAwarePredicate.filter(QueryContext queryContext)
Produces a filtered entry set by utilizing the indexes available while
executing the query in the given query context.
|
Set<QueryableEntry> |
PredicateBuilder.filter(QueryContext queryContext) |
Set<QueryableEntry> |
SqlPredicate.filter(QueryContext queryContext) |
Modifier and Type | Class and Description |
---|---|
class |
CachedQueryEntry<K,V>
Entry of the Query.
|
class |
QueryEntry
Entry of the Query.
|
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<K,V>> |
FalsePredicate.filter(QueryContext queryContext) |
Collection<QueryableEntry> |
QueryableEntriesSegment.getEntries() |
Set<QueryableEntry> |
AbstractIndex.getRecords(Comparable value) |
Set<QueryableEntry> |
Index.getRecords(Comparable value)
Produces a result set containing entries whose attribute values are equal
to the given value.
|
Set<QueryableEntry> |
UnorderedIndexStore.getRecords(Comparable value) |
Set<QueryableEntry> |
BitmapIndexStore.getRecords(Comparable value) |
Set<QueryableEntry> |
IndexStore.getRecords(Comparable value)
Obtains entries that have indexed attribute value equal to the given
value.
|
Set<QueryableEntry> |
OrderedIndexStore.getRecords(Comparable value) |
Set<QueryableEntry> |
AbstractIndex.getRecords(Comparable[] values) |
Set<QueryableEntry> |
Index.getRecords(Comparable[] values)
Produces a result set containing entries whose attribute values are equal
to at least one of the given values.
|
Set<QueryableEntry> |
AbstractIndex.getRecords(Comparable from,
boolean fromInclusive,
Comparable to,
boolean toInclusive) |
Set<QueryableEntry> |
Index.getRecords(Comparable from,
boolean fromInclusive,
Comparable to,
boolean toInclusive)
Produces a result set by performing a range query on this index with the
range defined by the passed arguments.
|
Set<QueryableEntry> |
UnorderedIndexStore.getRecords(Comparable from,
boolean fromInclusive,
Comparable to,
boolean toInclusive) |
Set<QueryableEntry> |
BitmapIndexStore.getRecords(Comparable from,
boolean fromInclusive,
Comparable to,
boolean toInclusive) |
Set<QueryableEntry> |
IndexStore.getRecords(Comparable from,
boolean fromInclusive,
Comparable to,
boolean toInclusive)
Obtains entries that have indexed attribute value belonging to the given
range.
|
Set<QueryableEntry> |
OrderedIndexStore.getRecords(Comparable from,
boolean fromInclusive,
Comparable to,
boolean toInclusive) |
Set<QueryableEntry> |
AbstractIndex.getRecords(Comparison comparison,
Comparable value) |
Set<QueryableEntry> |
Index.getRecords(Comparison comparison,
Comparable value)
Produces a result set containing entries whose attribute values are
satisfy the comparison of the given type with the given value.
|
Set<QueryableEntry> |
UnorderedIndexStore.getRecords(Comparison comparison,
Comparable value) |
Set<QueryableEntry> |
BitmapIndexStore.getRecords(Comparison comparison,
Comparable value) |
Set<QueryableEntry> |
IndexStore.getRecords(Comparison comparison,
Comparable value)
Obtains entries that have indexed attribute value satisfying the given
comparison with the given value.
|
Set<QueryableEntry> |
OrderedIndexStore.getRecords(Comparison comparison,
Comparable searchedValue) |
Set<QueryableEntry> |
UnorderedIndexStore.getRecords(Set<Comparable> values) |
Set<QueryableEntry> |
BitmapIndexStore.getRecords(Set<Comparable> values) |
Set<QueryableEntry> |
IndexStore.getRecords(Set<Comparable> values)
Obtains entries that have indexed attribute value equal to one of the
given set of values.
|
Set<QueryableEntry> |
OrderedIndexStore.getRecords(Set<Comparable> values) |
Iterator<QueryableEntry> |
FastMultiResultSet.iterator() |
Iterator<QueryableEntry> |
OrResultSet.iterator() |
Iterator<QueryableEntry> |
AndResultSet.iterator() |
Iterator<QueryableEntry> |
DuplicateDetectingMultiResult.iterator() |
Iterator<QueryableEntry> |
SingleResultSet.iterator() |
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 |
FastMultiResultSet.add(QueryableEntry obj) |
void |
BitmapIndexStore.insert(Object value,
QueryableEntry entry,
IndexOperationStats operationStats) |
void |
IndexStore.insert(Object value,
QueryableEntry entry,
IndexOperationStats operationStats)
Inserts the given entry into this index store under the given value
acting as an index key.
|
void |
BaseSingleValueIndexStore.insert(Object value,
QueryableEntry record,
IndexOperationStats operationStats) |
void |
AbstractIndex.putEntry(QueryableEntry entry,
Object oldValue,
Index.OperationSource operationSource) |
void |
Index.putEntry(QueryableEntry entry,
Object oldValue,
Index.OperationSource operationSource)
Saves the given entry into this index.
|
void |
Indexes.putEntry(QueryableEntry queryableEntry,
Object oldValue,
Index.OperationSource operationSource)
Inserts a new queryable entry into this indexes instance or updates the
existing one.
|
void |
BitmapIndexStore.update(Object oldValue,
Object newValue,
QueryableEntry entry,
IndexOperationStats operationStats) |
void |
IndexStore.update(Object oldValue,
Object newValue,
QueryableEntry entry,
IndexOperationStats operationStats)
Updates the existing entry mapping in this index by remapping it from the
given old value to the new given value.
|
void |
BaseSingleValueIndexStore.update(Object oldValue,
Object newValue,
QueryableEntry entry,
IndexOperationStats operationStats) |
Modifier and Type | Method and Description |
---|---|
void |
FastMultiResultSet.addResultSet(Map<Data,QueryableEntry> resultSet) |
void |
MultiResultSet.addResultSet(Map<Data,QueryableEntry> resultSet)
TODO
|
void |
DuplicateDetectingMultiResult.addResultSet(Map<Data,QueryableEntry> resultSet) |
Constructor and Description |
---|
AndResultSet(Set<QueryableEntry> setSmallest,
List<Set<QueryableEntry>> otherIndexedResults,
List<Predicate> lsNoIndexPredicates) |
AndResultSet(Set<QueryableEntry> setSmallest,
List<Set<QueryableEntry>> otherIndexedResults,
List<Predicate> lsNoIndexPredicates) |
OrResultSet(List<Set<QueryableEntry>> indexedResults) |
QueryableEntriesSegment(Collection<QueryableEntry> entries,
int nextTableIndexToReadFrom) |
SingleResultSet(Map<Data,QueryableEntry> records) |
Modifier and Type | Method and Description |
---|---|
Set<QueryableEntry> |
CompositeRangePredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
BetweenPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
EvaluatePredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
EqualPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
InPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
CompositeEqualPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
NotEqualPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
BoundedRangePredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
GreaterLessPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
OrPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
AndPredicate.filter(QueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
static int |
PredicateUtils.estimatedSizeOf(Collection<QueryableEntry> result)
In case of AndResultSet and OrResultSet calling size() may be very
expensive so quicker estimatedSize() is used.
|
Modifier and Type | Method and Description |
---|---|
static List<QueryableEntry> |
SortingUtil.getSortedSubList(List<QueryableEntry> list,
PagingPredicate pagingPredicate,
Map.Entry<Integer,Map.Entry> nearestAnchorEntry) |
Modifier and Type | Method and Description |
---|---|
static boolean |
SortingUtil.compareAnchor(PagingPredicate pagingPredicate,
QueryableEntry queryEntry,
Map.Entry<Integer,Map.Entry> nearestAnchorEntry) |
Modifier and Type | Method and Description |
---|---|
static List<QueryableEntry> |
SortingUtil.getSortedSubList(List<QueryableEntry> list,
PagingPredicate pagingPredicate,
Map.Entry<Integer,Map.Entry> nearestAnchorEntry) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.