Struct EventBatch 

pub struct EventBatch { /* private fields */ }

Immutable columnar batch of events sharing one schema.

Implementations

impl EventBatch

pub fn new( schema: Arc<Schema>, p4s: Vec<Arc<[RealVec4]>>, scalars: Vec<Arc<[f64]>>, weights: Option<Arc<[f64]>>, ) -> LadduDataResult<Self>

Validates column counts and lengths and constructs a batch.

Errors

Returns LadduDataError when column counts do not match schema or column and weight lengths are inconsistent.

pub fn from_events<I>(schema: Arc<Schema>, events: I) -> LadduDataResult<Self>

where I: IntoIterator<Item = OwnedEvent>,

Collects owned row events into a columnar batch.

Errors

Returns LadduDataError when an event has the wrong number of values or weighted and unweighted events are mixed.

pub fn schema(&self) -> &Arc<Schema>

Returns the shared logical schema.

pub fn len(&self) -> usize

Returns the number of rows.

pub fn bytes_per_event(&self) -> usize

Returns the logical payload bytes per event represented by this batch.

pub fn resident_bytes(&self) -> usize

Returns the retained column payload size in bytes.

Shared schema metadata, allocation headers, and other owners of shared columns are not included.

pub fn is_empty(&self) -> bool

Returns whether the batch contains no rows.

pub fn vec4_column(&self, index: usize) -> &[RealVec4]

Returns a four-momentum column by index.

pub fn scalar_column(&self, index: usize) -> &[f64]

Returns a scalar column by index.

pub fn weights_column(&self) -> Option<&[f64]>

Returns the optional explicit weight column.

pub fn vec4_column_named(&self, name: &str) -> Option<&[RealVec4]>

Returns a four-momentum column by logical name.

pub fn scalar_column_named(&self, name: &str) -> Option<&[f64]>

Returns a scalar column by logical name.

pub fn p4_at(&self, col: usize, row: usize) -> RealVec4

Returns one four-momentum cell.

pub fn scalar_at(&self, col: usize, row: usize) -> f64

Returns one scalar cell.

pub fn weights_at(&self, row: usize) -> f64

Returns the explicit row weight, or one when weights are absent.

pub fn event(&self, row: usize) -> BatchEvent<'_>

Returns a borrowed view of one row.

pub fn iter(&self) -> impl Iterator<Item = BatchEvent<'_>>

Iterates over borrowed event views.

pub fn select(&self, rows: &[usize]) -> Self

Copies selected rows into a new batch in the requested order.

pub fn filter<F>(&self, keep: F) -> Self

where F: Fn(BatchEvent<'_>) -> bool,

Copies rows satisfying keep into a new batch.

pub fn reweight<F>(&self, f: F) -> Self

where F: Fn(usize, f64) -> f64,

Returns a batch sharing value columns with newly computed weights.

pub fn slice(&self, start: usize, end: usize) -> Self

Copies the half-open row range start..end into a new batch.

Panics

Panics when start > end or end exceeds the batch length.

pub fn concat(batches: &[Self]) -> LadduDataResult<Self>

Concatenates schema-compatible batches.

Errors

Returns LadduDataError when batches is empty or contains incompatible schemas.

Trait Implementations

impl Clone for EventBatch

fn clone(&self) -> EventBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventBatch

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

Formats the value using the given formatter.