Skip to content

Commit 7979db1

Browse files
committed
DataFusion 52 migration
1 parent 678ce64 commit 7979db1

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

native/spark-expr/src/conversion_funcs/cast.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,10 @@ use arrow::array::{
2424
PrimitiveBuilder, StringArray, StructArray, TimestampMicrosecondBuilder,
2525
};
2626
use arrow::compute::can_cast_types;
27-
use arrow::datatypes::{i256, ArrowDictionaryKeyType, ArrowNativeType, DataType, Decimal256Type, GenericBinaryType, Schema, TimeUnit};
27+
use arrow::datatypes::{
28+
i256, ArrowDictionaryKeyType, ArrowNativeType, DataType, Decimal256Type, GenericBinaryType,
29+
Schema,
30+
};
2831
use arrow::{
2932
array::{
3033
cast::AsArray,

native/spark-expr/src/utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,13 +29,13 @@ use std::sync::Arc;
2929

3030
use crate::timezone::Tz;
3131
use arrow::array::types::TimestampMillisecondType;
32+
use arrow::array::TimestampMicrosecondArray;
3233
use arrow::datatypes::{MAX_DECIMAL128_FOR_EACH_PRECISION, MIN_DECIMAL128_FOR_EACH_PRECISION};
3334
use arrow::error::ArrowError;
3435
use arrow::{
3536
array::{as_dictionary_array, Array, ArrayRef, PrimitiveArray},
3637
temporal_conversions::as_datetime,
3738
};
38-
use arrow::array::TimestampMicrosecondArray;
3939
use chrono::{DateTime, Offset, TimeZone};
4040

4141
/// Preprocesses input arrays to add timezone information from Spark to Arrow array datatype or

0 commit comments

Comments
 (0)