()
| 3718 | |
| 3719 | #[test] |
| 3720 | fn encode_rows_empty_batch() { |
| 3721 | let schema = ArrowSchema::new(vec![Field::new("x", DataType::Int32, false)]); |
| 3722 | let arr = Int32Array::from(Vec::<i32>::new()); |
| 3723 | let batch = RecordBatch::try_new(Arc::new(schema.clone()), vec![Arc::new(arr)]).unwrap(); |
| 3724 | let encoder = RecordEncoder { |
| 3725 | columns: vec![FieldBinding { |
| 3726 | arrow_index: 0, |
| 3727 | nullability: None, |
| 3728 | plan: FieldPlan::Scalar, |
| 3729 | }], |
| 3730 | prefix: None, |
| 3731 | }; |
| 3732 | let mut out = BytesMut::new(); |
| 3733 | let mut offsets: Vec<usize> = vec![0]; |
| 3734 | encoder |
| 3735 | .encode_rows(&batch, 16, &mut out, &mut offsets) |
| 3736 | .unwrap(); |
| 3737 | assert_eq!(offsets, vec![0]); |
| 3738 | assert!(out.is_empty()); |
| 3739 | } |
| 3740 | |
| 3741 | #[test] |
| 3742 | fn encode_rows_matches_encode_output() { |
nothing calls this directly
no test coverage detected