com.hazelcast.map.impl.query

Class QueryEngineImpl

java.lang.Object

com.hazelcast.map.impl.query.QueryEngineImpl

All Implemented Interfaces:

QueryEngine

public class QueryEngineImpl
extends Object
implements QueryEngine

Invokes and orchestrates the query logic returning the final result.

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 Summary

Constructors

Constructor and Description
QueryEngineImpl(MapServiceContext mapServiceContext)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryEngineImpl

public QueryEngineImpl(MapServiceContext mapServiceContext)

Method Detail

execute

public Result execute(Query query,
                      Target target)

Description copied from interface: QueryEngine

Executes the given query on the given target.

Specified by:

execute in interface QueryEngine

Parameters:

query - query to execute

target - target where to execute the query

Returns:

Result of the specific type

getQueryResultSizeLimiter

protected QueryResultSizeLimiter getQueryResultSizeLimiter()

dispatchFullQueryOnQueryThread

protected List<Future<Result>> dispatchFullQueryOnQueryThread(Query query,
                                                              Target target)

dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread

protected List<Future<Result>> dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
                                                                                        BitSet partitionIds)

dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread

protected Future<Result> dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
                                                                                  int partitionId)