Skip to main content
pub fn encode_records_parallel<T: Serialize + Sync>(
    schema: &Schema,
    records: &[T],
) -> Result<Vec<Vec<u8>>, KineticaError>

Encodes records in parallel using serde_avro_fast + rayon.

Use this when you have a large number of records (500+) and want maximum throughput. For automatic threshold handling, use encode_records.