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 new_with_columns( schema: Arc<Schema>, p4s: Vec<Arc<[RealVec4]>>, scalars: Vec<Arc<[f64]>>, columns: Vec<Column>, weights: Option<Arc<[f64]>>, ) -> LadduDataResult<Self>

Constructs a batch including exact non-expression columns.

Errors

Returns an error for schema, dtype, or column-length mismatches.

pub fn new_with_columns_and_len( schema: Arc<Schema>, p4s: Vec<Arc<[RealVec4]>>, scalars: Vec<Arc<[f64]>>, columns: Vec<Column>, weights: Option<Arc<[f64]>>, len: usize, ) -> LadduDataResult<Self>

Constructs a typed batch with an explicit row count.

Errors

Returns an error if columns do not match the schema or row count.

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

Constructs a batch with an explicit event count, including column-free events.

Errors

Returns an error if the columns do not match the schema or event count.

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 row_ids(&self) -> Option<&[u64]>

Returns optional stable global source-row identities for distributed transforms.

pub fn with_row_ids(self, ids: Arc<[u64]>) -> LadduDataResult<Self>

Attaches stable source-row identities without changing the logical schema.

Errors

Returns an error when the identity count differs from the event count.

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 and row-identity 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 column(&self, index: usize) -> &Column

Returns an exact row-data column by index.

Panics

Panics when the column index is outside the schema.

pub fn column_named(&self, name: &str) -> Option<&Column>

Returns an exact row-data column by name.

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 p4_column_bound( &self, binding: &P4Binding, ) -> LadduDataResult<&[RealVec4]>

Returns a four-momentum column through a schema-resolved binding.

Schema compatibility is checked once, so callers can safely reuse the returned slice for every row in a packing loop.

Errors

Returns LadduDataError::Schema when the binding belongs to another schema.

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

Returns one scalar cell.

pub fn scalar_column_bound( &self, binding: &ScalarBinding, ) -> LadduDataResult<&[f64]>

Returns a scalar column through a schema-resolved binding.

Schema compatibility is checked once, so callers can safely reuse the returned slice for every row in a packing loop.

Errors

Returns LadduDataError::Schema when the binding belongs to another schema.

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.

Panics

Panics when a selected row is outside the batch.

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.

Panics

Panics if an internal batch invariant is violated while rebuilding the batch.

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) -> Self

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, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.