@@ -8,14 +8,10 @@ use std::marker::PhantomData;
88use vortex_array:: ArrayRef ;
99use vortex_array:: Canonical ;
1010use vortex_array:: IntoArray ;
11- use vortex_array:: LEGACY_SESSION ;
1211use vortex_array:: ToCanonical ;
13- use vortex_array:: VortexSessionExecute ;
1412use vortex_array:: arrays:: PrimitiveArray ;
1513use vortex_error:: VortexResult ;
16- use vortex_fastlanes:: DeltaArray ;
1714use vortex_fastlanes:: RLEArray ;
18- use vortex_fastlanes:: delta_compress;
1915
2016use crate :: BtrBlocksCompressor ;
2117use crate :: CanonicalCompressor ;
@@ -179,14 +175,18 @@ fn try_compress_delta(
179175 ctx : CompressorContext ,
180176 excludes : Excludes ,
181177) -> VortexResult < ArrayRef > {
182- let ( bases, deltas) =
183- delta_compress ( primitive_array, & mut LEGACY_SESSION . create_execution_ctx ( ) ) ?;
178+ use vortex_array:: VortexSessionExecute ;
179+
180+ let ( bases, deltas) = vortex_fastlanes:: delta_compress (
181+ primitive_array,
182+ & mut vortex_array:: LEGACY_SESSION . create_execution_ctx ( ) ,
183+ ) ?;
184184
185185 let compressed_bases =
186186 compressor. compress_canonical ( Canonical :: Primitive ( bases) , ctx, excludes) ?;
187187 let compressed_deltas =
188188 compressor. compress_canonical ( Canonical :: Primitive ( deltas) , ctx, excludes) ?;
189189
190- DeltaArray :: try_from_delta_compress_parts ( compressed_bases, compressed_deltas)
191- . map ( DeltaArray :: into_array)
190+ vortex_fastlanes :: DeltaArray :: try_from_delta_compress_parts ( compressed_bases, compressed_deltas)
191+ . map ( vortex_fastlanes :: DeltaArray :: into_array)
192192}
0 commit comments