Struct AnalysisRunner 

pub struct AnalysisRunner { /* private fields */ }

Orchestrates the execution of multiple analyzers on a dataset.

The AnalysisRunner optimizes execution by grouping compatible analyzers that can share computation, minimizing the number of DataFrame scans required.

Example

use term_guard::analyzers::{AnalysisRunner, basic::*};
use datafusion::prelude::*;

let ctx = SessionContext::new();
// Register your data table

let runner = AnalysisRunner::new()
    .add(SizeAnalyzer::new())
    .add(CompletenessAnalyzer::new("user_id"))
    .add(DistinctnessAnalyzer::new("user_id"))
    .on_progress(|progress| {
        println!("Analysis progress: {:.1}%", progress * 100.0);
    });

let context = runner.run(&ctx).await?;
println!("Computed {} metrics", context.all_metrics().len());

Implementations

impl AnalysisRunner

pub fn new() -> Self

Creates a new empty AnalysisRunner.

pub fn add<A>(self, analyzer: A) -> Self

where A: Analyzer + 'static, A::Metric: Into<MetricValue> + 'static,

Adds an analyzer to the runner.

Arguments

• analyzer - The analyzer to add

Type Parameters

• A - The analyzer type that implements the Analyzer trait

pub fn on_progress<F>(self, callback: F) -> Self

where F: Fn(f64) + Send + Sync + 'static,

Sets a progress callback that will be called during execution.

The callback receives a float between 0.0 and 1.0 indicating progress.

pub fn continue_on_error(self, continue_on_error: bool) -> Self

Sets whether to continue execution when individual analyzers fail.

Default is true (continue on error).

pub async fn run(&self, ctx: &SessionContext) -> AnalyzerResult<AnalyzerContext>

Executes all analyzers on the given data context.

This method optimizes execution by grouping compatible analyzers and executing them together when possible.

Arguments

• ctx - The DataFusion session context with registered data

Returns

An AnalyzerContext containing all computed metrics and any errors

pub fn analyzer_count(&self) -> usize

Returns the number of analyzers configured.

Trait Implementations

impl Default for AnalysisRunner

fn default() -> Self

Returns the “default value” for a type.