Skip to content

Commit d5609f5

Browse files
committed
fix: Allow date_trunc to accept Date32 (stub)
1 parent fe08167 commit d5609f5

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

datafusion/core/src/physical_plan/functions.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -515,6 +515,7 @@ fn signature(fun: &BuiltinScalarFunction) -> Signature {
515515
DataType::Utf8,
516516
DataType::Timestamp(TimeUnit::Nanosecond, Some("UTC".to_owned())),
517517
]),
518+
TypeSignature::Exact(vec![DataType::Utf8, DataType::Date32]),
518519
],
519520
fun.volatility(),
520521
),

datafusion/physical-expr/src/datetime_expressions.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -442,6 +442,11 @@ pub fn date_trunc(args: &[ColumnarValue]) -> Result<ColumnarValue> {
442442
tz_opt.clone(),
443443
))
444444
}
445+
ColumnarValue::Scalar(ScalarValue::Date32(_)) => {
446+
return Err(DataFusionError::Execution(
447+
"`date_trunc` does not accept Date32 type, it's a stub".to_string(),
448+
));
449+
}
445450
ColumnarValue::Array(array) => {
446451
let array = array
447452
.as_any()

0 commit comments

Comments
 (0)