Interface ResettableRowBuffer
-
- All Superinterfaces:
AutoCloseable,Closeable
- All Known Implementing Classes:
ResettableExternalBuffer
public interface ResettableRowBuffer extends Closeable
Resettable buffer that addRowDataand returnBinaryRowDataiterator.Instructions: 1.
reset()2.multiadd(RowData)3.complete()4.multinewIterator()repeat the above steps orCloseable.close().
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceResettableRowBuffer.ResettableIteratorRow iterator that can be reset.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidadd(org.apache.flink.table.data.RowData row)Appends the specified row to the end of this buffer.voidcomplete()Finally, complete add.ResettableRowBuffer.ResettableIteratornewIterator()Get a new iterator starting from first row.ResettableRowBuffer.ResettableIteratornewIterator(int beginRow)Get a new iterator starting from the `beginRow`-th row.voidreset()Re-initialize the buffer state.
-
-
-
Method Detail
-
reset
void reset()
Re-initialize the buffer state.
-
add
void add(org.apache.flink.table.data.RowData row) throws IOException
Appends the specified row to the end of this buffer.- Throws:
IOException
-
complete
void complete()
Finally, complete add.
-
newIterator
ResettableRowBuffer.ResettableIterator newIterator()
Get a new iterator starting from first row.
-
newIterator
ResettableRowBuffer.ResettableIterator newIterator(int beginRow)
Get a new iterator starting from the `beginRow`-th row. `beginRow` is 0-indexed.
-
-