use re_arrow2::array::*; use re_arrow2::chunk::Chunk; use re_arrow2::datatypes::*; use re_arrow2::error::Result; use re_arrow2::io::avro::avro_schema::file::Compression; use re_arrow2::io::avro::avro_schema::write_async::{write_block, write_metadata}; use re_arrow2::io::avro::write; use super::read::read_avro; use super::write::{data, schema, serialize_to_block}; async fn write_avro>( columns: &Chunk, schema: &Schema, compression: Option, ) -> Result> { // usually done on a different thread pool let compressed_block = serialize_to_block(columns, schema, compression)?; let record = write::to_record(schema)?; let mut file = vec![]; write_metadata(&mut file, record, compression).await?; write_block(&mut file, &compressed_block).await?; Ok(file) } async fn roundtrip(compression: Option) -> Result<()> { let expected = data(); let expected_schema = schema(); let data = write_avro(&expected, &expected_schema, compression).await?; let (result, read_schema) = read_avro(&data, None)?; assert_eq!(expected_schema, read_schema); for (c1, c2) in result.columns().iter().zip(expected.columns().iter()) { assert_eq!(c1.as_ref(), c2.as_ref()); } Ok(()) } #[tokio::test] async fn no_compression() -> Result<()> { roundtrip(None).await }