Skip to content

Commit 4317967

Browse files
committed
fix the name of the list
1 parent 97261c7 commit 4317967

File tree

1 file changed

+20
-3
lines changed

1 file changed

+20
-3
lines changed

datafusion/sql/src/planner.rs

Lines changed: 20 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -602,7 +602,14 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
602602
SQLDataType::Array(ArrayElemTypeDef::AngleBracket(inner_sql_type)) => {
603603
// Arrays may be multi-dimensional.
604604
let inner_data_type = self.convert_data_type(inner_sql_type)?;
605-
Ok(Field::new("", DataType::List(inner_data_type), true).into())
605+
Ok(Field::new(
606+
"",
607+
DataType::List(
608+
inner_data_type.as_ref().clone().with_name("item").into(),
609+
),
610+
true,
611+
)
612+
.into())
606613
}
607614
SQLDataType::Array(ArrayElemTypeDef::SquareBracket(
608615
inner_sql_type,
@@ -612,12 +619,22 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
612619
if let Some(array_size) = maybe_array_size {
613620
Ok(Field::new(
614621
"",
615-
DataType::FixedSizeList(inner_data_type, *array_size as i32),
622+
DataType::FixedSizeList(
623+
inner_data_type.as_ref().clone().with_name("item").into(),
624+
*array_size as i32,
625+
),
616626
true,
617627
)
618628
.into())
619629
} else {
620-
Ok(Field::new("", DataType::List(inner_data_type), true).into())
630+
Ok(Field::new(
631+
"",
632+
DataType::List(
633+
inner_data_type.as_ref().clone().with_name("item").into(),
634+
),
635+
true,
636+
)
637+
.into())
621638
}
622639
}
623640
SQLDataType::Array(ArrayElemTypeDef::None) => {

0 commit comments

Comments
 (0)