org.apache.paimon.mergetree.localmerge

Class HashMapLocalMerger

java.lang.Object

org.apache.paimon.mergetree.localmerge.HashMapLocalMerger

All Implemented Interfaces:

LocalMerger

public class HashMapLocalMerger
extends Object
implements LocalMerger

A LocalMerger which stores records in BytesHashMap.

Constructor Summary

Constructors

Constructor and Description
HashMapLocalMerger(RowType rowType, List<String> primaryKeys, MemorySegmentPool memoryPool, MergeFunction<KeyValue> mergeFunction, FieldsComparator userDefinedSeqComparator)

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

HashMapLocalMerger

public HashMapLocalMerger(RowType rowType,
                          List<String> primaryKeys,
                          MemorySegmentPool memoryPool,
                          MergeFunction<KeyValue> mergeFunction,
                          @Nullable
                          FieldsComparator userDefinedSeqComparator)

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