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 IPartitionService	partitionService
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 Collection<QueryableEntry>	doRunUsingPartitionScanOnSinglePartition(String mapName, Predicate originalPredicate, int partitionId)
protected boolean	hasOwnerMigrationsInFlight() Check whether migrations of owner partition are currently executed.
protected boolean	hasPartitionStateVersionChanged(int initialPartitionStateVersion) Check whether partition state version has changed since initialPartitionStateVersion.
protected boolean	hasPartitionVersion(int expectedVersion, Predicate predicate)
protected boolean	isResultSafe(int initialPartitionStateVersion) Check whether results obtained since partition state version was at initialPartitionStateVersion are safe to be returned to the caller.
protected Result	populateTheResult(Query query, Collection<QueryableEntry> entries, Collection<Integer> initialPartitions)
Result	run(Query query)
protected Collection<QueryableEntry>	runUsingIndex(Predicate predicate, MapContainer mapContainer)
protected Collection<QueryableEntry>	runUsingIndexSafely(Predicate predicate, MapContainer mapContainer, int initialPartitionStateVersion)
Result	runUsingPartitionScanOnSinglePartition(Query query, int partitionId)
protected Collection<QueryableEntry>	runUsingPartitionScanSafely(String name, Predicate predicate, Collection<Integer> partitions, int initialPartitionStateVersion)
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

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

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

run

public Result run(Query query)
           throws ExecutionException,
                  InterruptedException

Throws:

ExecutionException

InterruptedException

populateTheResult

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

runUsingIndexSafely

protected Collection<QueryableEntry> runUsingIndexSafely(Predicate predicate,
                                                         MapContainer mapContainer,
                                                         int initialPartitionStateVersion)

runUsingIndex

protected Collection<QueryableEntry> runUsingIndex(Predicate predicate,
                                                   MapContainer mapContainer)

runUsingPartitionScanSafely

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

Throws:

InterruptedException

ExecutionException

runUsingPartitionScanOnSinglePartition

public Result runUsingPartitionScanOnSinglePartition(Query query,
                                                     int partitionId)
                                              throws ExecutionException,
                                                     InterruptedException

Throws:

ExecutionException

InterruptedException

doRunUsingPartitionScanOnSinglePartition

protected Collection<QueryableEntry> doRunUsingPartitionScanOnSinglePartition(String mapName,
                                                                              Predicate originalPredicate,
                                                                              int partitionId)
                                                                       throws ExecutionException,
                                                                              InterruptedException

Throws:

ExecutionException

InterruptedException

hasOwnerMigrationsInFlight

protected boolean hasOwnerMigrationsInFlight()

Check whether migrations of owner partition are currently executed. If a migration is in progress, do not attempt to use an index as they may have not been created yet. MapService.getMigrationsInFlight() returns the number of currently executing migrations (for which beforeMigration has been executed but commit/rollback is not yet executed). This check is a temporary fix for 3.7, the actual issue will be addressed with an additional migration hook in 3.8. see https://github.com/hazelcast/hazelcast/issues/6471 & https://github.com/hazelcast/hazelcast/issues/8046

Returns:

true if owner partition migrations are currently being executed, otherwise false.

See Also:

CountingMigrationAwareService

hasPartitionStateVersionChanged

protected boolean hasPartitionStateVersionChanged(int initialPartitionStateVersion)

Check whether partition state version has changed since initialPartitionStateVersion.

Parameters:

initialPartitionStateVersion - the initial partition state version to compare against

Returns:

true if current partition state version is not equal to initialPartitionStateVersion

isResultSafe

protected boolean isResultSafe(int initialPartitionStateVersion)

Check whether results obtained since partition state version was at initialPartitionStateVersion are safe to be returned to the caller. Effectively this method checks:

• whether owner migrations are currently in flight; if there are any, then results are considered flawed
• whether current partition state version has changed, implying that some migrations were executed in the meanwhile, so results are again considered flawed

Parameters:

initialPartitionStateVersion -

Returns:

true if no owner migrations are currently executing and initialPartitionStateVersion is the same as the current partition state version, otherwise false.

hasPartitionVersion

protected boolean hasPartitionVersion(int expectedVersion,
                                      Predicate predicate)

updateStatistics

protected void updateStatistics(MapContainer mapContainer)