Skip to main content

TopicDecoder

mcap2arrow_core

Trait TopicDecoder 

Source 
pub trait TopicDecoder: Send + Sync {
    // Required methods
    fn decode(&self, message_data: &[u8]) -> Result<Value, DecoderError>;
    fn field_defs(&self) -> &FieldDefs;
}
Expand description

Topic-local decoder built from MCAP schema metadata.

Implementations are created by MessageDecoder once per schema/topic and reused for all messages in that topic.

Required Methods§

Source

fn decode(&self, message_data: &[u8]) -> Result<Value, DecoderError>

Decode a single message payload into a Value.

Source

fn field_defs(&self) -> &FieldDefs

Return the Arrow-independent schema for decoded values.

Implementors§