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

The MapQueryEngine implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	MapQueryEngineImpl.QueryPartitionCallable

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected ManagedExecutorService	executor
protected LocalMapStatsProvider	localMapStatsProvider
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected NodeEngine	nodeEngine
protected OperationService	operationService
protected boolean	parallelEvaluation
protected InternalPartitionService	partitionService
protected static long	QUERY_EXECUTION_TIMEOUT_MINUTES
protected QueryOptimizer	queryOptimizer
protected QueryResultSizeLimiter	queryResultSizeLimiter
protected SerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
MapQueryEngineImpl(MapServiceContext mapServiceContext, QueryOptimizer optimizer)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addResultsOfPagingPredicate(List<Future<QueryResult>> futures, Collection result, Collection<Integer> partitionIds) Adds results of paging predicates to result set and removes queried partition ids.
protected void	addResultsOfPredicate(List<Future<QueryResult>> futures, QueryResult result, Collection<Integer> partitionIds) Adds results of non-paging predicates to result set and removes queried partition ids.
protected void	checkNotPagingPredicate(Predicate predicate)
protected Set<Integer>	createSetWithPopulatedPartitionIds(int partitionCount)
protected Set<Integer>	getAllPartitionIds()
protected List<Integer>	getLocalPartitionIds()
protected long	getNow()
protected static Collection<Collection<QueryableEntry>>	getResult(List<Future<Collection<QueryableEntry>>> lsFutures)
protected boolean	hasPartitionVersion(int expectedVersion, Predicate predicate)
QueryResult	invokeQueryAllPartitions(String mapName, Predicate predicate, IterationType iterationType) Queries all partitions.
QueryResult	invokeQueryLocalPartitions(String mapName, Predicate predicate, IterationType iterationType) Query all local partitions.
protected QueryResult	newQueryResult(int numberOfPartitions, IterationType iterationType) Creates a QueryResult with configured result limit (according to the number of partitions) if feature is enabled.
Set	queryAllPartitionsWithPagingPredicate(String mapName, PagingPredicate predicate, IterationType iterationType) Queries all partitions with a paging predicate.
QueryResult	queryLocalPartition(String mapName, Predicate predicate, int partitionId, IterationType iterationType) Executes a query a specific local partition.
QueryResult	queryLocalPartitions(String mapName, Predicate predicate, IterationType iterationType) Executes a query on all the local partitions.
Set	queryLocalPartitionsWithPagingPredicate(String mapName, PagingPredicate predicate, IterationType iterationType) Query all local partitions with a paging predicate.
protected Future<QueryResult>	queryOnLocalMember(String mapName, Predicate predicate, IterationType iterationType)
protected List<Future<QueryResult>>	queryOnMembers(String mapName, Predicate predicate, IterationType iterationType)
protected QueryResult	queryParallel(String name, Predicate predicate, Collection<Integer> partitions, IterationType iterationType)
protected QueryResult	queryParallelForPaging(String name, PagingPredicate predicate, Collection<Integer> partitions, IterationType iterationType)
protected List<Future<QueryResult>>	queryPartitions(String mapName, Predicate predicate, Collection<Integer> partitionIds, IterationType iterationType)
protected QueryResult	querySequential(String name, Predicate predicate, Collection<Integer> partitions, IterationType iterationType)
protected Collection<QueryableEntry>	queryTheLocalPartition(String mapName, Predicate predicate, int partitionId)
protected QueryResult	queryUsingFullTableScan(String name, Predicate predicate, Collection<Integer> partitions, IterationType iterationType)
protected Object	toObject(Object obj)
protected QueryResult	tryQueryUsingIndexes(Predicate predicate, Collection<Integer> partitions, MapContainer mapContainer, IterationType iterationType)
protected void	updateStatistics(MapContainer mapContainer)

Methods inherited from class java.lang.Object

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

Field Detail

QUERY_EXECUTION_TIMEOUT_MINUTES

protected static final long QUERY_EXECUTION_TIMEOUT_MINUTES

