pub(crate) fn evaluate_predicate(
batch_size: usize,
array_reader: Box<dyn ArrayReader>,
input_selection: Option<RowSelection>,
predicate: &mut dyn ArrowPredicate,
) -> Result<RowSelection>
Expand description
Evaluates an ArrowPredicate
, returning a RowSelection
indicating
which rows to return.
input_selection
: Optional pre-existing selection. If Some
, then the
final RowSelection
will be the conjunction of it and the rows selected
by predicate
.
Note: A pre-existing selection may come from evaluating a previous predicate
or if the ParquetRecordBatchReader
specified an explicit
RowSelection
in addition to one or more predicates.