Struct DecoderDeserializer

pub struct DecoderDeserializer<T: Decoder> { /* private fields */ }

A generic, decoder-based deserialization scheme for processing encoded data.

This struct is responsible for converting a stream of bytes, which represent encoded data, into a stream of RecordBatch objects, following the specified schema and formatting options. It also handles any buffering necessary to satisfy the Decoder interface.

Implementations

impl<T: Decoder> DecoderDeserializer<T>

pub fn new(decoder: T) -> Self

Creates a new DecoderDeserializer with the provided decoder.

Trait Implementations

impl<T: Decoder> BatchDeserializer<Bytes> for DecoderDeserializer<T>

fn digest(&mut self, message: Bytes) -> usize

Feeds a message for deserialization, updating the internal state of this BatchDeserializer. Note that one can call this function multiple times before calling next, which will queue multiple messages for deserialization. Returns the number of bytes consumed.

fn next(&mut self) -> Result<DeserializerOutput, ArrowError>

Attempts to deserialize any pending messages and returns a DeserializerOutput to indicate progress.

fn finish(&mut self)

Informs the deserializer that no more messages will be provided for deserialization.

impl<T: Decoder> Debug for DecoderDeserializer<T>

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

Formats the value using the given formatter.