pub fn execute_columnar_batch(
batch: &ColumnarBatch,
predicates: &[ColumnPredicate],
aggregates: &[AggregateSpec],
_schema: Option<&CombinedSchema>,
) -> Result<Vec<Row>, ExecutorError>Expand description
Execute a columnar query end-to-end on a ColumnarBatch
This is the main entry point for native columnar execution. It accepts a ColumnarBatch from storage and executes filtering and aggregation entirely in columnar format.
§Arguments
batch- Input ColumnarBatch from storage layerpredicates- Column predicates for SIMD filteringaggregates- Aggregate specifications (SUM, COUNT, etc.)schema- Optional schema for expression evaluation
§Returns
A vector of rows containing the aggregated results