pub fn decode_records_parallel<T: DeserializeOwned + Send, B: AsRef<[u8]> + Sync>(
schema: &Schema,
binary_records: &[B],
) -> Result<Vec<T>, KineticaError>Decodes binary Avro 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 decode_records.
Performance
Achieves up to 5.3M records/second on modern hardware.