Module executor

Module executor 

Source
Expand description

High-performance query execution engine for RuVector graph database

This module provides a complete query execution system with:

  • Logical and physical query plans
  • Vectorized operators (scan, filter, join, aggregate)
  • Pipeline execution with iterator model
  • Parallel execution using rayon
  • Query result caching
  • Cost-based optimization statistics

Performance targets:

  • 100K+ traversals/second per core
  • Sub-millisecond simple lookups
  • SIMD-optimized predicate evaluation

Re-exports§

pub use cache::CacheConfig;
pub use cache::CacheEntry;
pub use cache::QueryCache;
pub use operators::Aggregate;
pub use operators::AggregateFunction;
pub use operators::EdgeScan;
pub use operators::Filter;
pub use operators::HyperedgeScan;
pub use operators::Join;
pub use operators::JoinType;
pub use operators::Limit;
pub use operators::NodeScan;
pub use operators::Operator;
pub use operators::Project;
pub use operators::ScanMode;
pub use operators::Sort;
pub use parallel::ParallelConfig;
pub use parallel::ParallelExecutor;
pub use pipeline::ExecutionContext;
pub use pipeline::Pipeline;
pub use pipeline::RowBatch;
pub use plan::LogicalPlan;
pub use plan::PhysicalPlan;
pub use plan::PlanNode;
pub use stats::ColumnStats;
pub use stats::Histogram;
pub use stats::Statistics;
pub use stats::TableStats;

Modules§

cache
Query result caching for performance optimization
operators
Query operators for graph traversal and data processing
parallel
Parallel query execution using rayon
pipeline
Pipeline execution model with Volcano-style iterators
plan
Query execution plan representation
stats
Statistics collection for cost-based query optimization

Structs§

QueryExecutor
Query execution engine

Enums§

ExecutionError
Query execution error types

Type Aliases§

Result