(schema: &Schema, batches: &[RecordBatch])
| 1786 | } |
| 1787 | |
| 1788 | fn write_ocf(schema: &Schema, batches: &[RecordBatch]) -> Vec<u8> { |
| 1789 | let mut w = AvroWriter::new(Vec::<u8>::new(), schema.clone()).expect("writer"); |
| 1790 | for b in batches { |
| 1791 | w.write(b).expect("write"); |
| 1792 | } |
| 1793 | w.finish().expect("finish"); |
| 1794 | w.into_inner() |
| 1795 | } |
| 1796 | |
| 1797 | #[test] |
| 1798 | fn ocf_projection_no_reader_schema_reorder() -> Result<(), Box<dyn std::error::Error>> { |