com.hazelcast.map.impl.query

Class ParallelPartitionScanExecutor

java.lang.Object

com.hazelcast.map.impl.query.ParallelPartitionScanExecutor

All Implemented Interfaces:

PartitionScanExecutor

public class ParallelPartitionScanExecutor
extends Object
implements PartitionScanExecutor

Implementation of the PartitionScanExecutor which executes the partition scan in a parallel-fashion delegating to the underlying executor.

Constructor Summary

Constructors

Constructor and Description
ParallelPartitionScanExecutor(PartitionScanRunner partitionScanRunner, ManagedExecutorService executor, int timeoutInMillis)

Method Summary

Modifier and Type	Method and Description
List<QueryableEntry>	execute(String mapName, Predicate predicate, Collection<Integer> partitions)
protected Future<Collection<QueryableEntry>>	runPartitionScanForPartition(String name, Predicate predicate, int partitionId)
protected List<QueryableEntry>	runUsingPartitionScanWithoutPaging(String name, Predicate predicate, Collection<Integer> partitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelPartitionScanExecutor

public ParallelPartitionScanExecutor(PartitionScanRunner partitionScanRunner,
                                     ManagedExecutorService executor,
                                     int timeoutInMillis)

Method Detail

execute

public List<QueryableEntry> execute(String mapName,
                                    Predicate predicate,
                                    Collection<Integer> partitions)

Specified by:

execute in interface PartitionScanExecutor

runUsingPartitionScanWithoutPaging

protected List<QueryableEntry> runUsingPartitionScanWithoutPaging(String name,
                                                                  Predicate predicate,
                                                                  Collection<Integer> partitions)

runPartitionScanForPartition

protected Future<Collection<QueryableEntry>> runPartitionScanForPartition(String name,
                                                                          Predicate predicate,
                                                                          int partitionId)