Trait BatchDeserializer 

pub trait BatchDeserializer<T>: Send + Debug {
    // Required methods
    fn digest(&mut self, message: T) -> usize;
    fn next(&mut self) -> Result<DeserializerOutput, ArrowError>;
    fn finish(&mut self);
}

Trait defining a scheme for deserializing byte streams into structured data. Implementors of this trait are responsible for converting raw bytes into RecordBatch objects.

Required Methods

fn digest(&mut self, message: T) -> 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.

Implementors

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