Struct VersionedBatch 

pub struct VersionedBatch {
    pub data: Arc<RecordBatch>,
    pub begin_ts: u64,
    pub end_ts: Option<u64>,
    pub sequence: u64,
}

A versioned RecordBatch with MVCC metadata.

Stores an immutable Arrow RecordBatch along with version information for Snapshot Isolation. Multiple versions can share the same RecordBatch via Arc, reducing memory overhead.

Fields

data: Arc<RecordBatch>

The actual columnar data (immutable, shared via Arc)

begin_ts: u64

Transaction timestamp when this batch became visible

end_ts: Option<u64>

Transaction timestamp when this batch became obsolete (None = still active)

sequence: u64

Batch sequence number for ordering within the same timestamp

Implementations

impl VersionedBatch

pub fn new(data: Arc<RecordBatch>, begin_ts: u64, sequence: u64) -> Self

Create a new versioned batch.

pub fn mark_obsolete(&mut self, end_ts: u64)

Mark this batch as obsolete at the given timestamp.

pub fn is_visible(&self, read_ts: u64) -> bool

Check if this batch is visible to a snapshot at the given read timestamp.

A batch is visible if:

• begin_ts <= read_ts
• end_ts is None OR end_ts > read_ts

pub fn is_obsolete(&self) -> bool

Check if this batch is obsolete (has an end_ts).

pub fn num_rows(&self) -> usize

Get the number of rows in this batch.

pub fn num_columns(&self) -> usize

Get the number of columns in this batch.

Trait Implementations

impl Clone for VersionedBatch

fn clone(&self) -> VersionedBatch

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for VersionedBatch

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.