File tree Expand file tree Collapse file tree 2 files changed +3
-5
lines changed
vortex-duckdb/src/exporter Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,7 @@ use vortex::array::arrays::ConstantArray;
1414use vortex:: array:: arrays:: ConstantVTable ;
1515use vortex:: array:: arrays:: DictArray ;
1616use vortex:: array:: arrays:: PrimitiveArray ;
17+ use vortex:: array:: builtins:: ArrayBuiltins ;
1718use vortex:: array:: mask:: MaskExecutor ;
1819use vortex:: array:: vectors:: VectorIntoArray ;
1920use vortex:: compute;
@@ -190,10 +191,7 @@ pub(crate) fn new_vector_exporter_with_flatten(
190191 if let Some ( constant) = values. as_opt :: < ConstantVTable > ( ) {
191192 return constant:: new_exporter_with_mask (
192193 & ConstantArray :: new ( constant. scalar ( ) . clone ( ) , array. codes ( ) . len ( ) ) ,
193- array
194- . codes ( )
195- . apply ( & not ( is_null ( root ( ) ) ) ) ?
196- . execute_mask ( session) ?,
194+ array. codes ( ) . is_null ( ) ?. not ( ) ?. execute_mask ( session) ?,
197195 cache,
198196 ) ;
199197 }
Original file line number Diff line number Diff line change @@ -107,7 +107,7 @@ pub(crate) fn new_vector_exporter(
107107
108108 let mask = array. validity ( ) ;
109109
110- if let Validity :: AllInvalid = mask {
110+ if matches ! ( mask , Validity :: AllInvalid ) {
111111 return Ok ( all_invalid:: new_exporter ( array. len ( ) , & ltype) ) ;
112112 }
113113
You can’t perform that action at this time.
0 commit comments