See Also:

Constant Field Values

mapServiceContext

protected final MapServiceContext mapServiceContext

nodeEngine

protected final NodeEngine nodeEngine

logger

protected final ILogger logger

queryResultSizeLimiter

protected final QueryResultSizeLimiter queryResultSizeLimiter

serializationService

protected final SerializationService serializationService

partitionService

protected final InternalPartitionService partitionService

queryOptimizer

protected final QueryOptimizer queryOptimizer

operationService

protected final OperationService operationService

clusterService

protected final ClusterService clusterService

localMapStatsProvider

protected final LocalMapStatsProvider localMapStatsProvider

parallelEvaluation

protected final boolean parallelEvaluation

executor

protected final ManagedExecutorService executor

Constructor Detail

MapQueryEngineImpl

public MapQueryEngineImpl(MapServiceContext mapServiceContext,
                  QueryOptimizer optimizer)

Method Detail

queryLocalPartitions

public QueryResult queryLocalPartitions(String mapName,
                               Predicate predicate,
                               IterationType iterationType)
                                 throws ExecutionException,
                                        InterruptedException

Description copied from interface: MapQueryEngine

Executes a query on all the local partitions.

Specified by:

queryLocalPartitions in interface MapQueryEngine

Parameters:

mapName - the name of the map

predicate - the predicate

Returns:

the QueryResult

Throws:

ExecutionException

InterruptedException

tryQueryUsingIndexes

protected QueryResult tryQueryUsingIndexes(Predicate predicate,
                               Collection<Integer> partitions,
                               MapContainer mapContainer,
                               IterationType iterationType)

updateStatistics

protected void updateStatistics(MapContainer mapContainer)

queryUsingFullTableScan

protected QueryResult queryUsingFullTableScan(String name,
                                  Predicate predicate,
                                  Collection<Integer> partitions,
                                  IterationType iterationType)
                                       throws InterruptedException,
                                              ExecutionException

Throws:

InterruptedException

ExecutionException

querySequential

protected QueryResult querySequential(String name,
                          Predicate predicate,
                          Collection<Integer> partitions,
                          IterationType iterationType)

queryParallel

protected QueryResult queryParallel(String name,
                        Predicate predicate,
                        Collection<Integer> partitions,
                        IterationType iterationType)
                             throws InterruptedException,
                                    ExecutionException

Throws:

InterruptedException

ExecutionException

queryParallelForPaging

protected QueryResult queryParallelForPaging(String name,
                                 PagingPredicate predicate,
                                 Collection<Integer> partitions,
                                 IterationType iterationType)
                                      throws InterruptedException,
                                             ExecutionException

Throws:

InterruptedException

ExecutionException

getResult

protected static Collection<Collection<QueryableEntry>> getResult(List<Future<Collection<QueryableEntry>>> lsFutures)

hasPartitionVersion

protected boolean hasPartitionVersion(int expectedVersion,
                          Predicate predicate)

queryTheLocalPartition

protected Collection<QueryableEntry> queryTheLocalPartition(String mapName,
                                                Predicate predicate,
                                                int partitionId)

queryLocalPartition

public QueryResult queryLocalPartition(String mapName,
                              Predicate predicate,
                              int partitionId,
                              IterationType iterationType)

Description copied from interface: MapQueryEngine

Executes a query a specific local partition. todo: what happens when the partition is not local?

Specified by:

queryLocalPartition in interface MapQueryEngine

Parameters:

mapName - map name.

predicate - any predicate.

partitionId - partition id.

Returns:

result of query

invokeQueryLocalPartitions

public QueryResult invokeQueryLocalPartitions(String mapName,
                                     Predicate predicate,
                                     IterationType iterationType)

Description copied from interface: MapQueryEngine

Query all local partitions. todo: we need better explanation of difference between this method and MapQueryEngine.queryLocalPartitions(String, Predicate, IterationType)

Specified by:

invokeQueryLocalPartitions in interface MapQueryEngine

