org.apache.paimon.deletionvectors

Class Bitmap64DeletionVector

java.lang.Object

org.apache.paimon.deletionvectors.Bitmap64DeletionVector

All Implemented Interfaces:

DeletionVector

public class Bitmap64DeletionVector
extends Object
implements DeletionVector

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

Mostly copied from iceberg.

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	CRC_SIZE_BYTES
static int	LENGTH_SIZE_BYTES
static int	MAGIC_NUMBER
static int	MAGIC_NUMBER_SIZE_BYTES

Constructor Summary

Constructors

Constructor and Description
Bitmap64DeletionVector()

Method Summary

Modifier and Type	Method and Description
void	delete(long position) Marks the row at the specified position as deleted.
static DeletionVector	deserializeFromBitmapDataBytes(byte[] bytes)
boolean	equals(Object o)
static Bitmap64DeletionVector	fromBitmapDeletionVector(BitmapDeletionVector bitmapDeletionVector)
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.
protected static int	toLittleEndianInt(int bigEndianInt)

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

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

Field Detail

MAGIC_NUMBER

public static final int MAGIC_NUMBER

See Also:

Constant Field Values

LENGTH_SIZE_BYTES

public static final int LENGTH_SIZE_BYTES

See Also:

Constant Field Values

CRC_SIZE_BYTES

public static final int CRC_SIZE_BYTES

See Also:

Constant Field Values

MAGIC_NUMBER_SIZE_BYTES

public static final int MAGIC_NUMBER_SIZE_BYTES

See Also:

Constant Field Values

Constructor Detail

Bitmap64DeletionVector

public Bitmap64DeletionVector()

Method Detail

fromBitmapDeletionVector

public static Bitmap64DeletionVector fromBitmapDeletionVector(BitmapDeletionVector bitmapDeletionVector)

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

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)
                throws IOException

Description copied from interface: DeletionVector

Serializes the deletion vector.

Specified by:

serializeTo in interface DeletionVector

Throws:

IOException

deserializeFromBitmapDataBytes

public static DeletionVector deserializeFromBitmapDataBytes(byte[] bytes)

toLittleEndianInt

protected static int toLittleEndianInt(int bigEndianInt)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object