Struct LogicEngine 

pub struct LogicEngine { /* private fields */ }

The logic engine manages Datalog rules and evaluates them against facts.

Implementations

impl LogicEngine

pub fn new(provenance_mode: ProvenanceMode) -> Result<Self>

Create a new logic engine with the specified provenance mode.

pub fn register_rule(&mut self, name: &str, datalog_source: &str) -> Result<()>

Register a named Datalog rule.

pub fn remove_rule(&mut self, name: &str) -> Result<()>

Remove a rule by name.

pub fn list_rules(&self) -> Vec<String>

List all registered rule names.

pub fn get_rule_body(&self, name: &str) -> Option<String>

Get the Datalog source body of a named rule.

pub fn add_facts( &mut self, relation: &str, batches: Vec<RecordBatch>, ) -> Result<()>

Add facts (ground tuples) for a relation.

pub fn evaluate(&self, rule_name: &str) -> Result<Vec<RecordBatch>>

Evaluate a specific rule and return derived tuples.

pub fn evaluate_all(&self) -> Result<Vec<RecordBatch>>

Evaluate all registered rules and return all derived tuples.

pub fn filter_batches( &self, batches: &[RecordBatch], ) -> Result<Vec<RecordBatch>>

Apply all registered rules as post-filters against the given batches.

For each rule, rows that violate the rule’s conditions are removed. Rules whose columns don’t match the batch schema are silently skipped (they apply to different tables).

This is the integration point for wiring Datalog constraints into DataFusion’s query pipeline.

Trait Implementations

impl Debug for LogicEngine

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

Formats the value using the given formatter.