arrow2 0.6.0

Unofficial implementation of Apache Arrow spec in safe Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use flatbuffers::FlatBufferBuilder;

use crate::datatypes::*;

use super::super::{convert, gen};
use super::MetadataVersion;

/// Converts
pub fn schema_to_bytes(schema: &Schema, version: MetadataVersion) -> Vec<u8> {
    let mut fbb = FlatBufferBuilder::new();
    let schema = {
        let fb = convert::schema_to_fb_offset(&mut fbb, schema);
        fb.as_union_value()
    };

    let mut message = gen::Message::MessageBuilder::new(&mut fbb);
    message.add_version(version);
    message.add_header_type(gen::Message::MessageHeader::Schema);
    message.add_bodyLength(0);
    message.add_header(schema);
    // TODO: custom metadata
    let data = message.finish();
    fbb.finish(data, None);

    fbb.finished_data().to_vec()
}