File tree Expand file tree Collapse file tree 1 file changed +8
-0
lines changed
Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -26,6 +26,7 @@ use url::Url;
2626use vortex:: VortexSessionDefault ;
2727use vortex:: array:: ArrayRef ;
2828use vortex:: array:: ToCanonical ;
29+ use vortex:: array:: optimizer:: ArrayOptimizer ;
2930use vortex:: dtype:: FieldNames ;
3031use vortex:: error:: VortexExpect ;
3132use vortex:: error:: VortexResult ;
@@ -43,6 +44,7 @@ use vortex::file::VortexFile;
4344use vortex:: file:: VortexOpenOptions ;
4445use vortex:: io:: runtime:: BlockingRuntime ;
4546use vortex:: io:: runtime:: current:: ThreadSafeIterator ;
47+ use vortex:: layout:: layouts:: USE_VORTEX_OPERATORS ;
4648use vortex:: session:: VortexSession ;
4749
4850use crate :: RUNTIME ;
@@ -327,6 +329,12 @@ impl TableFunction for VortexTableFunction {
327329
328330 let ( array_result, conversion_cache) = result?;
329331
332+ let array_result = if * USE_VORTEX_OPERATORS {
333+ array_result. optimize_recursive ( ) ?
334+ } else {
335+ array_result
336+ } ;
337+
330338 local_state. exporter = Some ( ArrayExporter :: try_new (
331339 & array_result. to_struct ( ) ,
332340 & conversion_cache,
You can’t perform that action at this time.
0 commit comments