public class FilteredWalIterator extends GridIteratorAdapter<IgniteBiTuple<WALPointer,WALRecord>> implements WALIterator
| Constructor and Description |
|---|
FilteredWalIterator(WALIterator walIterator,
Predicate<IgniteBiTuple<WALPointer,WALRecord>> filter) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes the iterator and frees all the resources held by the iterator.
|
boolean |
hasNextX()
This method is the same as
Iterator.hasNext(), but allows for failure
with exception. |
boolean |
isClosed()
Checks if iterator has been closed.
|
Optional<WALPointer> |
lastRead() |
IgniteBiTuple<WALPointer,WALRecord> |
nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
void |
removeX()
This method is the same as
Iterator.remove(), but allows for failure
with exception. |
hasNext, iterator, next, removeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, iterator, spliteratorforEachRemaining, hasNext, next, removepublic FilteredWalIterator(WALIterator walIterator, Predicate<IgniteBiTuple<WALPointer,WALRecord>> filter) throws IgniteCheckedException
walIterator - Source WAL iterator which provide data for filtering.filter - Filter for filtering iterated data.IgniteCheckedExceptionpublic Optional<WALPointer> lastRead()
lastRead in interface WALIteratorpublic IgniteBiTuple<WALPointer,WALRecord> 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.snextX in interface GridIterator<IgniteBiTuple<WALPointer,WALRecord>>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.next()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.hasNextX in interface GridIterator<IgniteBiTuple<WALPointer,WALRecord>>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 void removeX()
throws IgniteCheckedException
Iterator.remove(), but allows for failure
with exception.removeX in interface GridIterator<IgniteBiTuple<WALPointer,WALRecord>>IgniteCheckedException - If failed.public void close()
throws IgniteCheckedException
The method is invoked automatically on objects managed by the
try-with-resources statement.
close in interface AutoCloseableclose in interface GridCloseableIterator<IgniteBiTuple<WALPointer,WALRecord>>close in interface IgniteSpiCloseableIterator<IgniteBiTuple<WALPointer,WALRecord>>IgniteCheckedException - In case of error.public boolean isClosed()
isClosed in interface GridCloseableIterator<IgniteBiTuple<WALPointer,WALRecord>>True if iterator has been closed.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.1 Release Date : December 9 2020