public class IndexQueryReducer<R> extends CacheQueryReducer<R>
IndexQuery results.pageStreams| Constructor and Description |
|---|
IndexQueryReducer(String valType,
Map<UUID,NodePageStream<R>> pageStreams,
GridCacheContext<?,?> cctx,
CompletableFuture<IndexQueryResultMeta> meta) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
R |
nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
protected CompletableFuture<Comparator<NodePage<R>>> |
pageComparator() |
get, removeXhasNext, iterator, next, removeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorforEachRemainingpublic IndexQueryReducer(String valType, Map<UUID,NodePageStream<R>> pageStreams, GridCacheContext<?,?> cctx, CompletableFuture<IndexQueryResultMeta> meta)
protected CompletableFuture<Comparator<NodePage<R>>> pageComparator()
public boolean hasNextX()
throws IgniteCheckedException
Iterator.hasNext(), but allows for failure
with exception. Often iterators are used to iterate through values
that have not or have partially been received from remote nodes,
and need to account for possible network failures, rather than
just returning false out of Iterator.hasNext() method.True if iterator contains more elements.IgniteCheckedException - If no more elements can be returned due
to some failure, like a network error for example.Iterator.hasNext()public R nextX()
throws IgniteCheckedException
Iterator.next(), but allows for failure
with exception. Often iterators are used to iterate through values
that have not or have partially been received from remote nodes,
and need to account for possible network failures, rather than
throwing NoSuchElementException runtime exception.sTrue if iterator contains more elements.IgniteCheckedException - If no more elements can be returned due
to some failure, like a network error for example.Iterator.next()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023