com.hazelcast.map.impl.query

Class CallerRunsPartitionScanExecutor

java.lang.Object

com.hazelcast.map.impl.query.CallerRunsPartitionScanExecutor

All Implemented Interfaces:

PartitionScanExecutor

public class CallerRunsPartitionScanExecutor
extends Object
implements PartitionScanExecutor

Implementation of the PartitionScanExecutor which executes the partition scan in a sequential-fashion in the calling thread.

Constructor Summary

Constructors

Constructor and Description
CallerRunsPartitionScanExecutor(PartitionScanRunner partitionScanRunner)

Method Summary

Modifier and Type	Method and Description
void	execute(String mapName, Predicate predicate, Collection<Integer> partitions, Result result)
QueryableEntriesSegment	execute(String mapName, Predicate predicate, int partitionId, int tableIndex, int fetchSize) Executes the predicate on a partition chunk.

Methods inherited from class java.lang.Object

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

Constructor Detail

CallerRunsPartitionScanExecutor

public CallerRunsPartitionScanExecutor(PartitionScanRunner partitionScanRunner)

Method Detail

execute

public void execute(String mapName,
                    Predicate predicate,
                    Collection<Integer> partitions,
                    Result result)

Specified by:

execute in interface PartitionScanExecutor

execute

public QueryableEntriesSegment execute(String mapName,
                                       Predicate predicate,
                                       int partitionId,
                                       int tableIndex,
                                       int fetchSize)

Description copied from interface: PartitionScanExecutor

Executes the predicate on a partition chunk. The offset in the partition is defined by the tableIndex and the soft limit is defined by the fetchSize. The method returns the matched entries and an index from which new entries can be fetched which allows for efficient iteration of query results.

NOTE Iterating the query results using the returned next table index should be done only when the IMap is not being mutated and the cluster is stable (there are no migrations or membership changes). In other cases, entries are rearranged and the you may get the same query result twice or may miss some query results that match the predicate.

Specified by:

execute in interface PartitionScanExecutor

Parameters:

mapName - the map name

predicate - the predicate which the entries must match

partitionId - the partition which is queried

tableIndex - the index from which entries are queried

fetchSize - the soft limit for the number of entries to fetch

Returns:

entries matching the predicate and a table index from which new entries can be fetched