com.hazelcast.map.impl.query

Class QueryRunner

java.lang.Object

com.hazelcast.map.impl.query.QueryRunner

public class QueryRunner
extends Object

Runs query operations in the calling thread (thus blocking it)

Used by query operations only: QueryOperation & QueryPartitionOperation Should not be used by proxies or any other query related objects.

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected LocalMapStatsProvider	localMapStatsProvider
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected NodeEngine	nodeEngine
protected OperationService	operationService
protected PartitionScanExecutor	partitionScanExecutor
protected QueryOptimizer	queryOptimizer
protected QueryResultSizeLimiter	queryResultSizeLimiter
protected ResultProcessorRegistry	resultProcessorRegistry
protected InternalSerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
QueryRunner(MapServiceContext mapServiceContext, QueryOptimizer optimizer, PartitionScanExecutor partitionScanExecutor, ResultProcessorRegistry resultProcessorRegistry)

Method Summary

Modifier and Type	Method and Description
protected Result	populateEmptyResult(Query query, Collection<Integer> initialPartitions)
protected Result	populateNonEmptyResult(Query query, Collection<QueryableEntry> entries, Collection<Integer> initialPartitions)
Result	runIndexOrPartitionScanQueryOnOwnedPartitions(Query query)
Result	runPartitionIndexOrPartitionScanQueryOnGivenOwnedPartition(Query query, int partitionId)
ResultSegment	runPartitionScanQueryOnPartitionChunk(Query query, int partitionId, int tableIndex, int fetchSize) Runs a query on a chunk of a single partition.
protected Collection<QueryableEntry>	runUsingGlobalIndexSafely(Predicate predicate, MapContainer mapContainer, int migrationStamp)
protected Collection<QueryableEntry>	runUsingPartitionScanSafely(String name, Predicate predicate, Collection<Integer> partitions, int migrationStamp)

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

queryOptimizer

protected final QueryOptimizer queryOptimizer

operationService

protected final OperationService operationService

clusterService

protected final ClusterService clusterService

localMapStatsProvider

protected final LocalMapStatsProvider localMapStatsProvider

partitionScanExecutor

protected final PartitionScanExecutor partitionScanExecutor

resultProcessorRegistry

protected final ResultProcessorRegistry resultProcessorRegistry

Constructor Detail

QueryRunner

public QueryRunner(MapServiceContext mapServiceContext,
                   QueryOptimizer optimizer,
                   PartitionScanExecutor partitionScanExecutor,
                   ResultProcessorRegistry resultProcessorRegistry)

Method Detail

runPartitionScanQueryOnPartitionChunk

public ResultSegment runPartitionScanQueryOnPartitionChunk(Query query,
                                                           int partitionId,
                                                           int tableIndex,
                                                           int fetchSize)

Runs a query on a chunk of a single partition. The chunk is defined by the offset tableIndex and the soft limit fetchSize.

Parameters:

query - the query

partitionId - the partition which is queried

tableIndex - the index at which to start querying

fetchSize - the soft limit for the number of items to be queried

Returns:

the queryied entries along with the next tableIndex to resume querying

runIndexOrPartitionScanQueryOnOwnedPartitions

public Result runIndexOrPartitionScanQueryOnOwnedPartitions(Query query)
                                                     throws ExecutionException,
                                                            InterruptedException

Throws:

ExecutionException

InterruptedException

runPartitionIndexOrPartitionScanQueryOnGivenOwnedPartition

public Result runPartitionIndexOrPartitionScanQueryOnGivenOwnedPartition(Query query,
                                                                         int partitionId)

populateEmptyResult

protected Result populateEmptyResult(Query query,
                                     Collection<Integer> initialPartitions)

populateNonEmptyResult

protected Result populateNonEmptyResult(Query query,
                                        Collection<QueryableEntry> entries,
                                        Collection<Integer> initialPartitions)

runUsingGlobalIndexSafely

protected Collection<QueryableEntry> runUsingGlobalIndexSafely(Predicate predicate,
                                                               MapContainer mapContainer,
                                                               int migrationStamp)

runUsingPartitionScanSafely

protected Collection<QueryableEntry> runUsingPartitionScanSafely(String name,
                                                                 Predicate predicate,
                                                                 Collection<Integer> partitions,
                                                                 int migrationStamp)
                                                          throws InterruptedException,
                                                                 ExecutionException

Throws:

InterruptedException

ExecutionException