()
| 890 | |
| 891 | #[test] |
| 892 | fn groups_merge_batch() -> Result<()> { |
| 893 | let mut acc = make_groups_acc(","); |
| 894 | |
| 895 | // First batch: group 0 = "a", group 1 = "b" |
| 896 | let values: ArrayRef = Arc::new(LargeStringArray::from(vec!["a", "b"])); |
| 897 | acc.update_batch(&[values], &[0, 1], None, 2)?; |
| 898 | |
| 899 | // Simulate a second accumulator's state (LargeUtf8 partial strings) |
| 900 | let partial_state: ArrayRef = Arc::new(LargeStringArray::from(vec!["c,d", "e"])); |
| 901 | acc.merge_batch(&[partial_state], &[0, 1], None, 2)?; |
| 902 | |
| 903 | let result = evaluate_groups(&mut acc, EmitTo::All); |
| 904 | assert_eq!( |
| 905 | result, |
| 906 | vec![Some("a,c,d".to_string()), Some("b,e".to_string())] |
| 907 | ); |
| 908 | Ok(()) |
| 909 | } |
| 910 | |
| 911 | #[test] |
| 912 | fn groups_empty_groups() -> Result<()> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…