com.hazelcast.map.impl.query

Class PartitionScanRunner

java.lang.Object

com.hazelcast.map.impl.query.PartitionScanRunner

public class PartitionScanRunner
extends Object

Responsible for running a full-partition scna for a single partition in the calling thread.

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected NodeEngine	nodeEngine
protected OperationService	operationService
protected IPartitionService	partitionService
protected InternalSerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
PartitionScanRunner(MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
protected long	getNow()
protected boolean	isUseCachedDeserializedValuesEnabled(MapContainer mapContainer, int partitionId)
Collection<QueryableEntry>	run(String mapName, Predicate predicate, int partitionId)
QueryableEntriesSegment	run(String mapName, Predicate predicate, int partitionId, int tableIndex, int fetchSize) Executes the predicate on a partition chunk.
protected <T> Object	toData(T input)

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

serializationService

protected final InternalSerializationService serializationService

partitionService

protected final IPartitionService partitionService

operationService

protected final OperationService operationService

clusterService

protected final ClusterService clusterService

Constructor Detail

PartitionScanRunner

public PartitionScanRunner(MapServiceContext mapServiceContext)

Method Detail

run

public Collection<QueryableEntry> run(String mapName,
                                      Predicate predicate,
                                      int partitionId)

run

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

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 map 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, the iterator may not return some entries or may return an entry twice.

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

isUseCachedDeserializedValuesEnabled

protected boolean isUseCachedDeserializedValuesEnabled(MapContainer mapContainer,
                                                       int partitionId)

toData

protected <T> Object toData(T input)

getNow

protected long getNow()