Package org.apache.ignite.internal.cdc
Class WalRecordsConsumer.DataEntryIterator
- java.lang.Object
-
- org.apache.ignite.internal.cdc.WalRecordsConsumer.DataEntryIterator
-
- All Implemented Interfaces:
AutoCloseable,Iterator<DataEntry>
- Enclosing class:
- WalRecordsConsumer<K,V>
public static class WalRecordsConsumer.DataEntryIterator extends Object implements Iterator<DataEntry>, AutoCloseable
Iterator overDataEntry.
-
-
Constructor Summary
Constructors Constructor Description DataEntryIterator(WALIterator walIter, HistogramMetricImpl evtCaptureTime)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()booleanhasNext()DataEntrynext()T2<WALPointer,Integer>state()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.util.Iterator
forEachRemaining, remove
-
-
-
-
Constructor Detail
-
DataEntryIterator
public DataEntryIterator(WALIterator walIter, HistogramMetricImpl evtCaptureTime)
- Parameters:
walIter- WAL iterator.evtCaptureTime- Event capture time metric.
-
-
Method Detail
-
state
public T2<WALPointer,Integer> state()
- Returns:
- Current state.
-
close
public void close() throws IgniteCheckedException- Specified by:
closein interfaceAutoCloseable- Throws:
IgniteCheckedException
-
-