(
window_frame: &Arc<WindowFrame>,
expected_results: Vec<(Range<usize>, usize)>,
)
| 700 | } |
| 701 | |
| 702 | fn assert_group_ranges( |
| 703 | window_frame: &Arc<WindowFrame>, |
| 704 | expected_results: Vec<(Range<usize>, usize)>, |
| 705 | ) -> Result<()> { |
| 706 | let mut window_frame_groups = WindowFrameStateGroups::default(); |
| 707 | let (range_columns, _) = get_test_data(); |
| 708 | let n_row = range_columns[0].len(); |
| 709 | for (idx, (expected_range, expected_group_idx)) in |
| 710 | expected_results.into_iter().enumerate() |
| 711 | { |
| 712 | let range = window_frame_groups.calculate_range( |
| 713 | window_frame, |
| 714 | &range_columns, |
| 715 | n_row, |
| 716 | idx, |
| 717 | )?; |
| 718 | assert_eq!(range, expected_range); |
| 719 | assert_eq!(window_frame_groups.current_group_idx, expected_group_idx); |
| 720 | } |
| 721 | Ok(()) |
| 722 | } |
| 723 | |
| 724 | fn assert_frame_ranges( |
| 725 | window_frame: &Arc<WindowFrame>, |
searching dependent graphs…