org.apache.paimon.deletionvectors.append

Class AppendDeleteFileMaintainer

java.lang.Object

org.apache.paimon.deletionvectors.append.AppendDeleteFileMaintainer

All Implemented Interfaces:

BaseAppendDeleteFileMaintainer

public class AppendDeleteFileMaintainer
extends Object
implements BaseAppendDeleteFileMaintainer

A BaseAppendDeleteFileMaintainer of unaware bucket append table.

Method Summary

Modifier and Type	Method and Description
int	getBucket()
DeletionFile	getDeletionFile(String dataFile)
DeletionVector	getDeletionVector(String dataFile)
String	getIndexFilePath(String dataFile)
BinaryRow	getPartition()
void	notifyNewDeletionVector(String dataFile, DeletionVector deletionVector)
DeletionFile	notifyRemovedDeletionVector(String dataFile)
List<IndexManifestEntry>	persist()
void	putDeletionFile(String dataFile, DeletionFile deletionFile)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.deletionvectors.append.BaseAppendDeleteFileMaintainer

forBucketedAppend, forUnawareAppend

Method Detail

getPartition

public BinaryRow getPartition()

Specified by:

getPartition in interface BaseAppendDeleteFileMaintainer

getBucket

public int getBucket()

Specified by:

getBucket in interface BaseAppendDeleteFileMaintainer

getDeletionFile

public DeletionFile getDeletionFile(String dataFile)

putDeletionFile

public void putDeletionFile(String dataFile,
                            DeletionFile deletionFile)

getDeletionVector

public DeletionVector getDeletionVector(String dataFile)

notifyRemovedDeletionVector

public DeletionFile notifyRemovedDeletionVector(String dataFile)

notifyNewDeletionVector

public void notifyNewDeletionVector(String dataFile,
                                    DeletionVector deletionVector)

Specified by:

notifyNewDeletionVector in interface BaseAppendDeleteFileMaintainer

persist

public List<IndexManifestEntry> persist()

Specified by:

persist in interface BaseAppendDeleteFileMaintainer

getIndexFilePath

public String getIndexFilePath(String dataFile)