org.infinispan.iteration.impl

Class DistributedEntryRetriever.DistributedItr<C>

java.lang.Object

org.infinispan.iteration.impl.LocalEntryRetriever.Itr<C>

org.infinispan.iteration.impl.DistributedEntryRetriever.DistributedItr<C>

All Implemented Interfaces:

AutoCloseable, Iterator<CacheEntry<K,C>>, CloseableIterator<CacheEntry<K,C>>

Enclosing class:

DistributedEntryRetriever<K,V>

protected class DistributedEntryRetriever.DistributedItr<C>
extends LocalEntryRetriever.Itr<C>

Constructor Summary

Constructors

Constructor and Description
DistributedItr(int batchSize, UUID identifier, EntryRetriever.SegmentListener segmentListener, ConsistentHash hash)

Method Summary

Modifier and Type	Method and Description
void	addKeysForSegment(Map<Integer,ConcurrentHashSet<K>> keysForSegment)
protected void	close(CacheException e)
protected void	finalize()
CacheEntry<K,C>	next()

Methods inherited from class org.infinispan.iteration.impl.LocalEntryRetriever.Itr

addEntries, close, hasNext, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

DistributedItr

public DistributedItr(int batchSize,
                      UUID identifier,
                      EntryRetriever.SegmentListener segmentListener,
                      ConsistentHash hash)

Method Detail

next

public CacheEntry<K,C> next()

Specified by:

next in interface Iterator<CacheEntry<K,C>>

Overrides:

next in class LocalEntryRetriever.Itr<C>

addKeysForSegment

public void addKeysForSegment(Map<Integer,ConcurrentHashSet<K>> keysForSegment)

close

protected void close(CacheException e)

Overrides:

close in class LocalEntryRetriever.Itr<C>

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable