org.infinispan.query.clustered

Class DistributedIterator

java.lang.Object

org.infinispan.query.clustered.DistributedIterator

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<Object>, ResultIterator

Direct Known Subclasses:

DistributedLazyIterator

public class DistributedIterator
extends Object
implements ResultIterator

DistributedIterator. Iterates on a distributed query.

Since:

5.1

Author:

Israel Lacerra , Marko Luksa

Field Summary

Fields

Modifier and Type	Field and Description
protected AdvancedCache<?,?>	cache

Constructor Summary

Constructors

Constructor and Description
DistributedIterator(org.apache.lucene.search.Sort sort, int fetchSize, int resultSize, int maxResults, int firstResult, HashMap<UUID,ClusteredTopDocs> topDocsResponses, AdvancedCache<?,?> cache)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() This method must be called on your iterator once you have finished so that any local or remote resources can be freed up.
protected Object	fetchValue(ClusteredDoc scoreDoc, ClusteredTopDocs topDoc)
boolean	hasNext()
Object	next()
void	remove()

Methods inherited from class java.lang.Object

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

Field Detail

cache

protected final AdvancedCache<?,?> cache

Constructor Detail

DistributedIterator

public DistributedIterator(org.apache.lucene.search.Sort sort,
                   int fetchSize,
                   int resultSize,
                   int maxResults,
                   int firstResult,
                   HashMap<UUID,ClusteredTopDocs> topDocsResponses,
                   AdvancedCache<?,?> cache)

Method Detail

close

public void close()

Description copied from interface: ResultIterator

This method must be called on your iterator once you have finished so that any local or remote resources can be freed up.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ResultIterator

next

public Object next()

Specified by:

next in interface Iterator<Object>

fetchValue

protected Object fetchValue(ClusteredDoc scoreDoc,
                ClusteredTopDocs topDoc)

remove

public void remove()

Specified by:

remove in interface Iterator<Object>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Object>