File tree Expand file tree Collapse file tree 10 files changed +61
-449
lines changed
Expand file tree Collapse file tree 10 files changed +61
-449
lines changed Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -10,9 +10,6 @@ mod array;
1010pub use array:: * ;
1111
1212mod compute;
13- mod execute;
14-
15- pub use execute:: take_canonical;
1613
1714pub mod vtable;
1815pub use vtable:: * ;
Original file line number Diff line number Diff line change @@ -11,7 +11,6 @@ use vortex_error::vortex_err;
1111
1212use super :: DictArray ;
1313use super :: DictMetadata ;
14- use super :: take_canonical;
1514use crate :: ArrayRef ;
1615use crate :: Canonical ;
1716use crate :: DeserializeMetadata ;
@@ -20,6 +19,7 @@ use crate::SerializeMetadata;
2019use crate :: VectorExecutor ;
2120use crate :: arrays:: vtable:: rules:: PARENT_RULES ;
2221use crate :: buffer:: BufferHandle ;
22+ use crate :: compute:: take;
2323use crate :: executor:: ExecutionCtx ;
2424use crate :: serde:: ArrayChildren ;
2525use crate :: vtable;
@@ -132,9 +132,8 @@ impl VTable for DictVTable {
132132 }
133133
134134 fn execute ( array : & Self :: Array , ctx : & mut ExecutionCtx ) -> VortexResult < Canonical > {
135- let values = array. values ( ) . execute ( ctx) ?;
136- let codes = array. codes ( ) . execute ( ctx) ?. into_primitive ( ) ;
137- Ok ( take_canonical ( values, & codes) )
135+ // TODO(joe): remove take compute fn
136+ take ( array. values ( ) , array. codes ( ) ) . and_then ( |a| a. execute ( ctx) )
138137 }
139138
140139 fn reduce_parent (
Load Diff This file was deleted.
Original file line number Diff line number Diff line change 22// SPDX-FileCopyrightText: Copyright the Vortex contributors
33
44mod array;
5- mod execute;
65mod rules;
76mod vtable;
87
98pub use array:: * ;
10- pub use execute:: FILTER_SLICES_SELECTIVITY_THRESHOLD ;
11- pub use execute:: filter_canonical;
12- pub use execute:: filter_slice;
139pub use vtable:: * ;
Original file line number Diff line number Diff line change @@ -15,7 +15,6 @@ use vortex_error::vortex_ensure;
1515use vortex_mask:: Mask ;
1616use vortex_scalar:: Scalar ;
1717
18- use super :: execute:: filter_canonical;
1918use crate :: Array ;
2019use crate :: ArrayBufferVisitor ;
2120use crate :: ArrayChildVisitor ;
@@ -31,6 +30,7 @@ use crate::VortexSessionExecute;
3130use crate :: arrays:: filter:: array:: FilterArray ;
3231use crate :: arrays:: filter:: rules:: PARENT_RULES ;
3332use crate :: buffer:: BufferHandle ;
33+ use crate :: compute:: filter;
3434use crate :: executor:: ExecutionCtx ;
3535use crate :: serde:: ArrayChildren ;
3636use crate :: stats:: StatsSetRef ;
@@ -114,8 +114,7 @@ impl VTable for FilterVTable {
114114 }
115115
116116 fn execute ( array : & Self :: Array , ctx : & mut ExecutionCtx ) -> VortexResult < Canonical > {
117- let child = array. child . execute ( ctx) ?;
118- Ok ( filter_canonical ( child, & array. mask ) )
117+ filter ( array. child . as_ref ( ) , & array. mask ) . and_then ( |a| a. execute ( ctx) )
119118 }
120119
121120 fn reduce_parent (
You can’t perform that action at this time.
0 commit comments