public class QueryEngineImpl extends Object implements QueryEngine
Knows nothing about query logic. Should never invoke any query operations directly.
Should be used from top-level proxy-layer only (e.g. MapProxy, etc.).
Top level-query actors: - QueryEngine orchestrates the queries and merging the result - QueryRunner -> runs the query logic in the calling thread (so like evaluates the predicates and asks the index)
Constructor and Description |
---|
QueryEngineImpl(MapServiceContext mapServiceContext) |
Modifier and Type | Method and Description |
---|---|
protected List<Future<Result>> |
dispatchFullQueryOnQueryThread(Query query,
Target target) |
protected List<Future<Result>> |
dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
BitSet partitionIds) |
protected Future<Result> |
dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
int partitionId) |
Result |
execute(Query query,
Target target)
Executes the given query on the given target.
|
protected QueryResultSizeLimiter |
getQueryResultSizeLimiter() |
public QueryEngineImpl(MapServiceContext mapServiceContext)
public Result execute(Query query, Target target)
QueryEngine
execute
in interface QueryEngine
query
- query to executetarget
- target where to execute the queryprotected QueryResultSizeLimiter getQueryResultSizeLimiter()
protected List<Future<Result>> dispatchFullQueryOnQueryThread(Query query, Target target)
protected List<Future<Result>> dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query, BitSet partitionIds)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.