org.apache.paimon.mergetree

Class LookupUtils

java.lang.Object

org.apache.paimon.mergetree.LookupUtils

public class LookupUtils
extends Object

Utils for lookup.

Constructor Summary

Constructors

Constructor and Description
LookupUtils()

Method Summary

Modifier and Type	Method and Description
static int	fileKibiBytes(File file)
static <T> T	lookup(Comparator<InternalRow> keyComparator, InternalRow target, SortedRun level, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
static <T> T	lookup(Levels levels, InternalRow key, int startLevel, BiFunctionWithIOE<InternalRow,SortedRun,T> lookup, BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup)
static <T> T	lookupLevel0(Comparator<InternalRow> keyComparator, InternalRow target, TreeSet<DataFileMeta> level0, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupUtils

public LookupUtils()

Method Detail

lookup

public static <T> T lookup(Levels levels,
                           InternalRow key,
                           int startLevel,
                           BiFunctionWithIOE<InternalRow,SortedRun,T> lookup,
                           BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup)
                    throws IOException

Throws:

IOException

lookupLevel0

public static <T> T lookupLevel0(Comparator<InternalRow> keyComparator,
                                 InternalRow target,
                                 TreeSet<DataFileMeta> level0,
                                 BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
                          throws IOException

Throws:

IOException

lookup

public static <T> T lookup(Comparator<InternalRow> keyComparator,
                           InternalRow target,
                           SortedRun level,
                           BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
                    throws IOException

Throws:

IOException

fileKibiBytes

public static int fileKibiBytes(File file)