com.hazelcast.map.impl.query

Class MapQueryEngineImpl

java.lang.Object

com.hazelcast.map.impl.query.MapQueryEngineImpl

All Implemented Interfaces:

MapQueryEngine

public class MapQueryEngineImpl
extends Object
implements MapQueryEngine

Invokes and orchestrates the query logic returning the final result.

Knows nothing about query logic or how to dispatch query operations. It relies on QueryDispatcher only. 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 by dispatching query operations using QueryDispatcher and merging the result - QueryDispatcher invokes query operations on the given members and partitions - QueryRunner -> runs the query logic in the calling thread (so like evaluates the predicates and asks the index) TODO: Use bitset instead of collection for partitionIds

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected NodeEngine	nodeEngine
protected OperationService	operationService
protected IPartitionService	partitionService
protected com.hazelcast.map.impl.query.QueryDispatcher	queryDispatcher
protected QueryResultSizeLimiter	queryResultSizeLimiter
protected ResultProcessorRegistry	resultProcessorRegistry
protected InternalSerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
MapQueryEngineImpl(MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
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

Field Detail

mapServiceContext

protected final MapServiceContext mapServiceContext

nodeEngine

protected final NodeEngine nodeEngine

logger

protected final ILogger logger

queryResultSizeLimiter

protected final QueryResultSizeLimiter queryResultSizeLimiter

serializationService

protected final InternalSerializationService serializationService

partitionService

protected final IPartitionService partitionService

operationService

protected final OperationService operationService

clusterService

protected final ClusterService clusterService

queryDispatcher

protected final com.hazelcast.map.impl.query.QueryDispatcher queryDispatcher

resultProcessorRegistry

protected final ResultProcessorRegistry resultProcessorRegistry

Constructor Detail

MapQueryEngineImpl

public MapQueryEngineImpl(MapServiceContext mapServiceContext)

Method Detail

execute

public Result execute(Query query,
                      Target target)

Description copied from interface: MapQueryEngine

Executes the given query on the given target.

Specified by:

execute in interface MapQueryEngine

Parameters:

query - query to execute

target - target where to execute the query

Returns:

Result of the specific type

getQueryResultSizeLimiter

protected QueryResultSizeLimiter getQueryResultSizeLimiter()