Struct Planner 

pub struct Planner { /* private fields */ }

Converts a logical plan to a physical operator tree.

Implementations

impl Planner

pub fn new(store: Arc<LpgStore>) -> Self

Creates a new planner with the given store.

This creates a planner without transaction context, using the current epoch from the store for visibility.

pub fn with_context( store: Arc<LpgStore>, tx_manager: Arc<TransactionManager>, tx_id: Option<TxId>, viewing_epoch: EpochId, ) -> Self

Creates a new planner with transaction context for MVCC-aware planning.

Arguments

• store - The graph store
• tx_manager - Transaction manager for recording reads/writes
• tx_id - Current transaction ID (None for auto-commit)
• viewing_epoch - Epoch to use for version visibility

pub fn viewing_epoch(&self) -> EpochId

Returns the viewing epoch for this planner.

pub fn tx_id(&self) -> Option<TxId>

Returns the transaction ID for this planner, if any.

pub fn tx_manager(&self) -> Option<&Arc<TransactionManager>>

Returns a reference to the transaction manager, if available.

pub fn plan(&self, logical_plan: &LogicalPlan) -> Result<PhysicalPlan>

Plans a logical plan into a physical operator.

Errors

Returns an error if planning fails.

pub fn plan_adaptive(&self, logical_plan: &LogicalPlan) -> Result<PhysicalPlan>

Plans a logical plan with adaptive execution support.

Creates cardinality checkpoints at key points in the plan (scans, filters, joins) that can be monitored during execution to detect estimate errors.

Errors

Returns an error if planning fails.