Package | Description |
---|---|
com.hazelcast.map.impl.iterator | |
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.map.impl.query |
Modifier and Type | Field and Description |
---|---|
protected Query |
AbstractMapQueryPartitionIterator.query |
Modifier and Type | Method and Description |
---|---|
MapOperation |
MapOperationProvider.createFetchWithQueryOperation(String name,
int lastTableIndex,
int fetchSize,
Query query)
Creates an operation for fetching a segment of a query result from a single partition.
|
MapOperation |
DefaultMapOperationProvider.createFetchWithQueryOperation(String name,
int lastTableIndex,
int fetchSize,
Query query) |
MapOperation |
WANAwareOperationProvider.createQueryOperation(Query query) |
MapOperation |
MapOperationProvider.createQueryOperation(Query query) |
MapOperation |
DefaultMapOperationProvider.createQueryOperation(Query query) |
MapOperation |
WANAwareOperationProvider.createQueryPartitionOperation(Query query) |
MapOperation |
MapOperationProvider.createQueryPartitionOperation(Query query) |
MapOperation |
DefaultMapOperationProvider.createQueryPartitionOperation(Query query) |
Constructor and Description |
---|
MapFetchWithQueryOperation(String name,
int lastTableIndex,
int fetchSize,
Query query) |
Modifier and Type | Method and Description |
---|---|
Query |
Query.QueryBuilder.build() |
Modifier and Type | Method and Description |
---|---|
protected List<Future<Result>> |
QueryEngineImpl.dispatchFullQueryOnQueryThread(Query query,
Target target) |
protected List<Future<Result>> |
QueryEngineImpl.dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
BitSet partitionIds) |
protected Future<Result> |
QueryEngineImpl.dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
int partitionId) |
Result |
QueryEngineImpl.execute(Query query,
Target target) |
<T extends Result> |
QueryEngine.execute(Query query,
Target target)
Executes the given query on the given target.
|
static Query.QueryBuilder |
Query.of(Query query) |
protected Result |
QueryRunner.populateEmptyResult(Query query,
Collection<Integer> initialPartitions) |
protected Result |
QueryRunner.populateNonEmptyResult(Query query,
Collection<QueryableEntry> entries,
Collection<Integer> initialPartitions) |
QueryResult |
QueryResultProcessor.populateResult(Query query,
long resultLimit) |
AggregationResult |
AggregationResultProcessor.populateResult(Query query,
long resultLimit) |
T |
ResultProcessor.populateResult(Query query,
long resultLimit)
Populate an empty result for the given query type.
|
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.
|
Result |
QueryRunner.runIndexOrPartitionScanQueryOnOwnedPartitions(Query query) |
Result |
QueryRunner.runIndexQueryOnOwnedPartitions(Query query)
Performs the given query using indexes.
|
Result |
QueryRunner.runPartitionIndexOrPartitionScanQueryOnGivenOwnedPartition(Query query,
int partitionId) |
ResultSegment |
QueryRunner.runPartitionScanQueryOnPartitionChunk(Query query,
int partitionId,
int tableIndex,
int fetchSize)
Runs a query on a chunk of a single partition.
|
protected Result |
QueryRunner.runUsingPartitionScanSafely(Query query,
Predicate predicate,
Collection<Integer> partitions,
int migrationStamp) |
Constructor and Description |
---|
QueryOperation(Query query) |
QueryPartitionOperation(Query query) |
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.