org.apache.paimon.table.source

Class AppendOnlySplitGenerator

java.lang.Object

org.apache.paimon.table.source.AppendOnlySplitGenerator

All Implemented Interfaces:

SplitGenerator

public class AppendOnlySplitGenerator
extends Object
implements SplitGenerator

Append only 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
AppendOnlySplitGenerator(long targetSplitSize, long openFileCost, BucketMode bucketMode)

Method Summary

Modifier and Type	Method and Description
boolean	alwaysRawConvertible()
List<SplitGenerator.SplitGroup>	splitForBatch(List<DataFileMeta> input)
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

AppendOnlySplitGenerator

public AppendOnlySplitGenerator(long targetSplitSize,
                                long openFileCost,
                                BucketMode bucketMode)

Method Detail

alwaysRawConvertible

public boolean alwaysRawConvertible()

Specified by:

alwaysRawConvertible in interface SplitGenerator

splitForBatch

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

Specified by:

splitForBatch in interface SplitGenerator

splitForStreaming

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

Specified by:

splitForStreaming in interface SplitGenerator