Skip to content

Commit

Permalink
rm length check
Browse files Browse the repository at this point in the history
  • Loading branch information
jayzhan211 committed Feb 25, 2025
1 parent 1caec80 commit 7e28c67
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions datafusion/functions/src/math/gcd.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,9 +23,7 @@ use std::any::Any;
use std::mem::swap;
use std::sync::Arc;

use datafusion_common::{
exec_err, internal_datafusion_err, internal_err, Result, ScalarValue,
};
use datafusion_common::{exec_err, internal_datafusion_err, Result, ScalarValue};
use datafusion_expr::{
ColumnarValue, Documentation, ScalarFunctionArgs, ScalarUDFImpl, Signature,
Volatility,
Expand Down Expand Up @@ -114,13 +112,6 @@ impl ScalarUDFImpl for GcdFunc {
fn compute_gcd_for_arrays(a: &ArrayRef, b: &ArrayRef) -> Result<ColumnarValue> {
let a = a.as_primitive::<Int64Type>();
let b = b.as_primitive::<Int64Type>();
if a.len() != b.len() {
return internal_err!(
"Length of arguments for function gcd do not match: {} vs {}",
a.len(),
b.len()
);
}
try_binary(a, b, compute_gcd)
.map(|arr: PrimitiveArray<Int64Type>| {
ColumnarValue::Array(Arc::new(arr) as ArrayRef)
Expand Down

0 comments on commit 7e28c67

Please sign in to comment.