public class MapPartitionIterator<K,V> extends AbstractMapPartitionIterator<K,V>
partitionId
. The values are not fetched one-by-one but rather in batches.
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.currentIndex, fetchSize, index, lastTableIndex, map, partitionId, prefetchValues, result
Constructor and Description |
---|
MapPartitionIterator(MapProxyImpl<K,V> mapProxy,
int fetchSize,
int partitionId,
boolean prefetchValues) |
Modifier and Type | Method and Description |
---|---|
protected List |
fetch() |
protected SerializationService |
getSerializationService() |
advance, hasNext, next, remove, setLastTableIndex
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public MapPartitionIterator(MapProxyImpl<K,V> mapProxy, int fetchSize, int partitionId, boolean prefetchValues)
protected List fetch()
fetch
in class AbstractMapPartitionIterator<K,V>
protected SerializationService getSerializationService()
getSerializationService
in class AbstractMapPartitionIterator<K,V>
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.