Skip to content

Commit ac4adfa

Browse files
authored
fix typo (#8473)
1 parent 91cc573 commit ac4adfa

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

datafusion/physical-expr/src/datetime_expressions.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -419,7 +419,7 @@ pub fn date_trunc(args: &[ColumnarValue]) -> Result<ColumnarValue> {
419419
Ok(ColumnarValue::Array(Arc::new(array)))
420420
}
421421

422-
fn process_scalr<T: ArrowTimestampType>(
422+
fn process_scalar<T: ArrowTimestampType>(
423423
v: &Option<i64>,
424424
granularity: String,
425425
tz_opt: &Option<Arc<str>>,
@@ -432,16 +432,16 @@ pub fn date_trunc(args: &[ColumnarValue]) -> Result<ColumnarValue> {
432432

433433
Ok(match array {
434434
ColumnarValue::Scalar(ScalarValue::TimestampNanosecond(v, tz_opt)) => {
435-
process_scalr::<TimestampNanosecondType>(v, granularity, tz_opt)?
435+
process_scalar::<TimestampNanosecondType>(v, granularity, tz_opt)?
436436
}
437437
ColumnarValue::Scalar(ScalarValue::TimestampMicrosecond(v, tz_opt)) => {
438-
process_scalr::<TimestampMicrosecondType>(v, granularity, tz_opt)?
438+
process_scalar::<TimestampMicrosecondType>(v, granularity, tz_opt)?
439439
}
440440
ColumnarValue::Scalar(ScalarValue::TimestampMillisecond(v, tz_opt)) => {
441-
process_scalr::<TimestampMillisecondType>(v, granularity, tz_opt)?
441+
process_scalar::<TimestampMillisecondType>(v, granularity, tz_opt)?
442442
}
443443
ColumnarValue::Scalar(ScalarValue::TimestampSecond(v, tz_opt)) => {
444-
process_scalr::<TimestampSecondType>(v, granularity, tz_opt)?
444+
process_scalar::<TimestampSecondType>(v, granularity, tz_opt)?
445445
}
446446
ColumnarValue::Array(array) => {
447447
let array_type = array.data_type();

0 commit comments

Comments
 (0)