org.apache.paimon.table.source

Class MergeTreeSplitGenerator

java.lang.Object

org.apache.paimon.table.source.MergeTreeSplitGenerator

All Implemented Interfaces:

SplitGenerator

public class MergeTreeSplitGenerator
extends Object
implements SplitGenerator

Merge tree implementation of SplitGenerator.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.source.SplitGenerator

SplitGenerator.SplitGroup

Constructor Summary

Constructors

Constructor and Description
MergeTreeSplitGenerator(Comparator<InternalRow> keyComparator, long targetSplitSize, long openFileCost, boolean deletionVectorsEnabled, CoreOptions.MergeEngine mergeEngine)

Method Summary

Modifier and Type	Method and Description
boolean	alwaysRawConvertible()
List<SplitGenerator.SplitGroup>	splitForBatch(List<DataFileMeta> files)
List<SplitGenerator.SplitGroup>	splitForStreaming(List<DataFileMeta> files)

Methods inherited from class java.lang.Object

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

Constructor Detail

MergeTreeSplitGenerator

public MergeTreeSplitGenerator(Comparator<InternalRow> keyComparator,
                               long targetSplitSize,
                               long openFileCost,
                               boolean deletionVectorsEnabled,
                               CoreOptions.MergeEngine mergeEngine)

Method Detail

alwaysRawConvertible

public boolean alwaysRawConvertible()

Specified by:

alwaysRawConvertible in interface SplitGenerator

splitForBatch

public List<SplitGenerator.SplitGroup> splitForBatch(List<DataFileMeta> files)

Specified by:

splitForBatch in interface SplitGenerator

splitForStreaming

public List<SplitGenerator.SplitGroup> splitForStreaming(List<DataFileMeta> files)

Specified by:

splitForStreaming in interface SplitGenerator