org.apache.paimon.deletionvectors.append

Interface AppendDeletionFileMaintainer

All Known Implementing Classes:

BucketedAppendDeletionFileMaintainer, UnawareAppendDeletionFileMaintainer

public interface AppendDeletionFileMaintainer

A maintainer to maintain deletion files for append table, the core methods:

• notifyNewDeletionVector(java.lang.String, org.apache.paimon.deletionvectors.DeletionVector): Mark the deletion of data files, create new deletion vectors.
• persist(): persist deletion files to commit.

Method Summary

Modifier and Type	Method and Description
static BucketedAppendDeletionFileMaintainer	forBucketedAppend(IndexFileHandler indexFileHandler, Long snapshotId, BinaryRow partition, int bucket)
static UnawareAppendDeletionFileMaintainer	forUnawareAppend(IndexFileHandler indexFileHandler, Long snapshotId, BinaryRow partition)
int	getBucket()
BinaryRow	getPartition()
void	notifyNewDeletionVector(String dataFile, DeletionVector deletionVector)
List<IndexManifestEntry>	persist()

Method Detail

getPartition

BinaryRow getPartition()

getBucket

int getBucket()

notifyNewDeletionVector

void notifyNewDeletionVector(String dataFile,
                             DeletionVector deletionVector)

persist

List<IndexManifestEntry> persist()

forBucketedAppend

static BucketedAppendDeletionFileMaintainer forBucketedAppend(IndexFileHandler indexFileHandler,
                                                              @Nullable
                                                              Long snapshotId,
                                                              BinaryRow partition,
                                                              int bucket)

forUnawareAppend

static UnawareAppendDeletionFileMaintainer forUnawareAppend(IndexFileHandler indexFileHandler,
                                                            @Nullable
                                                            Long snapshotId,
                                                            BinaryRow partition)