|Constructor and Description|
|Modifier and Type||Method and Description|
Executes the predicate on a partition chunk.
public CallerRunsPartitionScanExecutor(PartitionScanRunner partitionScanRunner)
public void execute(String mapName, Predicate predicate, Collection<Integer> partitions, Result result)
public QueryableEntriesSegment execute(String mapName, Predicate predicate, int partitionId, int tableIndex, int fetchSize)
tableIndexand 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.
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.
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
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.