org.apache.paimon.mergetree

Class LookupLevels.PositionedKeyValueProcessor

java.lang.Object

org.apache.paimon.mergetree.LookupLevels.PositionedKeyValueProcessor

All Implemented Interfaces:

LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>

Enclosing class:

LookupLevels<T>

public static class LookupLevels.PositionedKeyValueProcessor
extends Object
implements LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>

A LookupLevels.ValueProcessor to return LookupLevels.PositionedKeyValue.

Constructor Summary

Constructors

Constructor and Description
PositionedKeyValueProcessor(RowType valueType, boolean persistValue)

Method Summary

Modifier and Type	Method and Description
byte[]	persistToDisk(KeyValue kv)
byte[]	persistToDisk(KeyValue kv, long rowPosition)
LookupLevels.PositionedKeyValue	readFromDisk(InternalRow key, int level, byte[] bytes, String fileName)
boolean	withPosition()

Methods inherited from class java.lang.Object

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

Constructor Detail

PositionedKeyValueProcessor

public PositionedKeyValueProcessor(RowType valueType,
                                   boolean persistValue)

Method Detail

withPosition

public boolean withPosition()

Specified by:

withPosition in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>

persistToDisk

public byte[] persistToDisk(KeyValue kv)

Specified by:

persistToDisk in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>

persistToDisk

public byte[] persistToDisk(KeyValue kv,
                            long rowPosition)

Specified by:

persistToDisk in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>

readFromDisk

public LookupLevels.PositionedKeyValue readFromDisk(InternalRow key,
                                                    int level,
                                                    byte[] bytes,
                                                    String fileName)

Specified by:

readFromDisk in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>