com.hazelcast.client.map.impl

Class ClientMapPartitionIterator<K,V>

java.lang.Object

com.hazelcast.map.impl.iterator.AbstractMapPartitionIterator<K,V>

com.hazelcast.client.map.impl.ClientMapPartitionIterator<K,V>

All Implemented Interfaces:

Iterator<Map.Entry<K,V>>

public class ClientMapPartitionIterator<K,V>
extends AbstractMapPartitionIterator<K,V>

Iterator for iterating map entries in the 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.

Field Summary

Fields inherited from class com.hazelcast.map.impl.iterator.AbstractMapPartitionIterator

currentIndex, fetchSize, index, lastTableIndex, map, partitionId, prefetchValues, result

Constructor Summary

Constructors

Constructor and Description
ClientMapPartitionIterator(ClientMapProxy<K,V> mapProxy, ClientContext context, int fetchSize, int partitionId, boolean prefetchValues)

Method Summary

Modifier and Type	Method and Description
protected List	fetch()
protected SerializationService	getSerializationService()

Methods inherited from class com.hazelcast.map.impl.iterator.AbstractMapPartitionIterator

advance, hasNext, next, remove, setLastTableIndex

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

ClientMapPartitionIterator

public ClientMapPartitionIterator(ClientMapProxy<K,V> mapProxy,
                                  ClientContext context,
                                  int fetchSize,
                                  int partitionId,
                                  boolean prefetchValues)

Method Detail

fetch

protected List fetch()

Specified by:

fetch in class AbstractMapPartitionIterator<K,V>

getSerializationService

protected SerializationService getSerializationService()

Specified by:

getSerializationService in class AbstractMapPartitionIterator<K,V>