| Package | Description | 
|---|---|
| com.hazelcast.map.impl | Contains implementation specific classes of  com.hazelcast.mappackage. | 
| 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  | LazyMapEntryA  Map.Entryimplementation which serializes/de-serializes key and value objects on demand. | 
| 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. doRunUsingPartitionScanOnSinglePartition(String mapName,
                                        Predicate originalPredicate,
                                        int partitionId) | 
| 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. runUsingIndex(Predicate predicate,
             MapContainer mapContainer) | 
| protected Collection<QueryableEntry> | QueryRunner. runUsingIndexSafely(Predicate predicate,
                   MapContainer mapContainer,
                   int initialPartitionStateVersion) | 
| protected Collection<QueryableEntry> | QueryRunner. runUsingPartitionScanSafely(String name,
                           Predicate predicate,
                           Collection<Integer> partitions,
                           int initialPartitionStateVersion) | 
| 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) | 
| 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. | 
| protected Result | QueryRunner. populateTheResult(Query query,
                 Collection<QueryableEntry> entries,
                 Collection<Integer> initialPartitions) | 
| Modifier and Type | Method and Description | 
|---|---|
| Set<QueryableEntry<K,V>> | PagingPredicate. filter(QueryContext queryContext)Used if inner predicate is instanceof  IndexAwarePredicatefor 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  | CachedQueryEntryEntry of the Query. | 
| class  | QueryEntryEntry 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(ConcurrentMap<Data,QueryableEntry> resultSet) | 
| void | MultiResultSet. addResultSet(ConcurrentMap<Data,QueryableEntry> resultSet)TODO | 
| void | DuplicateDetectingMultiResult. addResultSet(ConcurrentMap<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) | 
| SingleResultSet(ConcurrentMap<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 © 2016 Hazelcast, Inc.. All Rights Reserved.