com.hazelcast.cache.impl

Class ClusterWideIterator<K,V>

java.lang.Object

com.hazelcast.cache.impl.AbstractClusterWideIterator<K,V>

com.hazelcast.cache.impl.ClusterWideIterator<K,V>

Type Parameters:

K - key

V - value

All Implemented Interfaces:

Iterator<javax.cache.Cache.Entry<K,V>>

public class ClusterWideIterator<K,V>
extends AbstractClusterWideIterator<K,V>
implements Iterator<javax.cache.Cache.Entry<K,V>>

Cluster-wide iterator for the ICache This cluster key iterator, uses to indexes to iterate the cluster which ar PartitionId and tableIndex. Starting from the largest PartitionId it accesses related partition with a tableIndex. Each partition has a concurrentMap with single segment. So each partition data is basically a concurrent hashMap to iterate on. With a configurable batch size of keys are fetch from partition data, i.e CacheRecordStore. Although keys fetch in batches the AbstractClusterWideIterator.next() returns the entry one by one due to uncertainty of data.

Field Summary

Fields inherited from class com.hazelcast.cache.impl.AbstractClusterWideIterator

cache, currentIndex, fetchSize, index, lastTableIndex, partitionCount, partitionIndex, result

Constructor Summary

Constructors

Constructor and Description
ClusterWideIterator(CacheProxy<K,V> cache)

Method Summary

Methods

Modifier and Type	Method and Description
protected CacheKeyIteratorResult	fetch()
protected Data	toData(Object obj)
protected <T> T	toObject(Object data)

Methods inherited from class com.hazelcast.cache.impl.AbstractClusterWideIterator

advance, ensureOpen, getPartitionCount, hasNext, next, remove

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

hasNext, next, remove

Constructor Detail

ClusterWideIterator

public ClusterWideIterator(CacheProxy<K,V> cache)

Method Detail

fetch

protected CacheKeyIteratorResult fetch()

Specified by:

fetch in class AbstractClusterWideIterator<K,V>

toData

protected Data toData(Object obj)

Specified by:

toData in class AbstractClusterWideIterator<K,V>

toObject

protected <T> T toObject(Object data)

Specified by:

toObject in class AbstractClusterWideIterator<K,V>