Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator

Class PageRowLimitingIterator

java.lang.Object

org.elasticsearch.compute.operator.PageRowLimitingIterator

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<Page>, CloseableIterator<Page>

public class PageRowLimitingIterator
extends Object
implements CloseableIterator<Page>

Wrapper around CloseableIterator of Pages that stops yielding pages once a cumulative row budget is exhausted. When the last page would overshoot the budget, it is trimmed to the exact remaining count.

Constructor Summary

Constructors

Constructor	Description
PageRowLimitingIterator(CloseableIterator<Page> delegate, int rowLimit)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
Page	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.compute.operator.CloseableIterator

tryAdvance, waitForReady

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Details

PageRowLimitingIterator

public PageRowLimitingIterator(CloseableIterator<Page> delegate,
 int rowLimit)

Method Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Page>

next

public Page next()

Specified by:

next in interface Iterator<Page>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException