Struct HybridPhysicalPlanner 

pub struct HybridPhysicalPlanner { /* private fields */ }

Hybrid physical planner that produces DataFusion ExecutionPlan trees.

Routes graph operations to custom ExecutionPlan implementations and relational operations to native DataFusion operators.

Example

let planner = HybridPhysicalPlanner::new(
    session_ctx,
    storage,
    l0,
    property_manager,
    schema,
    params,
);

let execution_plan = planner.plan(&logical_plan)?;

Implementations

impl HybridPhysicalPlanner

pub fn new( session_ctx: Arc<RwLock<SessionContext>>, storage: Arc<StorageManager>, l0: Arc<RwLock<L0Buffer>>, property_manager: Arc<PropertyManager>, schema: Arc<UniSchema>, params: HashMap<String, Value>, ) -> Self

Create a new hybrid physical planner.

Arguments

• session_ctx - DataFusion session context
• storage - Storage manager for dataset access
• l0 - Current L0 buffer for MVCC
• property_manager - Property manager for lazy loading
• schema - Uni schema for lookups

pub fn with_plugin_registry(self, plugin_registry: Arc<PluginRegistry>) -> Self

Replace the plugin registry used for Locy aggregate resolution.

The default registry contains only the built-in aggregates from uni-plugin-builtin. Hosts that have registered additional Locy aggregates should pass their full uni_plugin::PluginRegistry here so user-declared aggregates resolve at plan time.

pub fn with_l0_context( session_ctx: Arc<RwLock<SessionContext>>, storage: Arc<StorageManager>, l0_context: L0Context, property_manager: Arc<PropertyManager>, schema: Arc<UniSchema>, params: HashMap<String, Value>, outer_values: HashMap<String, Value>, ) -> Self

Create planner with full L0 context.

pub fn with_writer(self, writer: Arc<Writer>) -> Self

Attach the outer transaction’s writer handle so declared WRITE-mode procedures invoked through this plan can run their Cypher bodies via the write-enabled inner-query host (FU-1 / M11 #6).

pub fn set_outer_entity_vars(&mut self, vars: HashSet<String>)

Set the algorithm registry for uni.algo.* procedure dispatch.

Rebuilds the inner GraphExecutionContext with the registry attached. Set outer entity variable names for nested EXISTS correlated reference detection.

pub fn with_algo_registry(self, registry: Arc<AlgorithmRegistry>) -> Self

pub fn with_procedure_registry(self, registry: Arc<ProcedureRegistry>) -> Self

Set the external procedure registry for test/user-defined procedures.

Rebuilds the inner GraphExecutionContext with the registry attached.

pub fn with_xervo_runtime(self, runtime: Arc<ModelRuntime>) -> Self

Set Uni-Xervo runtime used by query-time vector auto-embedding.

pub fn with_mutation_context(self, ctx: Arc<MutationContext>) -> Self

Set the mutation context for write operations.

pub fn graph_ctx(&self) -> &Arc<GraphExecutionContext>

Return the graph execution context (for columnar subplan execution).

pub fn session_ctx(&self) -> &Arc<RwLock<SessionContext>>

Return the DataFusion session context (for columnar subplan execution).

pub fn storage(&self) -> &Arc<StorageManager>

Return the storage manager (for columnar subplan execution).

pub fn schema_info(&self) -> &Arc<UniSchema>

Return the schema (for columnar subplan execution).

pub fn plan(&self, logical: &LogicalPlan) -> Result<Arc<dyn ExecutionPlan>>

Plan a logical plan into an execution plan.

Arguments

• logical - The logical plan to convert

Returns

DataFusion ExecutionPlan ready for execution.

Errors

Returns an error if planning fails (unsupported operation, schema mismatch, etc.)

pub fn plan_with_properties( &self, logical: &LogicalPlan, extra_properties: HashMap<String, HashSet<String>>, ) -> Result<Arc<dyn ExecutionPlan>>

Plan a LogicalPlan with additional property requirements.

Merges extra_properties into the auto-collected properties from the plan tree. Used by MERGE execution to ensure structural projections are applied for variables that need full node/edge Maps in the output.

Trait Implementations

impl Debug for HybridPhysicalPlanner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.