MCPcopy Create free account
hub / github.com/apache/datafusion / assert_group_ranges

Function assert_group_ranges

datafusion/expr/src/window_state.rs:702–722  ·  view source on GitHub ↗
(
        window_frame: &Arc<WindowFrame>,
        expected_results: Vec<(Range<usize>, usize)>,
    )

Source from the content-addressed store, hash-verified

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>,

Calls 4

get_test_dataFunction · 0.70
lenMethod · 0.45
into_iterMethod · 0.45
calculate_rangeMethod · 0.45

Used in the wild real call sites across dependent graphs

searching dependent graphs…