Struct ReceivedBatch 

pub struct ReceivedBatch { /* private fields */ }

A decoded shuffle batch together with the memory admission charged for its source IPC payload.

The admission remains charged while this value lives, so consumers must retain the envelope while processing shallow clones of the batch.

Implementations

impl ReceivedBatch

pub const fn batch(&self) -> &RecordBatch

Borrow the decoded batch without releasing its inbound admission.

pub const fn peer(&self) -> ShufflePeerId

Peer and exact transport stream that delivered this batch.

pub const fn sender_incarnation(&self) -> Uuid

Sender process incarnation bound by the stream handshake.

pub const fn receiver_incarnation(&self) -> Uuid

Receiver process incarnation bound by the stream handshake.

pub const fn stream_id(&self) -> Uuid

Connection identity bound by the stream handshake.

pub const fn assignment_version(&self) -> u64

Assignment version bound by the stream handshake.

pub const fn recovery_gen(&self) -> u64

Recovery generation bound by the stream handshake.

pub const fn checkpoint_sequence(&self) -> u64

Zero-based logical-frame sequence for this data batch.

pub fn into_parts(self) -> (RecordBatch, ShuffleBatchAdmission)

Split the decoded batch from its admission so a retaining consumer can keep the charge for exactly as long as shallow Arrow views remain live.

Trait Implementations

impl Debug for ReceivedBatch

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

Formats the value using the given formatter.