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
static int	MAGIC_NUMBER_SIZE_BYTES

Constructor Summary

Constructors

Constructor and Description
BitmapDeletionVector()

Method Summary

Modifier and Type	Method and Description
static int	calculateChecksum(byte[] bytes)
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	deserializeFromByteBuffer(ByteBuffer buffer)
boolean	equals(Object o)
RoaringBitmap32	get() Note: the result is read only, do not call any modify operation outside.
long	getCardinality()
int	hashCode()
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.
int	serializeTo(DataOutputStream out) Serializes the deletion vector.

Methods inherited from class java.lang.Object

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

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

deserializeFromBytes, emptyFactory, factory, factory, read, read, serializeToBytes

Field Detail

MAGIC_NUMBER

public static final int MAGIC_NUMBER

See Also:

Constant Field Values

MAGIC_NUMBER_SIZE_BYTES

public static final int MAGIC_NUMBER_SIZE_BYTES

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.

serializeTo

public int serializeTo(DataOutputStream out)

Description copied from interface: DeletionVector

Serializes the deletion vector.

Specified by:

serializeTo in interface DeletionVector

get

public RoaringBitmap32 get()

Note: the result is read only, do not call any modify operation outside.

Returns:

the deleted position

deserializeFromByteBuffer

public static DeletionVector deserializeFromByteBuffer(ByteBuffer buffer)
                                                throws IOException

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

calculateChecksum

public static int calculateChecksum(byte[] bytes)