Trait DecodeDataFromRecordBatch

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

Required Methods

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

Decodes a RecordBatch into raw Data values, 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 DecodeDataFromRecordBatch for Bar

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

impl DecodeDataFromRecordBatch for IndexPriceUpdate

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

impl DecodeDataFromRecordBatch for InstrumentClose

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

impl DecodeDataFromRecordBatch for MarkPriceUpdate

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

impl DecodeDataFromRecordBatch for OrderBookDelta

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

impl DecodeDataFromRecordBatch for OrderBookDepth10

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

impl DecodeDataFromRecordBatch for QuoteTick

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

impl DecodeDataFromRecordBatch for TradeTick

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

Implementors