|
1 | 1 | use super::{BindInfo, DataChunkHandle, InitInfo, LogicalTypeHandle, TableFunctionInfo, VTab}; |
2 | | -use std::sync::Arc; |
3 | | -use std::sync::{atomic::AtomicBool, Mutex}; |
| 2 | +use std::sync::{atomic::AtomicBool, Arc, Mutex}; |
4 | 3 |
|
5 | 4 | use crate::{ |
6 | 5 | core::{ArrayVector, FlatVector, Inserter, ListVector, LogicalTypeId, StructVector, Vector}, |
7 | 6 | types::DuckString, |
8 | 7 | }; |
9 | 8 |
|
10 | | -use arrow::array::as_map_array; |
11 | 9 | use arrow::{ |
12 | 10 | array::{ |
13 | | - as_boolean_array, as_generic_binary_array, as_large_list_array, as_list_array, as_primitive_array, |
14 | | - as_string_array, as_struct_array, Array, ArrayData, AsArray, BinaryArray, BinaryViewArray, BooleanArray, |
15 | | - Date32Array, Decimal128Array, FixedSizeBinaryArray, FixedSizeListArray, GenericBinaryBuilder, GenericListArray, |
16 | | - GenericStringArray, IntervalMonthDayNanoArray, LargeBinaryArray, LargeStringArray, OffsetSizeTrait, |
17 | | - PrimitiveArray, StringArray, StringViewArray, StructArray, TimestampMicrosecondArray, TimestampNanosecondArray, |
| 11 | + as_boolean_array, as_generic_binary_array, as_large_list_array, as_list_array, as_map_array, |
| 12 | + as_primitive_array, as_string_array, as_struct_array, Array, ArrayData, AsArray, BinaryArray, BinaryViewArray, |
| 13 | + BooleanArray, Date32Array, Decimal128Array, FixedSizeBinaryArray, FixedSizeListArray, GenericBinaryBuilder, |
| 14 | + GenericListArray, GenericStringArray, IntervalMonthDayNanoArray, LargeBinaryArray, LargeStringArray, |
| 15 | + OffsetSizeTrait, PrimitiveArray, StringArray, StringViewArray, StructArray, TimestampMicrosecondArray, |
| 16 | + TimestampNanosecondArray, |
18 | 17 | }, |
19 | 18 | buffer::{BooleanBuffer, NullBuffer}, |
20 | 19 | compute::cast, |
@@ -1714,11 +1713,7 @@ mod test { |
1714 | 1713 |
|
1715 | 1714 | let mut stmt = db.prepare("SELECT * FROM arrow(?, ?)").unwrap(); |
1716 | 1715 |
|
1717 | | - let res = match stmt.execute(arrow_recordbatch_to_query_params(batch)) { |
1718 | | - Ok(..) => None, |
1719 | | - Err(e) => Some(e), |
1720 | | - } |
1721 | | - .unwrap(); |
| 1716 | + let res = stmt.execute(arrow_recordbatch_to_query_params(batch)).err().unwrap(); |
1722 | 1717 |
|
1723 | 1718 | assert_eq!( |
1724 | 1719 | res, |
|
0 commit comments