nautilus_persistence::arrow

Trait DecodeDataFromRecordBatch

source
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§

source

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

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl DecodeDataFromRecordBatch for Bar

source§

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

source§

impl DecodeDataFromRecordBatch for OrderBookDelta

source§

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

source§

impl DecodeDataFromRecordBatch for OrderBookDepth10

source§

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

source§

impl DecodeDataFromRecordBatch for QuoteTick

source§

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

source§

impl DecodeDataFromRecordBatch for TradeTick

source§

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

Implementors§