Trait DecodeFromRecordBatch

pub trait DecodeFromRecordBatch
where
    Self: Sized + Into<Data> + ArrowSchemaProvider,
{
    // Required method
    fn decode_batch(
        metadata: &HashMap<String, String>,
        record_batch: RecordBatch,
    ) -> Result<Vec<Self>, EncodingError>;
}

Required Methods

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

Decodes a RecordBatch into a vector of values of the implementing type, using the provided metadata.

Errors

Returns an EncodingError if the decoding fails.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl DecodeFromRecordBatch for Bar

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for IndexPriceUpdate

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for InstrumentClose

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for MarkPriceUpdate

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for OrderBookDelta

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for OrderBookDepth10

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for QuoteTick

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

impl DecodeFromRecordBatch for TradeTick

fn decode_batch( metadata: &HashMap<String, String>, record_batch: RecordBatch, ) -> Result<Vec<Self>, EncodingError>

Implementors