public class InMemoryBuffer extends Object implements RowBuffer
InternalRow
s in memory.RowBuffer.RowBufferIterator
Modifier and Type | Method and Description |
---|---|
void |
complete() |
boolean |
flushMemory() |
long |
memoryOccupancy() |
org.apache.paimon.disk.InMemoryBuffer.InMemoryBufferIterator |
newIterator() |
boolean |
put(InternalRow row) |
void |
reset() |
int |
size() |
public boolean flushMemory() throws IOException
flushMemory
in interface RowBuffer
IOException
public boolean put(InternalRow row) throws IOException
put
in interface RowBuffer
IOException
public long memoryOccupancy()
memoryOccupancy
in interface RowBuffer
public org.apache.paimon.disk.InMemoryBuffer.InMemoryBufferIterator newIterator()
newIterator
in interface RowBuffer
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.