From 852a1a31ca710b569e49e0d946536859e0d399ea Mon Sep 17 00:00:00 2001 From: "Jorge C. Leitao" Date: Sun, 22 Aug 2021 21:11:20 +0000 Subject: [PATCH] Simplified code. --- src/compute/comparison/mod.rs | 78 +++++++++++++++++------------------ 1 file changed, 39 insertions(+), 39 deletions(-) diff --git a/src/compute/comparison/mod.rs b/src/compute/comparison/mod.rs index 69d7ed07b1b..9df1d4fac2d 100644 --- a/src/compute/comparison/mod.rs +++ b/src/compute/comparison/mod.rs @@ -57,77 +57,77 @@ pub fn compare(lhs: &dyn Array, rhs: &dyn Array, operator: Operator) -> Result { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::Int16 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::Int32 | DataType::Date32 | DataType::Time32(_) | DataType::Interval(IntervalUnit::YearMonth) => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::Int64 | DataType::Timestamp(_, None) | DataType::Date64 | DataType::Time64(_) | DataType::Duration(_) => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::UInt8 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::UInt16 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::UInt32 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::UInt64 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::Float16 => unreachable!(), DataType::Float32 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::Float64 => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } DataType::Utf8 => { - let lhs = lhs.as_any().downcast_ref::>().unwrap(); - let rhs = rhs.as_any().downcast_ref::>().unwrap(); - utf8::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + utf8::compare::(lhs, rhs, operator) } DataType::LargeUtf8 => { - let lhs = lhs.as_any().downcast_ref::>().unwrap(); - let rhs = rhs.as_any().downcast_ref::>().unwrap(); - utf8::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + utf8::compare::(lhs, rhs, operator) } DataType::Decimal(_, _) => { - let lhs = lhs.as_any().downcast_ref::().unwrap(); - let rhs = rhs.as_any().downcast_ref::().unwrap(); - primitive::compare(lhs, rhs, operator) + let lhs = lhs.as_any().downcast_ref().unwrap(); + let rhs = rhs.as_any().downcast_ref().unwrap(); + primitive::compare::(lhs, rhs, operator) } _ => Err(ArrowError::NotYetImplemented(format!( "Comparison between {:?} is not supported",