Struct ArrowIpcEncoder 

pub struct ArrowIpcEncoder { /* private fields */ }

Available on crate feature arrow only.

Per-stream state for ArrowRecordBatchIpcStreamFormat.

Genuinely stateful, unlike every other format here: the dictionary tracker spans the whole stream, so batches cannot be encoded independently of one another.

Trait Implementations

impl ItemEncoder<RecordBatch> for ArrowIpcEncoder

fn epilogue(&mut self, buf: &mut BytesMut) -> Result<(), StreamError>

The end-of-stream marker. Emitted only on a clean end, so a truncated body stays visibly truncated rather than reading as a complete, empty-tailed stream.

fn encode( &mut self, item: &RecordBatch, index: u64, buf: &mut BytesMut, ) -> Result<(), StreamError>

Encode one item.

fn prologue(&mut self, buf: &mut BytesMut) -> Result<(), StreamError>

Bytes emitted before the first item, if any.