Function msgpack_to_arrow_roundtrip

nodedb/src/control/arrow_convert.rs:282–294

()

    #[test]
    fn msgpack_to_arrow_roundtrip() {
        let payload = nodedb_types::json_to_msgpack(&serde_json::json!([
            {"id": "d1", "data": {"name": "alice", "age": 30}},
            {"id": "d2", "data": {"name": "bob", "age": 25}}
        ]))
        .unwrap();

        let batch = msgpack_rows_to_record_batch(&payload).unwrap();
        assert_eq!(batch.num_rows(), 2);
        assert!(batch.schema().field_with_name("id").is_ok());
        assert!(batch.schema().field_with_name("name").is_ok());
        assert!(batch.schema().field_with_name("age").is_ok());
    }
}