com.hazelcast.map.impl.query

Interface MapQueryEngine

All Known Implementing Classes:

MapQueryEngineImpl

public interface MapQueryEngine

Responsible for executing queries on the IMap.

Method Summary

Methods

Modifier and Type	Method and Description
QueryResult	invokeQueryAllPartitions(String mapName, Predicate predicate, IterationType iterationType) Queries all partitions.
QueryResult	invokeQueryLocalPartitions(String mapName, Predicate predicate, IterationType iterationType) Query all local partitions.
Set	queryAllPartitionsWithPagingPredicate(String mapName, PagingPredicate pagingPredicate, 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 name, Predicate predicate, IterationType iterationType) Executes a query on all the local partitions.
Set	queryLocalPartitionsWithPagingPredicate(String mapName, PagingPredicate pagingPredicate, IterationType iterationType) Query all local partitions with a paging predicate.

Method Detail

queryLocalPartitions

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

Executes a query on all the local partitions.

Parameters:

name - the name of the map

predicate - the predicate

Returns:

the QueryResult

Throws:

ExecutionException

InterruptedException

queryLocalPartition

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

Executes a query a specific local partition.

todo: what happens when the partition is not local?

Parameters:

mapName - map name.

predicate - any predicate.

partitionId - partition id.

Returns:

result of query

invokeQueryLocalPartitions

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

Query all local partitions.

todo: we need better explanation of difference between this method and queryLocalPartitions(String, Predicate, IterationType)

Parameters:

mapName - map name.

predicate - except paging predicate.

iterationType - the IterationType

invokeQueryAllPartitions

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

Queries all partitions. Paging predicates are not allowed.

Parameters:

mapName - map name.

predicate - except paging predicate.

iterationType - the IterationType

queryLocalPartitionsWithPagingPredicate

Set queryLocalPartitionsWithPagingPredicate(String mapName,
                                          PagingPredicate pagingPredicate,
                                          IterationType iterationType)

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.

Parameters:

mapName - map name.

pagingPredicate - to queryOnMembers.

iterationType - type of IterationType

Returns:

SortedQueryResultSet

queryAllPartitionsWithPagingPredicate

Set queryAllPartitionsWithPagingPredicate(String mapName,
                                        PagingPredicate pagingPredicate,
                                        IterationType iterationType)

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 queryLocalPartitionsWithPagingPredicate(java.lang.String, com.hazelcast.query.PagingPredicate, com.hazelcast.util.IterationType)

Parameters:

mapName - map name.

pagingPredicate - to queryOnMembers.

iterationType - type of IterationType

Returns:

SortedQueryResultSet