execute_columnar_batch

Function execute_columnar_batch 

Source
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 layer
  • predicates - Column predicates for SIMD filtering
  • aggregates - Aggregate specifications (SUM, COUNT, etc.)
  • schema - Optional schema for expression evaluation

§Returns

A vector of rows containing the aggregated results