(
window_frame: &Arc<WindowFrame>,
expected_results: Vec<Range<usize>>,
)
| 722 | } |
| 723 | |
| 724 | fn assert_frame_ranges( |
| 725 | window_frame: &Arc<WindowFrame>, |
| 726 | expected_results: Vec<Range<usize>>, |
| 727 | ) -> Result<()> { |
| 728 | let mut window_frame_context = |
| 729 | WindowFrameContext::new(Arc::clone(window_frame), vec![]); |
| 730 | let (range_columns, _) = get_test_data(); |
| 731 | let n_row = range_columns[0].len(); |
| 732 | let mut last_range = Range { start: 0, end: 0 }; |
| 733 | for (idx, expected_range) in expected_results.into_iter().enumerate() { |
| 734 | let range = window_frame_context.calculate_range( |
| 735 | &range_columns, |
| 736 | &last_range, |
| 737 | n_row, |
| 738 | idx, |
| 739 | )?; |
| 740 | assert_eq!(range, expected_range); |
| 741 | last_range = range; |
| 742 | } |
| 743 | Ok(()) |
| 744 | } |
| 745 | |
| 746 | #[test] |
| 747 | fn test_default_window_frame_group_boundaries() -> Result<()> { |
searching dependent graphs…