Skip to content

Commit 399e478

Browse files
committed
mention what is unimplemented in binaryview/utf8view
1 parent 7eda5bf commit 399e478

File tree

6 files changed

+18
-8
lines changed

6 files changed

+18
-8
lines changed

arrow-data/src/data.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1545,7 +1545,9 @@ pub fn layout(data_type: &DataType) -> DataTypeLayout {
15451545
DataType::LargeBinary => DataTypeLayout::new_binary::<i64>(),
15461546
DataType::Utf8 => DataTypeLayout::new_binary::<i32>(),
15471547
DataType::LargeUtf8 => DataTypeLayout::new_binary::<i64>(),
1548-
DataType::BinaryView | DataType::Utf8View => unimplemented!("Not implemented"),
1548+
DataType::BinaryView | DataType::Utf8View => {
1549+
unimplemented!("BinvaryView/Utf8View not implemented")
1550+
}
15491551
DataType::FixedSizeList(_, _) => DataTypeLayout::new_empty(), // all in child data
15501552
DataType::List(_) => DataTypeLayout::new_fixed_width::<i32>(),
15511553
DataType::LargeList(_) => DataTypeLayout::new_fixed_width::<i64>(),

arrow-data/src/equal/mod.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,9 @@ fn equal_values(
9696
variable_sized_equal::<i64>(lhs, rhs, lhs_start, rhs_start, len)
9797
}
9898
DataType::FixedSizeBinary(_) => fixed_binary_equal(lhs, rhs, lhs_start, rhs_start, len),
99-
DataType::BinaryView | DataType::Utf8View => unimplemented!("BinaryView/Utf8View not yet implemented"),
99+
DataType::BinaryView | DataType::Utf8View => {
100+
unimplemented!("BinaryView/Utf8View not yet implemented")
101+
}
100102
DataType::List(_) => list_equal::<i32>(lhs, rhs, lhs_start, rhs_start, len),
101103
DataType::LargeList(_) => list_equal::<i64>(lhs, rhs, lhs_start, rhs_start, len),
102104
DataType::FixedSizeList(_, _) => fixed_list_equal(lhs, rhs, lhs_start, rhs_start, len),

arrow-data/src/transform/mod.rs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,9 @@ fn build_extend(array: &ArrayData) -> Extend {
224224
DataType::Decimal256(_, _) => primitive::build_extend::<i256>(array),
225225
DataType::Utf8 | DataType::Binary => variable_size::build_extend::<i32>(array),
226226
DataType::LargeUtf8 | DataType::LargeBinary => variable_size::build_extend::<i64>(array),
227-
DataType::BinaryView | DataType::Utf8View => unimplemented!("Not implemented"),
227+
DataType::BinaryView | DataType::Utf8View => {
228+
unimplemented!("BinaryView/Utf8View not implemented")
229+
}
228230
DataType::Map(_, _) | DataType::List(_) => list::build_extend::<i32>(array),
229231
DataType::LargeList(_) => list::build_extend::<i64>(array),
230232
DataType::Dictionary(_, _) => unreachable!("should use build_extend_dictionary"),
@@ -267,7 +269,9 @@ fn build_extend_nulls(data_type: &DataType) -> ExtendNulls {
267269
DataType::Decimal256(_, _) => primitive::extend_nulls::<i256>,
268270
DataType::Utf8 | DataType::Binary => variable_size::extend_nulls::<i32>,
269271
DataType::LargeUtf8 | DataType::LargeBinary => variable_size::extend_nulls::<i64>,
270-
DataType::BinaryView | DataType::Utf8View => unimplemented!("Not implemented"),
272+
DataType::BinaryView | DataType::Utf8View => {
273+
unimplemented!("BinaryView/Utf8View not implemented")
274+
}
271275
DataType::Map(_, _) | DataType::List(_) => list::extend_nulls::<i32>,
272276
DataType::LargeList(_) => list::extend_nulls::<i64>,
273277
DataType::Dictionary(child_data_type, _) => match child_data_type.as_ref() {
@@ -422,7 +426,7 @@ impl<'a> MutableArrayData<'a> {
422426
| DataType::Interval(_)
423427
| DataType::FixedSizeBinary(_) => vec![],
424428
DataType::BinaryView | DataType::Utf8View => {
425-
unimplemented!("Not implemented")
429+
unimplemented!("BinaryView/Utf8View not implemented")
426430
}
427431
DataType::Map(_, _) | DataType::List(_) | DataType::LargeList(_) => {
428432
let children = arrays

arrow-integration-test/src/datatype.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -271,7 +271,9 @@ pub fn data_type_to_json(data_type: &DataType) -> serde_json::Value {
271271
DataType::LargeUtf8 => json!({"name": "largeutf8"}),
272272
DataType::Binary => json!({"name": "binary"}),
273273
DataType::LargeBinary => json!({"name": "largebinary"}),
274-
DataType::BinaryView | DataType::Utf8View => unimplemented!("Not implemented"),
274+
DataType::BinaryView | DataType::Utf8View => {
275+
unimplemented!("BinaryView/Utf8View not implemented")
276+
}
275277
DataType::FixedSizeBinary(byte_width) => {
276278
json!({"name": "fixedsizebinary", "byteWidth": byte_width})
277279
}

arrow-ipc/src/convert.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -543,7 +543,7 @@ pub(crate) fn get_fb_field_type<'a>(
543543
.as_union_value(),
544544
children: Some(fbb.create_vector(&empty_fields[..])),
545545
},
546-
BinaryView | Utf8View => unimplemented!("Not implemented"),
546+
BinaryView | Utf8View => unimplemented!("BinaryView/Utf8View not implemented"),
547547
Utf8 => FBFieldType {
548548
type_type: crate::Type::Utf8,
549549
type_: crate::Utf8Builder::new(fbb).finish().as_union_value(),

parquet/src/arrow/schema/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -481,7 +481,7 @@ fn arrow_to_parquet_type(field: &Field) -> Result<Type> {
481481
.with_length(*length)
482482
.build()
483483
}
484-
DataType::BinaryView | DataType::Utf8View => unimplemented!("Not implemented"),
484+
DataType::BinaryView | DataType::Utf8View => unimplemented!("BinaryView/Utf8View not implemented"),
485485
DataType::Decimal128(precision, scale)
486486
| DataType::Decimal256(precision, scale) => {
487487
// Decimal precision determines the Parquet physical type to use.

0 commit comments

Comments
 (0)