org.apache.paimon.disk

Class InMemoryBuffer

java.lang.Object

org.apache.paimon.disk.InMemoryBuffer

All Implemented Interfaces:

RowBuffer

public class InMemoryBuffer
extends Object
implements RowBuffer

Only cache InternalRows in memory.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.disk.RowBuffer

RowBuffer.RowBufferIterator

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.disk.RowBuffer

getBuffer

Method Detail

reset

public void reset()

Specified by:

reset in interface RowBuffer

flushMemory

public boolean flushMemory()
                    throws IOException

Specified by:

flushMemory in interface RowBuffer

Throws:

IOException

put

public boolean put(InternalRow row)
            throws IOException

Specified by:

put in interface RowBuffer

Throws:

IOException

size

public int size()

Specified by:

size in interface RowBuffer

complete

public void complete()

Specified by:

complete in interface RowBuffer

memoryOccupancy

public long memoryOccupancy()

Specified by:

memoryOccupancy in interface RowBuffer

newIterator

public org.apache.paimon.disk.InMemoryBuffer.InMemoryBufferIterator newIterator()

Specified by:

newIterator in interface RowBuffer