common_recordbatch::filter

Function batch_filter

source
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