Package | Description |
---|---|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.map.impl.query |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMapQueryMessageTask<P,QueryResult extends Result,AccumulatedResults,ReducedResult> |
Modifier and Type | Interface and Description |
---|---|
interface |
Result<T extends Result>
Result of a Query.
|
interface |
ResultProcessor<T extends Result>
Responsible for creating query results of a concrete type depending on the type of the Query.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationResult
Contains the result of the evaluation of an aggregation on a specific Partition or Node.
|
class |
QueryResult
Represents a result of the query execution in the form of an iterable
collection of
rows . |
Modifier and Type | Method and Description |
---|---|
<T extends Result> |
QueryEngine.execute(Query query,
Target target)
Executes the given query on the given target.
|
Modifier and Type | Method and Description |
---|---|
Result |
Query.createResult(SerializationService serializationService,
long limit) |
Result |
QueryEngineImpl.execute(Query query,
Target target) |
Result |
ResultSegment.getResult() |
protected Result |
QueryRunner.populateEmptyResult(Query query,
Collection<Integer> initialPartitions) |
protected Result |
QueryRunner.populateNonEmptyResult(Query query,
Collection<QueryableEntry> entries,
Collection<Integer> initialPartitions) |
Result |
QueryRunner.runIndexOrPartitionScanQueryOnOwnedPartitions(Query query) |
Result |
QueryRunner.runIndexQueryOnOwnedPartitions(Query query)
Performs the given query using indexes.
|
Result |
QueryRunner.runPartitionIndexOrPartitionScanQueryOnGivenOwnedPartition(Query query,
int partitionId) |
protected Result |
QueryRunner.runUsingPartitionScanSafely(Query query,
Predicate predicate,
Collection<Integer> partitions,
int migrationStamp) |
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) |
Class<? extends Result> |
Query.getResultType() |
protected Future<Result> |
ParallelPartitionScanExecutor.runPartitionScanForPartition(String name,
Predicate predicate,
int partitionId,
Result result) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
void |
CallerRunsPartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
void |
ParallelPartitionScanExecutor.execute(String mapName,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
void |
PartitionScanRunner.run(String mapName,
Predicate predicate,
int partitionId,
Result result) |
protected Future<Result> |
ParallelPartitionScanExecutor.runPartitionScanForPartition(String name,
Predicate predicate,
int partitionId,
Result result) |
protected void |
ParallelPartitionScanExecutor.runUsingPartitionScanWithoutPaging(String name,
Predicate predicate,
Collection<Integer> partitions,
Result result) |
void |
ResultSegment.setResult(Result result) |
Modifier and Type | Method and Description |
---|---|
ResultProcessor |
ResultProcessorRegistry.get(Class<? extends Result> clazz) |
void |
ResultProcessorRegistry.registerProcessor(Class<? extends Result> clazz,
ResultProcessor processor) |
Constructor and Description |
---|
ResultSegment(Result result,
int nextTableIndexToReadFrom) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.