Class ResettableExternalBuffer.BufferIterator
- java.lang.Object
-
- org.apache.flink.table.runtime.util.ResettableExternalBuffer.BufferIterator
-
- All Implemented Interfaces:
Closeable,AutoCloseable,ResettableRowBuffer.ResettableIterator,RowIterator<org.apache.flink.table.data.binary.BinaryRowData>
- Enclosing class:
- ResettableExternalBuffer
public class ResettableExternalBuffer.BufferIterator extends Object implements ResettableRowBuffer.ResettableIterator
Iterator of external buffer.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanadvanceNext()Advance this iterator by a single row.voidclose()org.apache.flink.table.data.binary.BinaryRowDatagetRow()Retrieve the row from this iterator.voidreset()Re-initialize the iterator, start from begin row.
-
-
-
Method Detail
-
reset
public void reset() throws IOExceptionDescription copied from interface:ResettableRowBuffer.ResettableIteratorRe-initialize the iterator, start from begin row.- Specified by:
resetin interfaceResettableRowBuffer.ResettableIterator- Throws:
IOException
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
advanceNext
public boolean advanceNext()
Description copied from interface:RowIteratorAdvance this iterator by a single row. Returns `false` if this iterator has no more rows and `true` otherwise. If this returns `true`, then the new row can be retrieved by callingRowIterator.getRow().- Specified by:
advanceNextin interfaceRowIterator<org.apache.flink.table.data.binary.BinaryRowData>
-
getRow
public org.apache.flink.table.data.binary.BinaryRowData getRow()
Description copied from interface:RowIteratorRetrieve the row from this iterator. This method is idempotent. It is illegal to call this method after [[advanceNext()]] has returned `false`.- Specified by:
getRowin interfaceRowIterator<org.apache.flink.table.data.binary.BinaryRowData>
-
-