Struct VectorizedExecutor 

pub struct VectorizedExecutor { /* private fields */ }

Vectorized executor for batch predicate evaluation

Performance Characteristics

• Traditional row-at-a-time: ~100M rows/sec (branch misprediction bound)
• Vectorized with selection vector: ~1B rows/sec (branch-free)

Usage

let executor = VectorizedExecutor::new(1024);
let columns = vec![/* column batches */];
let predicates = vec![/* predicates */];
let selection = executor.evaluate_batch(&columns, &predicates);

Implementations

impl VectorizedExecutor

pub fn new(batch_size: usize) -> Self

Create with specified batch size

pub fn default_batch_size() -> usize

Default batch size (1024 rows)

pub fn evaluate_batch( &self, columns: &[ColumnBatch], predicates: &[VectorPredicate], ) -> SelectionVector

Evaluate predicates on columnar batch

Returns selection vector of rows that pass all predicates. Short-circuits at batch level when selection becomes empty.

pub fn materialize( &self, columns: &[ColumnBatch], selection: &SelectionVector, ) -> Vec<SochRow>

Materialize selected rows from columnar data

pub fn row_to_columnar( &self, rows: &[SochRow], column_names: &[String], ) -> Vec<ColumnBatch>

Convert row-oriented data to columnar batches

Trait Implementations

impl Default for VectorizedExecutor

fn default() -> Self

Returns the “default value” for a type.