@@ -248,14 +248,14 @@ impl PruningPredicate {
248
248
// values in the set for the predicate to evaluate to true.
249
249
// If `contained` returns false, that means the column is
250
250
// not any of the values so we can prune the container
251
- Guarantee :: In => builder. append_array ( & results) ,
251
+ Guarantee :: In => builder. combine_array ( & results) ,
252
252
// `NotIn` means the values in the column must must not be
253
253
// any of the values in the set for the predicate to
254
254
// evaluate to true. If contained returns true, it means the
255
255
// column is only in the set of values so we can prune the
256
256
// container
257
257
Guarantee :: NotIn => {
258
- builder. append_array ( & arrow:: compute:: not ( & results) ?)
258
+ builder. combine_array ( & arrow:: compute:: not ( & results) ?)
259
259
}
260
260
}
261
261
}
@@ -270,7 +270,7 @@ impl PruningPredicate {
270
270
build_statistics_record_batch ( statistics, & self . required_columns ) ?;
271
271
272
272
// Evaluate the pruning predicate on that record batch and append any results to the builder
273
- builder. append_value ( self . predicate_expr . evaluate ( & statistics_batch) ?) ;
273
+ builder. combine_value ( self . predicate_expr . evaluate ( & statistics_batch) ?) ;
274
274
275
275
Ok ( builder. build ( ) )
276
276
}
@@ -336,14 +336,14 @@ impl BoolVecBuilder {
336
336
}
337
337
}
338
338
339
- /// Combines result `array` for a conjunct (e.g. `AND` clause) of a
339
+ /// Combines result `array` for a conjunct (e.g. `AND` clause) of a
340
340
/// predicate into the currently in progress array.
341
341
///
342
342
/// Each `array` element is:
343
343
/// * `true`: container has row that may pass the predicate
344
344
/// * `false`: all container rows DEFINITELY DO NOT pass the predicate
345
345
/// * `null`: container may or may not have rows that pass the predicate
346
- fn append_array ( & mut self , array : & BooleanArray ) {
346
+ fn combine_array ( & mut self , array : & BooleanArray ) {
347
347
assert_eq ! ( array. len( ) , self . inner. len( ) ) ;
348
348
for ( cur, new) in self . inner . iter_mut ( ) . zip ( array. iter ( ) ) {
349
349
// `false` for this conjunct means we know for sure no rows could
@@ -356,14 +356,14 @@ impl BoolVecBuilder {
356
356
}
357
357
358
358
/// Combines the results in the [`ColumnarValue`] to the currently in
359
- /// progress array, following the same rules as [`Self::append_array `].
359
+ /// progress array, following the same rules as [`Self::combine_array `].
360
360
///
361
361
/// # Panics
362
362
/// If `value` is not boolean
363
- fn append_value ( & mut self , value : ColumnarValue ) {
363
+ fn combine_value ( & mut self , value : ColumnarValue ) {
364
364
match value {
365
365
ColumnarValue :: Array ( array) => {
366
- self . append_array ( array. as_boolean ( ) ) ;
366
+ self . combine_array ( array. as_boolean ( ) ) ;
367
367
}
368
368
ColumnarValue :: Scalar ( ScalarValue :: Boolean ( Some ( false ) ) ) => {
369
369
// False means all containers can not pass the predicate
0 commit comments