File tree Expand file tree Collapse file tree 1 file changed +3
-9
lines changed
parquet/src/arrow/arrow_reader Expand file tree Collapse file tree 1 file changed +3
-9
lines changed Original file line number Diff line number Diff line change @@ -164,15 +164,16 @@ impl ReadPlanBuilder {
164164 let Self {
165165 batch_size,
166166 selection,
167- cached_predicate_result,
167+ // The cached predicate result is not used in the final `ReadPlan` -- it is used directly
168+ // in the ArrayReader to filter the data.
169+ cached_predicate_result : _,
168170 } = self ;
169171
170172 let selection = selection. map ( |s| s. trim ( ) . into ( ) ) ;
171173
172174 ReadPlan {
173175 batch_size,
174176 selection,
175- cached_predicate_result,
176177 }
177178 }
178179}
@@ -272,8 +273,6 @@ pub(crate) struct ReadPlan {
272273 /// TODO update this to use something more efficient
273274 /// See <https://github.com/apache/arrow-rs/pull/7454/files#r2092962327>
274275 selection : Option < VecDeque < RowSelector > > ,
275- /// Cached result of evaluating some column(s) with the current RowSelection
276- cached_predicate_result : Option < CachedPredicateResult > ,
277276}
278277
279278impl ReadPlan {
@@ -282,11 +281,6 @@ impl ReadPlan {
282281 self . selection . as_mut ( )
283282 }
284283
285- /// Returns the current cached predicate result, if any
286- pub ( crate ) fn cached_predicate_result ( & self ) -> Option < & CachedPredicateResult > {
287- self . cached_predicate_result . as_ref ( )
288- }
289-
290284 /// Return the number of rows to read in each output batch
291285 #[ inline( always) ]
292286 pub fn batch_size ( & self ) -> usize {
You can’t perform that action at this time.
0 commit comments