org.infinispan.query.clustered

Class DistributedLazyIterator

java.lang.Object

org.infinispan.query.clustered.DistributedIterator

org.infinispan.query.clustered.DistributedLazyIterator

All Implemented Interfaces:

Iterator<Object>, ResultIterator

public class DistributedLazyIterator
extends DistributedIterator

DistributedLazyIterator. Lazily iterates on a distributed query

Since:

5.1

Author:

Israel Lacerra

Field Summary

Fields inherited from class org.infinispan.query.clustered.DistributedIterator

cache

Constructor Summary

Constructors

Constructor and Description
DistributedLazyIterator(org.apache.lucene.search.Sort sort, int fetchSize, int resultSize, int maxResults, int firstResult, UUID id, HashMap<UUID,ClusteredTopDocs> topDocsResponses, ExecutorService asyncExecutor, 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)

Methods inherited from class org.infinispan.query.clustered.DistributedIterator

hasNext, next, remove

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedLazyIterator

public DistributedLazyIterator(org.apache.lucene.search.Sort sort,
                       int fetchSize,
                       int resultSize,
                       int maxResults,
                       int firstResult,
                       UUID id,
                       HashMap<UUID,ClusteredTopDocs> topDocsResponses,
                       ExecutorService asyncExecutor,
                       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 ResultIterator

Overrides:

close in class DistributedIterator

fetchValue

protected Object fetchValue(ClusteredDoc scoreDoc,
                ClusteredTopDocs topDoc)

Overrides:

fetchValue in class DistributedIterator