Crate hirn_exec 

hirn-exec — DataFusion physical operators, scoring UDFs, and optimizer rules.

This crate provides the execution layer for hirn’s cognitive memory engine, built on top of Apache DataFusion. Every cognitive operation (activation, scoring, budgeting, causal reasoning) is expressed as a composable DataFusion physical operator over Arrow columnar batches.

Modules

• operators — Physical ExecutionPlan implementations (19 operators)
• udfs — Scalar UDF implementations (8 UDFs)
• rules — Physical optimizer rule implementations (5 rules)
• extensions — HirnSessionExt for runtime state injection

Re-exports

pub use extensions::ContextAssemblyRuntime;

pub use extensions::GraphActivationOutput;

pub use extensions::GraphCausalChainRow;

pub use extensions::GraphReadRuntime;

pub use extensions::GraphTraverseRow;

pub use extensions::HirnSessionExt;

pub use extensions::QueryReadRuntime;

pub use extensions::RegisteredContextAssemblyRuntime;

pub use extensions::RegisteredQueryReadRuntime;

pub use extensions::register_context_assembly_runtime;

pub use extensions::register_query_read_runtime;

pub use operators::ActivationMode;

pub use operators::CausalChainExec;

pub use operators::CausalQueryReadExec;

pub use operators::CausalReadKind;

pub use operators::ContextAssemblyExec;

pub use operators::ContextBudgetExec;

pub use operators::GlobalSearchExec;

pub use operators::GlobalSearchParams;

pub use operators::GraphActivationExec;

pub use operators::GraphTraverseExec;

pub use operators::HebbianBufferExec;

pub use operators::HybridSearchParams;

pub use operators::LanceHybridSearchExec;

pub use operators::PolicyQueryReadExec;

pub use operators::PolicyReadKind;

pub use operators::RaptorSearchExec;

pub use operators::RaptorSearchParams;

pub use operators::RecallMergeExec;

pub use operators::SearchComparisonOp;

pub use operators::SearchNumericField;

pub use operators::SearchNumericFilter;

pub use operators::SvoEventScanExec;

pub use operators::TargetedQueryReadExec;

pub use operators::TargetedReadKind;

pub use planner::HirnExtensionPlanner;

pub use planner::HirnQueryPlanner;

pub use rules::ActivationFusionRule;

pub use rules::TemporalIndexRule;

pub use rules::all_rules;

pub use udfs::CausalRelevanceUdf;

pub use udfs::CompositeScoreUdf;

pub use udfs::FadeMemDecayUdf;

pub use udfs::RpeScoreUdf;

pub use udfs::SourceReliabilityUdf;

pub use udfs::SurpriseScoreUdf;

pub use udfs::TemporalDecayUdf;

pub use udfs::TokenCountUdf;

pub use udfs::register_all_udfs;

Modules

extensions

Runtime state for DataFusion operators.

operators

Physical operators for the DataFusion execution engine.

planner

HirnExtensionPlanner — converts HirnPlanNode logical nodes into physical operators.

rules

Optimizer rules for the DataFusion execution engine.

udfs

Scalar UDF implementations for DataFusion.