com.hazelcast.client.map.impl

Class ClientMapQueryPartitionIterator<K,V,R>

java.lang.Object

com.hazelcast.map.impl.iterator.AbstractMapQueryPartitionIterator<K,V,R>

com.hazelcast.client.map.impl.ClientMapQueryPartitionIterator<K,V,R>

All Implemented Interfaces:

Iterator<R>

public class ClientMapQueryPartitionIterator<K,V,R>
extends AbstractMapQueryPartitionIterator<K,V,R>

Iterator for iterating map entries in the partitionId. The values are not fetched one-by-one but rather in batches. The Iterator.remove() method is not supported and will throw an UnsupportedOperationException. 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.AbstractMapQueryPartitionIterator

currentIndex, fetchSize, index, lastTableIndex, map, partitionId, query, segment

Constructor Summary

Constructors

Constructor and Description
ClientMapQueryPartitionIterator(ClientMapProxy<K,V> mapProxy, ClientContext context, int fetchSize, int partitionId, Predicate<K,V> predicate, Projection<Map.Entry<K,V>,R> projection)

Method Summary

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

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

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

ClientMapQueryPartitionIterator

public ClientMapQueryPartitionIterator(ClientMapProxy<K,V> mapProxy,
                                       ClientContext context,
                                       int fetchSize,
                                       int partitionId,
                                       Predicate<K,V> predicate,
                                       Projection<Map.Entry<K,V>,R> projection)

Method Detail

fetch

protected List<Data> fetch()

Specified by:

fetch in class AbstractMapQueryPartitionIterator<K,V,R>

getSerializationService

protected SerializationService getSerializationService()

Specified by:

getSerializationService in class AbstractMapQueryPartitionIterator<K,V,R>