org.apache.paimon.append

Class UnawareBucketNewFilesCompactionCoordinator

java.lang.Object

org.apache.paimon.append.UnawareBucketNewFilesCompactionCoordinator

public class UnawareBucketNewFilesCompactionCoordinator
extends Object

Buffer files from the same partition, until their total size reaches targetFileSize.

Constructor Summary

Constructors

Constructor and Description
UnawareBucketNewFilesCompactionCoordinator(long targetFileSize)

Method Summary

Modifier and Type	Method and Description
Optional<Pair<BinaryRow,List<DataFileMeta>>>	addFile(BinaryRow partition, DataFileMeta file)
List<Pair<BinaryRow,List<DataFileMeta>>>	emitAll()

Methods inherited from class java.lang.Object

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

Constructor Detail

UnawareBucketNewFilesCompactionCoordinator

public UnawareBucketNewFilesCompactionCoordinator(long targetFileSize)

Method Detail

addFile

public Optional<Pair<BinaryRow,List<DataFileMeta>>> addFile(BinaryRow partition,
                                                            DataFileMeta file)

emitAll

public List<Pair<BinaryRow,List<DataFileMeta>>> emitAll()