Skip to content

Commit ec21168

Browse files
committed
format
Signed-off-by: Robert Kruszewski <github@robertk.io>
1 parent 1edb7f8 commit ec21168

2 files changed

Lines changed: 8 additions & 11 deletions

File tree

encodings/fastlanes/src/for/array/for_compress.rs

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -38,16 +38,13 @@ fn compress_primitive<T: NativePType + WrappingSub + PrimInt>(
3838
) -> VortexResult<PrimitiveArray> {
3939
// Set null values to the min value, ensuring that decompress into a value in the primitive
4040
// range (and stop them wrapping around).
41-
let encoded = parray.map_each_with_validity::<T, _, _>(
42-
|(v, bool)| {
43-
if bool {
44-
v.wrapping_sub(&min)
45-
} else {
46-
T::zero()
47-
}
48-
},
49-
ctx,
50-
)?;
41+
let encoded = parray.map_each_with_validity::<T, _, _>(ctx, |(v, bool)| {
42+
if bool {
43+
v.wrapping_sub(&min)
44+
} else {
45+
T::zero()
46+
}
47+
})?;
5148
Ok(encoded)
5249
}
5350

vortex-array/src/arrays/primitive/array/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -480,7 +480,7 @@ impl Array<Primitive> {
480480
}
481481
}
482482

483-
pub fn map_each_with_validity<T, R, F>(self, f: F, ctx: &mut ExecutionCtx) -> VortexResult<Self>
483+
pub fn map_each_with_validity<T, R, F>(self, ctx: &mut ExecutionCtx, f: F) -> VortexResult<Self>
484484
where
485485
T: NativePType,
486486
R: NativePType,

0 commit comments

Comments
 (0)