org.apache.paimon.deletionvectors

Class DeletionVectorsMaintainer

java.lang.Object

org.apache.paimon.deletionvectors.DeletionVectorsMaintainer

public class DeletionVectorsMaintainer
extends Object

Maintainer of deletionVectors index.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DeletionVectorsMaintainer.Factory Factory to restore DeletionVectorsMaintainer.

Method Summary

Modifier and Type	Method and Description
Optional<DeletionVector>	deletionVectorOf(String fileName) Retrieves the deletion vector associated with the specified file name.
Map<String,DeletionVector>	deletionVectors()
static DeletionVectorsMaintainer.Factory	factory(IndexFileHandler handler)
IndexFileHandler	indexFileHandler()
void	mergeNewDeletion(String fileName, DeletionVector deletionVector) Merge a new deletion which marks the specified deletion vector with the given file name, if the previous deletion vector exist, merge the old one.
void	notifyNewDeletion(String fileName, DeletionVector deletionVector) Notifies a new deletion which marks the specified deletion vector with the given file name.
void	notifyNewDeletion(String fileName, long position) Notifies a new deletion which marks the specified row position as deleted with the given file name.
void	removeDeletionVectorOf(String fileName) Removes the specified file's deletion vector, this method is typically used for remove before files' deletion vector in compaction.
List<IndexFileMeta>	writeDeletionVectorsIndex() Write new deletion vectors index file if any modifications have been made.

Methods inherited from class java.lang.Object

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

Method Detail

notifyNewDeletion

public void notifyNewDeletion(String fileName,
                              long position)

Notifies a new deletion which marks the specified row position as deleted with the given file name.

Parameters:

fileName - The name of the file where the deletion occurred.

position - The row position within the file that has been deleted.

notifyNewDeletion

public void notifyNewDeletion(String fileName,
                              DeletionVector deletionVector)

Notifies a new deletion which marks the specified deletion vector with the given file name.

Parameters:

fileName - The name of the file where the deletion occurred.

deletionVector - The deletion vector

mergeNewDeletion

public void mergeNewDeletion(String fileName,
                             DeletionVector deletionVector)

Merge a new deletion which marks the specified deletion vector with the given file name, if the previous deletion vector exist, merge the old one.

Parameters:

fileName - The name of the file where the deletion occurred.

deletionVector - The deletion vector

removeDeletionVectorOf

public void removeDeletionVectorOf(String fileName)

Removes the specified file's deletion vector, this method is typically used for remove before files' deletion vector in compaction.

Parameters:

fileName - The name of the file whose deletion vector should be removed.

writeDeletionVectorsIndex

public List<IndexFileMeta> writeDeletionVectorsIndex()

Write new deletion vectors index file if any modifications have been made.

Returns:

A list containing the metadata of the deletion vectors index file, or an empty list if no changes need to be committed.

deletionVectorOf

public Optional<DeletionVector> deletionVectorOf(String fileName)

Retrieves the deletion vector associated with the specified file name.

Parameters:

fileName - The name of the file for which the deletion vector is requested.

Returns:

An Optional containing the deletion vector if it exists, or an empty Optional if not.

indexFileHandler

public IndexFileHandler indexFileHandler()

deletionVectors

@VisibleForTesting
public Map<String,DeletionVector> deletionVectors()

factory

public static DeletionVectorsMaintainer.Factory factory(IndexFileHandler handler)