Interface RowIterator<T extends org.apache.flink.table.data.RowData>
-
- All Known Subinterfaces:
ResettableRowBuffer.ResettableIterator
- All Known Implementing Classes:
BuildSideIterator,BuildSideIterator.BucketIterator,LongHashPartition.MatchIterator,LookupBucketIterator,ResettableExternalBuffer.BufferIterator,WrappedRowIterator
public interface RowIterator<T extends org.apache.flink.table.data.RowData>An internal iterator interface which presents a more restrictive API thanIterator.One major departure from the Java iterator API is the fusing of the `hasNext()` and `next()` calls: Java's iterator allows users to call `hasNext()` without immediately advancing the iterator to consume the next row, whereas
RowIteratorcombines these calls into a singleadvanceNext()method.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanadvanceNext()Advance this iterator by a single row.TgetRow()Retrieve the row from this iterator.
-
-
-
Method Detail
-
advanceNext
boolean advanceNext()
Advance 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 callinggetRow().
-
getRow
T getRow()
Retrieve the row from this iterator. This method is idempotent. It is illegal to call this method after [[advanceNext()]] has returned `false`.
-
-