org.apache.paimon.mergetree

Class Levels

java.lang.Object

org.apache.paimon.mergetree.Levels

public class Levels
extends Object

A class which stores all level files of merge tree.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Levels.DropFileCallback A callback to notify dropping file.

Constructor Summary

Constructors

Constructor and Description
Levels(Comparator<InternalRow> keyComparator, List<DataFileMeta> inputFiles, int numLevels)

Method Summary

Modifier and Type	Method and Description
void	addDropFileCallback(Levels.DropFileCallback callback)
void	addLevel0File(DataFileMeta file)
List<DataFileMeta>	allFiles()
TreeSet<DataFileMeta>	level0()
List<LevelSortedRun>	levelSortedRuns()
int	maxLevel()
int	nonEmptyHighestLevel()
int	numberOfLevels()
int	numberOfSortedRuns()
SortedRun	runOfLevel(int level)
void	update(List<DataFileMeta> before, List<DataFileMeta> after)

Methods inherited from class java.lang.Object

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

Constructor Detail

Levels

public Levels(Comparator<InternalRow> keyComparator,
              List<DataFileMeta> inputFiles,
              int numLevels)

Method Detail

level0

public TreeSet<DataFileMeta> level0()

addDropFileCallback

public void addDropFileCallback(Levels.DropFileCallback callback)

addLevel0File

public void addLevel0File(DataFileMeta file)

runOfLevel

public SortedRun runOfLevel(int level)

numberOfLevels

public int numberOfLevels()

maxLevel

public int maxLevel()

numberOfSortedRuns

public int numberOfSortedRuns()

nonEmptyHighestLevel

public int nonEmptyHighestLevel()

Returns:

the highest non-empty level or -1 if all levels empty.

allFiles

public List<DataFileMeta> allFiles()

levelSortedRuns

public List<LevelSortedRun> levelSortedRuns()

update

public void update(List<DataFileMeta> before,
                   List<DataFileMeta> after)