nautilus_persistence::arrow

Trait DecodeFromRecordBatch

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

source

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

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl DecodeFromRecordBatch for Bar

source§

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

source§

impl DecodeFromRecordBatch for OrderBookDelta

source§

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

source§

impl DecodeFromRecordBatch for OrderBookDepth10

source§

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

source§

impl DecodeFromRecordBatch for QuoteTick

source§

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

source§

impl DecodeFromRecordBatch for TradeTick

source§

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

Implementors§