org.apache.paimon.deletionvectors.append

Class UnawareAppendDeletionFileMaintainer

java.lang.Object

org.apache.paimon.deletionvectors.append.UnawareAppendDeletionFileMaintainer

All Implemented Interfaces:

AppendDeletionFileMaintainer

public class UnawareAppendDeletionFileMaintainer
extends Object
implements AppendDeletionFileMaintainer

A AppendDeletionFileMaintainer of unaware bucket append table.

Method Summary

Modifier and Type	Method and Description
int	getBucket()
DeletionFile	getDeletionFile(String dataFile)
DeletionVector	getDeletionVector(String dataFile)
IndexFileMeta	getIndexFile(String dataFile)
BinaryRow	getPartition()
boolean	hasDeletionFile(String dataFile)
void	notifyNewDeletionVector(String dataFile, DeletionVector deletionVector)
DeletionFile	notifyRemovedDeletionVector(String dataFile)
List<IndexManifestEntry>	persist()

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.AppendDeletionFileMaintainer

forBucketedAppend, forUnawareAppend

Method Detail

getPartition

public BinaryRow getPartition()

Specified by:

getPartition in interface AppendDeletionFileMaintainer

getBucket

public int getBucket()

Specified by:

getBucket in interface AppendDeletionFileMaintainer

hasDeletionFile

public boolean hasDeletionFile(String dataFile)

getDeletionFile

public DeletionFile getDeletionFile(String dataFile)

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 AppendDeletionFileMaintainer

persist

public List<IndexManifestEntry> persist()

Specified by:

persist in interface AppendDeletionFileMaintainer

getIndexFile

public IndexFileMeta getIndexFile(String dataFile)