Skip to main content

RecordSerializer

laminar_connectors::serde

Trait RecordSerializer 

Source 
pub trait RecordSerializer: Send + Sync {
    // Required methods
    fn serialize(&self, batch: &RecordBatch) -> Result<Vec<Vec<u8>>, SerdeError>;
    fn format(&self) -> Format;

    // Provided method
    fn serialize_batch(
        &self,
        batch: &RecordBatch,
    ) -> Result<Vec<u8>, SerdeError> { ... }
}
Expand description

Trait for serializing Arrow RecordBatch into raw bytes.

Implementations convert from Arrow columnar format to external formats for writing to sinks.

Required Methods§

Source

fn serialize(&self, batch: &RecordBatch) -> Result<Vec<Vec<u8>>, SerdeError>

Serializes a RecordBatch into a vector of byte records.

Each element in the returned vector represents one serialized record.

§Errors

Returns SerdeError if serialization fails.

Source

fn format(&self) -> Format

Returns the format this serializer produces.

Provided Methods§

Source

fn serialize_batch(&self, batch: &RecordBatch) -> Result<Vec<u8>, SerdeError>

Serializes a RecordBatch into a single byte buffer.

For formats that support batch encoding (e.g., JSON array, CSV), this may be more efficient than serializing individual records.

§Errors

Returns SerdeError if serialization fails.

Implementors§