public interface SortBuffer
Modifier and Type | Method and Description |
---|---|
void |
clear() |
boolean |
flushMemory()
Flush memory, return false if not supported.
|
long |
getOccupancy() |
int |
size() |
org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> |
sortedIterator() |
boolean |
write(org.apache.flink.table.data.RowData record) |
int size()
void clear()
long getOccupancy()
boolean flushMemory() throws IOException
IOException
boolean write(org.apache.flink.table.data.RowData record) throws IOException
IOException
org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> sortedIterator() throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.