Helper: evaluate and downcast to LargeStringArray
(
acc: &mut StringAggGroupsAccumulator,
emit_to: EmitTo,
)
| 795 | |
| 796 | /// Helper: evaluate and downcast to LargeStringArray |
| 797 | fn evaluate_groups( |
| 798 | acc: &mut StringAggGroupsAccumulator, |
| 799 | emit_to: EmitTo, |
| 800 | ) -> Vec<Option<String>> { |
| 801 | let result = acc.evaluate(emit_to).unwrap(); |
| 802 | let arr = result.as_any().downcast_ref::<LargeStringArray>().unwrap(); |
| 803 | arr.iter().map(|v| v.map(|s| s.to_string())).collect() |
| 804 | } |
| 805 | |
| 806 | #[test] |
| 807 | fn groups_basic() -> Result<()> { |
searching dependent graphs…