Skip to content

Commit 1629420

Browse files
feat(spark): implement Spark make_interval function (#17424)
* feat(spark): implement Spark make_interval function * fix name length * add doc * add doc and change test, need more test * fmt * add test and doc, need to work in overflow * clippy * empty params * test ok IntervalMonthDayNano::new(0, 0, 0) in unit test * line blank * fix doc table select * dont panic * update test and not panic fmt * review * review fix test failure * review fix test failure format simple string * test uncomment and link * return test (empty) * changes review * all overflow null * all overflow null fix fmt * changes review * changes review clippy * refactor move * fix error doc date_sub * clean slt * no space device
1 parent 78d5779 commit 1629420

File tree

4 files changed

+708
-2
lines changed

4 files changed

+708
-2
lines changed

datafusion/spark/src/function/datetime/date_sub.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ fn spark_date_sub(args: &[ArrayRef]) -> Result<ArrayRef> {
114114
}
115115
_ => {
116116
return internal_err!(
117-
"Spark `date_add` function: argument must be int8, int16, int32, got {:?}",
117+
"Spark `date_sub` function: argument must be int8, int16, int32, got {:?}",
118118
days_arg.data_type()
119119
);
120120
}

0 commit comments

Comments
 (0)