flarrow-message 0.3.1

flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications.
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

#[cfg(test)]
mod tests {
    use flarrow_message::prelude::*;
    use thirdparty::{arrow_array::*, arrow_data::ArrayData};

    #[test]
    fn test_zero_copy() {
        #[derive(ArrowMessage)]
        struct Message {
            buffer: UInt32Array,
        }

        let buffer: Vec<u32> = vec![0, 1, 2, 3, 4, 5];
        let ptr_1 = buffer.as_ptr();

        let message = Message {
            buffer: UInt32Array::from(buffer),
        };
        let arrow = ArrayData::try_from(message).unwrap();
        let message = Message::try_from(arrow).unwrap();
        let ptr_2 = message.buffer.values().as_ptr();

        assert_eq!(ptr_1, ptr_2);
    }
}