MCPcopy Create free account
hub / github.com/apache/arrow-rs / write_ocf

Function write_ocf

arrow-avro/src/reader/mod.rs:1788–1795  ·  view source on GitHub ↗
(schema: &Schema, batches: &[RecordBatch])

Source from the content-addressed store, hash-verified

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>> {

Calls 4

cloneMethod · 0.45
writeMethod · 0.45
finishMethod · 0.45
into_innerMethod · 0.45