Parameters:

mapName - map name.

predicate - except paging predicate.

iterationType - the IterationType

queryLocalPartitionsWithPagingPredicate

public Set queryLocalPartitionsWithPagingPredicate(String mapName,
                                          PagingPredicate predicate,
                                          IterationType iterationType)

Description copied from interface: MapQueryEngine

Query all local partitions with a paging predicate. todo: it would be better to have a single queryLocal... method and let the implementation figure out how to deal with a regular predicate and a paging predicate. No need to have that in the interface. The problem is that currently the signatures don't match up. This implementation detail should not be exposed through the interface.

Specified by:

queryLocalPartitionsWithPagingPredicate in interface MapQueryEngine

Parameters:

mapName - map name.

predicate - to queryOnMembers.

iterationType - type of IterationType

Returns:

SortedQueryResultSet

queryAllPartitionsWithPagingPredicate

public Set queryAllPartitionsWithPagingPredicate(String mapName,
                                        PagingPredicate predicate,
                                        IterationType iterationType)

Description copied from interface: MapQueryEngine

Queries all partitions with a paging predicate. todo: it would be better to have single queryAll method and let the implementation figure out how to deal with a paging predicate. See comment in MapQueryEngine.queryLocalPartitionsWithPagingPredicate(java.lang.String, com.hazelcast.query.PagingPredicate, com.hazelcast.util.IterationType)

Specified by:

queryAllPartitionsWithPagingPredicate in interface MapQueryEngine

Parameters:

mapName - map name.

predicate - to queryOnMembers.

iterationType - type of IterationType

Returns:

SortedQueryResultSet

invokeQueryAllPartitions

public QueryResult invokeQueryAllPartitions(String mapName,
                                   Predicate predicate,
                                   IterationType iterationType)

Description copied from interface: MapQueryEngine

Queries all partitions. Paging predicates are not allowed.

Specified by:

invokeQueryAllPartitions in interface MapQueryEngine

Parameters:

mapName - map name.

predicate - except paging predicate.

iterationType - the IterationType

newQueryResult

protected QueryResult newQueryResult(int numberOfPartitions,
                         IterationType iterationType)

Creates a QueryResult with configured result limit (according to the number of partitions) if feature is enabled.

Parameters:

numberOfPartitions - number of partitions to calculate result limit

Returns:

QueryResult

checkNotPagingPredicate

protected void checkNotPagingPredicate(Predicate predicate)

queryOnLocalMember

protected Future<QueryResult> queryOnLocalMember(String mapName,
                                     Predicate predicate,
                                     IterationType iterationType)

queryOnMembers

protected List<Future<QueryResult>> queryOnMembers(String mapName,
                                       Predicate predicate,
                                       IterationType iterationType)

queryPartitions

protected List<Future<QueryResult>> queryPartitions(String mapName,
                                        Predicate predicate,
                                        Collection<Integer> partitionIds,
                                        IterationType iterationType)

addResultsOfPagingPredicate

protected void addResultsOfPagingPredicate(List<Future<QueryResult>> futures,
                               Collection result,
                               Collection<Integer> partitionIds)
                                    throws ExecutionException,
                                           InterruptedException

Adds results of paging predicates to result set and removes queried partition ids.

Throws:

ExecutionException

InterruptedException

addResultsOfPredicate

protected void addResultsOfPredicate(List<Future<QueryResult>> futures,
                         QueryResult result,
                         Collection<Integer> partitionIds)
                              throws ExecutionException,
                                     InterruptedException

Adds results of non-paging predicates to result set and removes queried partition ids.

Throws:

ExecutionException

InterruptedException

toObject

protected Object toObject(Object obj)

getLocalPartitionIds

protected List<Integer> getLocalPartitionIds()

getAllPartitionIds

protected Set<Integer> getAllPartitionIds()

createSetWithPopulatedPartitionIds

protected Set<Integer> createSetWithPopulatedPartitionIds(int partitionCount)

getNow

protected long getNow()