Trait EncodeToRecordBatch 

pub trait EncodeToRecordBatch
where
    Self: Sized + ArrowSchemaProvider,
{
    // Required methods
    fn encode_batch(
        metadata: &HashMap<String, String>,
        data: &[Self],
    ) -> Result<RecordBatch, ArrowError>;
    fn metadata(&self) -> HashMap<String, String>;

    // Provided method
    fn chunk_metadata(chunk: &[Self]) -> HashMap<String, String> { ... }
}

Encodes data types to Apache Arrow RecordBatch format.

Required Methods

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

Encodes a batch of values into an Arrow RecordBatch using the provided metadata.

Errors

Returns an ArrowError if the encoding fails.

fn metadata(&self) -> HashMap<String, String>

Returns the metadata for this data element.

Provided Methods

fn chunk_metadata(chunk: &[Self]) -> HashMap<String, String>

Returns the metadata for the first element in a chunk.

Panics

Panics if chunk is empty.

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 EncodeToRecordBatch for AccountState

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for Bar

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for BettingInstrument

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for BinaryOption

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for Cfd

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for Commodity

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for CryptoFuture

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for CryptoOption

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for CryptoPerpetual

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for CurrencyPair

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for Equity

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for ExecutionMassStatus

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for FillReport

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for FundingRateUpdate

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for FuturesContract

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for FuturesSpread

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for IndexInstrument

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for IndexPriceUpdate

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for InstrumentAny

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for InstrumentClose

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for InstrumentStatus

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for MarkPriceUpdate

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OptionContract

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OptionSpread

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderAccepted

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderBookDelta

fn chunk_metadata(chunk: &[Self]) -> HashMap<String, String>

Extract metadata from first two deltas

Use the second delta if the first one has 0 precision

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderBookDepth10

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderCancelRejected

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderCanceled

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderDenied

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderEmulated

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderExpired

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderFilled

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderInitialized

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderModifyRejected

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderPendingCancel

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderPendingUpdate

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderRejected

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderReleased

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderSnapshot

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderStatusReport

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderSubmitted

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderTriggered

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for OrderUpdated

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PerpetualContract

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PositionAdjusted

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PositionChanged

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PositionClosed

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PositionOpened

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PositionSnapshot

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for PositionStatusReport

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for QuoteTick

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for TokenizedAsset

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

impl EncodeToRecordBatch for TradeTick

fn encode_batch( metadata: &HashMap<String, String>, data: &[Self], ) -> Result<RecordBatch, ArrowError>

fn metadata(&self) -> HashMap<String, String>

Implementors