Struct MergeRecordDecoder

pub struct MergeRecordDecoder<D> { /* private fields */ }

Merges the record decoding streams from one or more other decoders, performing a k-merge based on Record::index_ts().

Implementations

impl<D> RecordDecoder<D>

where D: DecodeRecordRef,

pub fn new(decoders: Vec<D>) -> Result<Self>

Creates a new record-stream merging decoder.

Errors

This function returns an error if decoders is empty. It will also return an error if one of the inner decoders returns an error while decoding the first record. A decoder returning Ok(None) does not result in a failure.

Trait Implementations

impl<D> DecodeRecord for RecordDecoder<D>

where D: BufferSlice + DecodeRecordRef,

fn decode_record<T: HasRType>(&mut self) -> Result<Option<&T>>

Tries to decode a reference to a single record of type T. Returns Ok(None) if the input has been exhausted.

fn decode_records<T: HasRType + Clone>(self) -> Result<Vec<T>>

where Self: Sized,

Tries to decode all records into a Vec. This eagerly decodes the data.

impl<D> DecodeRecordRef for RecordDecoder<D>

where D: BufferSlice + DecodeRecordRef,

fn decode_record_ref(&mut self) -> Result<Option<RecordRef<'_>>>

Tries to decode a generic reference a record. Returns Ok(None) if input has been exhausted.

impl<D> DecodeStream for RecordDecoder<D>

where D: BufferSlice + DecodeRecordRef,

fn decode_stream<T: HasRType>(self) -> StreamIterDecoder<Self, T>

where Self: Sized,

Converts the decoder into a streaming iterator of records of type T. This lazily decodes the data.