org.apache.paimon.disk

Class ExternalBuffer

java.lang.Object

org.apache.paimon.disk.ExternalBuffer

All Implemented Interfaces:

RowBuffer

public class ExternalBuffer
extends Object
implements RowBuffer

An external buffer for storing rows, it will spill the data to disk when the memory is full.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ExternalBuffer.BufferIterator Iterator of external buffer.

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()
List<ChannelWithMeta>	getSpillChannels()
long	memoryOccupancy()
RowBuffer.RowBufferIterator	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

complete

public void complete()

Specified by:

complete in interface RowBuffer

newIterator

public RowBuffer.RowBufferIterator newIterator()

Specified by:

newIterator in interface RowBuffer

size

public int size()

Specified by:

size in interface RowBuffer

memoryOccupancy

public long memoryOccupancy()

Specified by:

memoryOccupancy in interface RowBuffer

getSpillChannels

@VisibleForTesting
public List<ChannelWithMeta> getSpillChannels()