()
| 1254 | |
| 1255 | #[test] |
| 1256 | fn duplicates_distinct() -> Result<()> { |
| 1257 | let (mut acc1, mut acc2) = ArrayAggAccumulatorBuilder::string() |
| 1258 | .distinct() |
| 1259 | .build_two()?; |
| 1260 | |
| 1261 | acc1.update_batch(&[data(["a", "b", "c"])])?; |
| 1262 | acc2.update_batch(&[data(["a", "b", "c"])])?; |
| 1263 | acc1 = merge(acc1, acc2)?; |
| 1264 | |
| 1265 | let mut result = print_nulls(str_arr(acc1.evaluate()?)?); |
| 1266 | result.sort(); |
| 1267 | |
| 1268 | assert_eq!(result, vec!["a", "b", "c"]); |
| 1269 | |
| 1270 | Ok(()) |
| 1271 | } |
| 1272 | |
| 1273 | #[test] |
| 1274 | fn duplicates_on_second_batch_distinct() -> Result<()> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…