org.apache.paimon.deletionvectors

Class BitmapDeletionVector

java.lang.Object

org.apache.paimon.deletionvectors.BitmapDeletionVector

All Implemented Interfaces:

DeletionVector

public class BitmapDeletionVector
extends Object
implements DeletionVector

A DeletionVector based on RoaringBitmap32, it only supports files with row count not exceeding RoaringBitmap32.MAX_VALUE.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.deletionvectors.DeletionVector

DeletionVector.Factory

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAGIC_NUMBER

Constructor Summary

Constructors

Constructor and Description
BitmapDeletionVector()

Method Summary

Modifier and Type	Method and Description
boolean	checkedDelete(long position) Marks the row at the specified position as deleted.
void	delete(long position) Marks the row at the specified position as deleted.
static DeletionVector	deserializeFromDataInput(DataInput bis)
boolean	equals(Object o)
long	getCardinality()
boolean	isDeleted(long position) Checks if the row at the specified position is marked as deleted.
boolean	isEmpty() Determines if the deletion vector is empty, indicating no deletions.
void	merge(DeletionVector deletionVector) merge another DeletionVector to this current one.
byte[]	serializeToBytes() Serializes the deletion vector to a byte array for storage or transmission.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.deletionvectors.DeletionVector

deserializeFromBytes, emptyFactory, factory, factory, read

Field Detail

MAGIC_NUMBER

public static final int MAGIC_NUMBER

See Also:

Constant Field Values

Constructor Detail

BitmapDeletionVector

public BitmapDeletionVector()

Method Detail

delete

public void delete(long position)

Description copied from interface: DeletionVector

Marks the row at the specified position as deleted.

Specified by:

delete in interface DeletionVector

Parameters:

position - The position of the row to be marked as deleted.

merge

public void merge(DeletionVector deletionVector)

Description copied from interface: DeletionVector

merge another DeletionVector to this current one.

Specified by:

merge in interface DeletionVector

Parameters:

deletionVector - the other DeletionVector

checkedDelete

public boolean checkedDelete(long position)

Description copied from interface: DeletionVector

Marks the row at the specified position as deleted.

Specified by:

checkedDelete in interface DeletionVector

Parameters:

position - The position of the row to be marked as deleted.

Returns:

true if the added position wasn't already deleted. False otherwise.

isDeleted

public boolean isDeleted(long position)

Description copied from interface: DeletionVector

Checks if the row at the specified position is marked as deleted.

Specified by:

isDeleted in interface DeletionVector

Parameters:

position - The position of the row to check.

Returns:

true if the row is marked as deleted, false otherwise.

isEmpty

public boolean isEmpty()

Description copied from interface: DeletionVector

Determines if the deletion vector is empty, indicating no deletions.

Specified by:

isEmpty in interface DeletionVector

Returns:

true if the deletion vector is empty, false if it contains deletions.

getCardinality

public long getCardinality()

Specified by:

getCardinality in interface DeletionVector

Returns:

the number of distinct integers added to the DeletionVector.

serializeToBytes

public byte[] serializeToBytes()

Description copied from interface: DeletionVector

Serializes the deletion vector to a byte array for storage or transmission.

Specified by:

serializeToBytes in interface DeletionVector

Returns:

A byte array representing the serialized deletion vector.

deserializeFromDataInput

public static DeletionVector deserializeFromDataInput(DataInput bis)
                                               throws IOException

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class Object