org.apache.paimon.mergetree.localmerge

Class SortBufferLocalMerger

java.lang.Object

org.apache.paimon.mergetree.localmerge.SortBufferLocalMerger

All Implemented Interfaces:

LocalMerger

public class SortBufferLocalMerger
extends Object
implements LocalMerger

A LocalMerger which stores records in SortBufferWriteBuffer.

Constructor Summary

Constructors

Constructor and Description
SortBufferLocalMerger(SortBufferWriteBuffer sortBuffer, RecordComparator keyComparator, MergeFunction<KeyValue> mergeFunction)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	forEach(java.util.function.Consumer<InternalRow> consumer)
boolean	put(RowKind rowKind, BinaryRow key, InternalRow value)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

SortBufferLocalMerger

public SortBufferLocalMerger(SortBufferWriteBuffer sortBuffer,
                             RecordComparator keyComparator,
                             MergeFunction<KeyValue> mergeFunction)

Method Detail

put

public boolean put(RowKind rowKind,
                   BinaryRow key,
                   InternalRow value)
            throws IOException

Specified by:

put in interface LocalMerger

Throws:

IOException

size

public int size()

Specified by:

size in interface LocalMerger

forEach

public void forEach(java.util.function.Consumer<InternalRow> consumer)
             throws IOException

Specified by:

forEach in interface LocalMerger

Throws:

IOException

clear

public void clear()

Specified by:

clear in interface LocalMerger