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)
Collection<QueryableEntry>	run(String mapName, Predicate predicate, int partitionId)
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)

isUseCachedDeserializedValuesEnabled

protected boolean isUseCachedDeserializedValuesEnabled(MapContainer mapContainer)

toData

protected <T> Object toData(T input)

getNow

protected long getNow()