com.hazelcast.map.impl.iterator

Class AbstractMapPartitionIterator<K,V>

java.lang.Object

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

Type Parameters:

K - the key type

V - the value type

All Implemented Interfaces:

Iterator<Map.Entry<K,V>>

Direct Known Subclasses:

ClientMapPartitionIterator, MapPartitionIterator

public abstract class AbstractMapPartitionIterator<K,V>
extends Object
implements Iterator<Map.Entry<K,V>>

Base class for iterating a partition. When iterating you can control:

• the fetch size
• whether values are prefetched or fetched when iterating

Field Summary

Fields

Modifier and Type	Field and Description
protected int	currentIndex
protected int	fetchSize
protected int	index
protected int	lastTableIndex The table is segment table of hash map, which is an array that stores the actual records.
protected IMap<K,V>	map
protected int	partitionId
protected boolean	prefetchValues
protected List	result

Constructor Summary

Constructors

Constructor and Description
AbstractMapPartitionIterator(IMap<K,V> map, int fetchSize, int partitionId, boolean prefetchValues)

Method Summary

Modifier and Type	Method and Description
protected boolean	advance()
protected abstract List	fetch()
protected abstract SerializationService	getSerializationService()
boolean	hasNext()
Map.Entry<K,V>	next()
void	remove()
protected void	setLastTableIndex(List response, int lastTableIndex)

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

Field Detail

map

protected IMap<K,V> map

fetchSize

protected final int fetchSize

partitionId

protected final int partitionId

prefetchValues

protected boolean prefetchValues

lastTableIndex

protected int lastTableIndex

The table is segment table of hash map, which is an array that stores the actual records. This field is used to mark where the latest entry is read.

The iteration will start from highest index available to the table. It will be converted to array size on the server side.

index

protected int index

currentIndex

protected int currentIndex

result

protected List result

Constructor Detail

AbstractMapPartitionIterator

public AbstractMapPartitionIterator(IMap<K,V> map,
                                    int fetchSize,
                                    int partitionId,
                                    boolean prefetchValues)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Map.Entry<K,V>>

next

public Map.Entry<K,V> next()

Specified by:

next in interface Iterator<Map.Entry<K,V>>

remove

public void remove()

Specified by:

remove in interface Iterator<Map.Entry<K,V>>

advance

protected boolean advance()

setLastTableIndex

protected void setLastTableIndex(List response,
                                 int lastTableIndex)

fetch

protected abstract List fetch()

getSerializationService

protected abstract SerializationService getSerializationService()