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 |
---|---|
Collection<QueryableEntry> |
PartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions) |
Collection<QueryableEntry> |
CallerRunsPartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions) |
List<QueryableEntry> |
ParallelPartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions) |
Collection<QueryableEntry> |
PartitionScanRunner.run(String mapName,
Predicate predicate,
int partitionId) |
protected Future<Collection<QueryableEntry>> |
ParallelPartitionScanExecutor.runPartitionScanForPartition(String name,
Predicate predicate,
int partitionId) |
protected Collection<QueryableEntry> |
QueryRunner.runUsingGlobalIndexSafely(Predicate predicate,
MapContainer mapContainer,
int migrationStamp) |
protected Collection<QueryableEntry> |
QueryRunner.runUsingPartitionScanSafely(String name,
Predicate predicate,
Collection<Integer> partitions,
int migrationStamp) |
protected List<QueryableEntry> |
ParallelPartitionScanExecutor.runUsingPartitionScanWithoutPaging(String name,
Predicate predicate,
Collection<Integer> partitions) |
Modifier and Type | Method and Description |
---|---|
void |
QueryResult.add(QueryableEntry entry,
Projection projection,
SerializationService serializationService) |
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) |
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 |
---|---|
boolean |
FastMultiResultSet.add(QueryableEntry obj) |
void |
IndexStore.newIndex(Object newValue,
QueryableEntry entry) |
void |
BaseIndexStore.newIndex(Object newValue,
QueryableEntry record) |
void |
Index.saveEntryIndex(QueryableEntry e,
Object oldValue)
Add entry to this index.
|
void |
IndexImpl.saveEntryIndex(QueryableEntry entry,
Object oldRecordValue) |
void |
Indexes.saveEntryIndex(QueryableEntry queryableEntry,
Object oldValue) |
void |
IndexStore.updateIndex(Object oldValue,
Object newValue,
QueryableEntry entry) |
void |
BaseIndexStore.updateIndex(Object oldValue,
Object newValue,
QueryableEntry entry) |
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.