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(InternalSerializationService serializationService,
Data key,
Object value,
Extractors extractors) |
Modifier and Type | Method and Description |
---|---|
protected Collection<QueryableEntry> |
QueryRunner.runUsingGlobalIndexSafely(Predicate predicate,
MapContainer mapContainer,
int migrationStamp) |
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<K,V>> |
FalsePredicate.filter(QueryContext queryContext) |
Collection<QueryableEntry> |
QueryableEntriesSegment.getEntries() |
Set<QueryableEntry> |
Index.getRecords(Comparable value)
Produces a result set containing entries whose attribute values are equal
to the given value.
|
Set<QueryableEntry> |
IndexImpl.getRecords(Comparable attributeValue) |
Set<QueryableEntry> |
UnsortedIndexStore.getRecords(Comparable value) |
Set<QueryableEntry> |
IndexStore.getRecords(Comparable value) |
Set<QueryableEntry> |
SortedIndexStore.getRecords(Comparable value) |
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> |
IndexImpl.getRecords(Comparable[] values) |
Set<QueryableEntry> |
UnsortedIndexStore.getRecords(Set<Comparable> values) |
Set<QueryableEntry> |
IndexStore.getRecords(Set<Comparable> values) |
Set<QueryableEntry> |
SortedIndexStore.getRecords(Set<Comparable> values) |
Set<QueryableEntry> |
Index.getSubRecords(ComparisonType comparisonType,
Comparable searchedValue)
Produces a result set containing entries whose attribute values are
satisfy the comparison of the given type with the given value.
|
Set<QueryableEntry> |
IndexImpl.getSubRecords(ComparisonType comparisonType,
Comparable searchedAttributeValue) |
Set<QueryableEntry> |
UnsortedIndexStore.getSubRecords(ComparisonType comparisonType,
Comparable searchedValue) |
Set<QueryableEntry> |
IndexStore.getSubRecords(ComparisonType comparisonType,
Comparable searchedValue) |
Set<QueryableEntry> |
SortedIndexStore.getSubRecords(ComparisonType comparisonType,
Comparable searchedValue) |
Set<QueryableEntry> |
Index.getSubRecordsBetween(Comparable from,
Comparable to)
Produces a result set by performing a range query on this index.
|
Set<QueryableEntry> |
IndexImpl.getSubRecordsBetween(Comparable fromAttributeValue,
Comparable toAttributeValue) |
Set<QueryableEntry> |
UnsortedIndexStore.getSubRecordsBetween(Comparable from,
Comparable to) |
Set<QueryableEntry> |
IndexStore.getSubRecordsBetween(Comparable from,
Comparable to) |
Set<QueryableEntry> |
SortedIndexStore.getSubRecordsBetween(Comparable from,
Comparable to) |
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)
Performs a query on this indexes instance using the given predicate.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FastMultiResultSet.add(QueryableEntry obj) |
void |
IndexStore.newIndex(Object newValue,
QueryableEntry entry,
IndexOperationStats operationStats) |
void |
BaseIndexStore.newIndex(Object newValue,
QueryableEntry record,
IndexOperationStats operationStats) |
void |
Index.saveEntryIndex(QueryableEntry entry,
Object oldValue,
Index.OperationSource operationSource)
Saves the given entry into this index.
|
void |
IndexImpl.saveEntryIndex(QueryableEntry entry,
Object oldRecordValue,
Index.OperationSource operationSource) |
void |
Indexes.saveEntryIndex(QueryableEntry queryableEntry,
Object oldValue,
Index.OperationSource operationSource)
Inserts a new queryable entry into this indexes instance or updates the
existing one.
|
void |
IndexStore.updateIndex(Object oldValue,
Object newValue,
QueryableEntry entry,
IndexOperationStats operationStats) |
void |
BaseIndexStore.updateIndex(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> |
BetweenPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
EqualPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
InPredicate.filter(QueryContext queryContext) |
Set<QueryableEntry> |
NotEqualPredicate.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 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 © 2018 Hazelcast, Inc.. All Rights Reserved.