diff --git a/vortex-array/src/expr/exprs/get_item.rs b/vortex-array/src/expr/exprs/get_item.rs index 74459401c16..57c745c8336 100644 --- a/vortex-array/src/expr/exprs/get_item.rs +++ b/vortex-array/src/expr/exprs/get_item.rs @@ -116,8 +116,7 @@ impl VTable for GetItem { match input.dtype().nullability() { Nullability::NonNullable => Ok(field), Nullability::Nullable => field.mask(input.validity()?.to_array(input.len())), - }? - .execute(args.ctx) + } } fn reduce( diff --git a/vortex-array/src/expr/exprs/is_null.rs b/vortex-array/src/expr/exprs/is_null.rs index fdc765fbb09..3c76561e274 100644 --- a/vortex-array/src/expr/exprs/is_null.rs +++ b/vortex-array/src/expr/exprs/is_null.rs @@ -81,13 +81,13 @@ impl VTable for IsNull { return Ok(ConstantArray::new(scalar.is_null(), args.row_count).into_array()); } - Ok(match child.validity()? { + match child.validity()? { Validity::NonNullable | Validity::AllValid => { - ConstantArray::new(false, args.row_count).into_array() + Ok(ConstantArray::new(false, args.row_count).into_array()) } - Validity::AllInvalid => ConstantArray::new(true, args.row_count).into_array(), - Validity::Array(a) => a.not()?.execute(args.ctx)?, - }) + Validity::AllInvalid => Ok(ConstantArray::new(true, args.row_count).into_array()), + Validity::Array(a) => a.not(), + } } fn stat_falsification(