Struct EventBatch 

pub struct EventBatch {
    pub payload: RecordBatch,
    pub metadata: ArcEventMetadata,
    pub ack_token: Option<AckToken>,
}

The core unit of data flowing through a Kinetic pipeline.

An EventBatch wraps an Apache Arrow RecordBatch along with metadata tracking its lineage, timing, and multi-tenant profile.

Fields

payload: RecordBatch

The actual data payload in columnar Arrow format.

metadata: ArcEventMetadata

Metadata tracking the batch’s journey through the pipeline.

ack_token: Option<AckToken>

Optional token for end-to-end acknowledgement.

Implementations

impl EventBatch

pub fn new(payload: RecordBatch, metadata: ArcEventMetadata) -> Result<Self>

Create a new EventBatch from a RecordBatch and metadata.

This is a low-level constructor that assumes the payload is already correctly formatted.

pub fn new_with_xid( payload: RecordBatch, metadata: ArcEventMetadata, ) -> Result<Self>

Create a new EventBatch and ensure it has a unique _xid column.

This is temporarily mapped to new to delay xid creation until it is actually needed (e.g., when routing to an error topic).

pub fn new_with_ack( payload: RecordBatch, metadata: ArcEventMetadata, ack_token: AckToken, ) -> Result<Self>

Create a new EventBatch with an acknowledgement token.

pub fn num_rows(&self) -> usize

Returns the number of rows (events) in this batch.

pub fn is_empty(&self) -> bool

Returns true if the batch contains no rows.

pub fn estimated_size(&self) -> usize

Returns the estimated in-memory size of the batch in bytes.

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.

impl PartialEq for EventBatch

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.