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

Function assert_frame_ranges

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

Source from the content-addressed store, hash-verified

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<()> {

Calls 5

newFunction · 0.85
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…