fix

spiraldb · Mar 20, 2024 · 047b343 · 047b343
1 parent 74fe623
commit 047b343
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/vortex-array/src/array/varbinview/compute.rs b/vortex-array/src/array/varbinview/compute.rs
@@ -12,7 +12,7 @@ use crate::compute::as_arrow::AsArrowArray;
 use crate::compute::flatten::{flatten, flatten_primitive, FlattenFn, FlattenedArray};
 use crate::compute::scalar_at::ScalarAtFn;
 use crate::compute::ArrayCompute;
-use crate::error::VortexResult;
+use crate::error::{VortexError, VortexResult};
 use crate::ptype::PType;
 use crate::scalar::Scalar;
 

diff --git a/vortex-array/src/ptype.rs b/vortex-array/src/ptype.rs
@@ -224,10 +224,12 @@ impl From<PType> for &DType {
             PType::I16 => &Int(IntWidth::_16, Signed, NonNullable),
             PType::I32 => &Int(IntWidth::_32, Signed, NonNullable),
             PType::I64 => &Int(IntWidth::_64, Signed, NonNullable),
+            PType::I128 => &Int(IntWidth::_128, Signed, NonNullable),
             PType::U8 => &Int(IntWidth::_8, Unsigned, NonNullable),
             PType::U16 => &Int(IntWidth::_16, Unsigned, NonNullable),
             PType::U32 => &Int(IntWidth::_32, Unsigned, NonNullable),
             PType::U64 => &Int(IntWidth::_64, Unsigned, NonNullable),
+            PType::U128 => &Int(IntWidth::_128, Unsigned, NonNullable),
             PType::F16 => &Float(FloatWidth::_16, NonNullable),
             PType::F32 => &Float(FloatWidth::_32, NonNullable),
             PType::F64 => &Float(FloatWidth::_64, NonNullable),
@@ -245,10 +247,12 @@ impl From<PType> for DType {
             PType::I16 => Int(IntWidth::_16, Signed, NonNullable),
             PType::I32 => Int(IntWidth::_32, Signed, NonNullable),
             PType::I64 => Int(IntWidth::_64, Signed, NonNullable),
+            PType::I128 => Int(IntWidth::_128, Signed, NonNullable),
             PType::U8 => Int(IntWidth::_8, Unsigned, NonNullable),
             PType::U16 => Int(IntWidth::_16, Unsigned, NonNullable),
             PType::U32 => Int(IntWidth::_32, Unsigned, NonNullable),
             PType::U64 => Int(IntWidth::_64, Unsigned, NonNullable),
+            PType::U128 => Int(IntWidth::_128, Unsigned, NonNullable),
             PType::F16 => Float(FloatWidth::_16, NonNullable),
             PType::F32 => Float(FloatWidth::_32, NonNullable),
             PType::F64 => Float(FloatWidth::_64, NonNullable),