org.apache.paimon.disk

Interface RowBuffer

All Known Implementing Classes:

ExternalBuffer, InMemoryBuffer

public interface RowBuffer

Cache buffer for InternalRow.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	RowBuffer.RowBufferIterator Iterator to fetch record from buffer.

Method Summary

Modifier and Type	Method and Description
void	complete()
boolean	flushMemory()
static RowBuffer	getBuffer(IOManager ioManager, MemorySegmentPool memoryPool, AbstractRowDataSerializer<InternalRow> serializer, boolean spillable, MemorySize maxDiskSize, CompressOptions compression)
long	memoryOccupancy()
RowBuffer.RowBufferIterator	newIterator()
boolean	put(InternalRow row)
void	reset()
int	size()

Method Detail

put

boolean put(InternalRow row)
     throws IOException

Throws:

IOException

size

int size()

memoryOccupancy

long memoryOccupancy()

complete

void complete()

reset

void reset()

flushMemory

boolean flushMemory()
             throws IOException

Throws:

IOException

newIterator

RowBuffer.RowBufferIterator newIterator()

getBuffer

static RowBuffer getBuffer(IOManager ioManager,
                           MemorySegmentPool memoryPool,
                           AbstractRowDataSerializer<InternalRow> serializer,
                           boolean spillable,
                           MemorySize maxDiskSize,
                           CompressOptions compression)