Module processor 

Query processor — maps logical operators to physical operators and executes them.

Pipeline execution model:

1. Scan operators produce raw DataChunks
2. Filter removes non-matching rows
3. Projection selects/transforms columns
4. Limit/OrderBy/Aggregate are applied last

Re-exports

pub use chunk_helpers::*;

pub use graph_source::*;

pub use join_helpers::*;

pub use mapper::*;

pub use plan_serializer::*;

pub use projection_helper::*;

pub use union_helpers::*;

Modules

chunk_helpers

graph_source

Builds a GraphDataSource snapshot from the storage TableCatalog.

join_helpers

mapper

plan_serializer

projection_helper

union_helpers

Structs

QueryProcessor

The query processor executes a physical plan and produces result chunks.

StandaloneCallRegistry

Enums

SchemaDdlOp

DDL operations that require the schema-level Catalog (from Akar-catalog). These are dispatched via callback because the processor layer doesn’t directly own the schema catalog.

Traits

StandaloneCallFn

StandaloneCallHandler

Type Aliases

SchemaDdlFn

SequenceFn

SubqueryFn