org.infinispan.query.clustered
Class DistributedLazyIterator

java.lang.Object
  org.infinispan.query.impl.AbstractIterator
      org.infinispan.query.clustered.DistributedIterator
          org.infinispan.query.clustered.DistributedLazyIterator

All Implemented Interfaces:

Iterator<Object>, ListIterator<Object>, QueryIterator

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.impl.AbstractIterator

buffer, bufferIndex, cache, fetchSize, first, index, max

Constructor Summary

DistributedLazyIterator(org.apache.lucene.search.Sort sort, int fetchSize, int resultSize, UUID id, HashMap<UUID,ClusteredTopDocs> topDocsResponses, ExecutorService asyncExecutor, AdvancedCache<?,?> cache)

Method Summary

void	close() This method must be called on your iterator once you have finished so that Lucene resources can be freed up.
protected Object	fetchValue(ClusteredDoc scoreDoc, ClusteredTopDocs topDoc)

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

add, hasNext, jumpToResult, next, nextIndex, previous, previousIndex, remove, set

Methods inherited from class org.infinispan.query.impl.AbstractIterator

afterFirst, beforeLast, first, hasPrevious, isAfterFirst, isBeforeLast, isFirst, isLast, last

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,
                               UUID id,
                               HashMap<UUID,ClusteredTopDocs> topDocsResponses,
                               ExecutorService asyncExecutor,
                               AdvancedCache<?,?> cache)

Method Detail

close

public void close()

Description copied from interface: QueryIterator

This method must be called on your iterator once you have finished so that Lucene resources can be freed up.

Specified by:

close in interface QueryIterator

Overrides:

close in class DistributedIterator

fetchValue

protected Object fetchValue(ClusteredDoc scoreDoc,
                            ClusteredTopDocs topDoc)

Overrides:

fetchValue in class DistributedIterator