pub fn batch_filter(
batch: &RecordBatch,
predicate: &Arc<dyn PhysicalExpr>,
) -> Result<RecordBatch>
Expand description
Evaluate the predicate on the input RecordBatch, and return a new RecordBatch. Copy from datafusion::physical_plan::src::filter.rs