|
1 | 1 | use std::sync::Arc; |
2 | 2 |
|
3 | | -use arrow::{ |
4 | | - array::{Array, NullArray, RecordBatch}, |
5 | | - datatypes::{Field, Schema}, |
6 | | -}; |
| 3 | +use arrow_array::{Array, ArrayRef, NullArray, RecordBatch}; |
| 4 | +use arrow_schema::{Field, Schema}; |
7 | 5 | use calamine::{Data as CalData, DataRef as CalDataRef, DataType, Range}; |
8 | 6 |
|
9 | 7 | use crate::{ |
@@ -77,7 +75,7 @@ mod array_impls { |
77 | 75 | use std::fmt::Debug; |
78 | 76 | use std::sync::Arc; |
79 | 77 |
|
80 | | - use arrow::array::{ |
| 78 | + use arrow_array::{ |
81 | 79 | Array, BooleanArray, Date32Array, DurationMillisecondArray, Float64Array, Int64Array, |
82 | 80 | StringArray, TimestampMillisecondArray, |
83 | 81 | }; |
@@ -570,10 +568,7 @@ pub(crate) fn record_batch_from_data_and_columns_with_errors( |
570 | 568 | let dtype = *column_info.dtype(); |
571 | 569 |
|
572 | 570 | let (array, new_cell_errors) = match dtype { |
573 | | - DType::Null => ( |
574 | | - Arc::new(NullArray::new(limit - offset)) as Arc<dyn arrow::array::Array>, |
575 | | - vec![], |
576 | | - ), |
| 571 | + DType::Null => (Arc::new(NullArray::new(limit - offset)) as ArrayRef, vec![]), |
577 | 572 | DType::Int => create_int_array_with_errors(data, col_idx, offset, limit), |
578 | 573 | DType::Float => create_float_array_with_errors(data, col_idx, offset, limit), |
579 | 574 | DType::String => create_string_array_with_errors(data, col_idx, offset, limit), |
|
0 commit comments