Class WrappedRowIterator<T extends org.apache.flink.table.data.RowData>
- java.lang.Object
-
- org.apache.flink.table.runtime.hashtable.WrappedRowIterator<T>
-
- All Implemented Interfaces:
RowIterator<T>
public class WrappedRowIterator<T extends org.apache.flink.table.data.RowData> extends Object implements RowIterator<T>
WrapMutableObjectIteratorto javaRowIterator.
-
-
Constructor Summary
Constructors Constructor Description WrappedRowIterator(org.apache.flink.util.MutableObjectIterator<T> iterator, T reuse)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanadvanceNext()Advance this iterator by a single row.TgetRow()Retrieve the row from this iterator.
-
-
-
Method Detail
-
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<T extends org.apache.flink.table.data.RowData>
-
getRow
public T 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<T extends org.apache.flink.table.data.RowData>
-
-