Skip to content

Commit 2355533

Browse files
author
Jiayu Liu
committed
updating unit tests
1 parent 7fd6a49 commit 2355533

File tree

2 files changed

+10
-7
lines changed

2 files changed

+10
-7
lines changed

datafusion/src/physical_plan/windows.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ fn create_built_in_window_expr(
119119
Ok(Arc::new(LastValue::new(arg, name, data_type)))
120120
}
121121
_ => Err(DataFusionError::NotImplemented(format!(
122-
"window function with {:?} not yet implemented",
122+
"Window function with {:?} not yet implemented",
123123
fun
124124
))),
125125
}

datafusion/tests/sql.rs

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -807,15 +807,18 @@ async fn csv_query_window_with_empty_over() -> Result<()> {
807807
avg(c3) over (), \
808808
count(c3) over (), \
809809
max(c3) over (), \
810-
min(c3) over () \
810+
min(c3) over (), \
811+
first_value(c3) over (), \
812+
last_value(c3) over (), \
813+
nth_value(c3, 2) over ()
811814
from aggregate_test_100 limit 5";
812815
let actual = execute(&mut ctx, sql).await;
813816
let expected = vec![
814-
vec!["2", "781", "7.81", "100", "125", "-117"],
815-
vec!["5", "781", "7.81", "100", "125", "-117"],
816-
vec!["1", "781", "7.81", "100", "125", "-117"],
817-
vec!["1", "781", "7.81", "100", "125", "-117"],
818-
vec!["5", "781", "7.81", "100", "125", "-117"],
817+
vec!["2", "781", "7.81", "100", "125", "-117", "1", "30", "-40"],
818+
vec!["5", "781", "7.81", "100", "125", "-117", "1", "30", "-40"],
819+
vec!["1", "781", "7.81", "100", "125", "-117", "1", "30", "-40"],
820+
vec!["1", "781", "7.81", "100", "125", "-117", "1", "30", "-40"],
821+
vec!["5", "781", "7.81", "100", "125", "-117", "1", "30", "-40"],
819822
];
820823
assert_eq!(expected, actual);
821824
Ok(())

0 commit comments

Comments
 (0)