Struct PlanRunner 

pub struct PlanRunner { /* private fields */ }

Runs multiple OutputPlans in parallel, managing the number of threads used to run them.

Implementations

impl PlanRunner

pub fn new(plans: Vec<OutputPlan>, num_threads: usize) -> Self

Create a new PlanRunner with the given plans and number of threads. Progress reporting is disabled by default.

pub fn with_progress_tracker(self, tracker: Arc<dyn ProgressTracker>) -> Self

Attach a ProgressTracker.

The runner pre-registers each table’s output-unit total with the tracker before scheduling, calls ProgressTracker::increment after output units are written, and calls ProgressTracker::finish once on the success path. Implementations needing cleanup on the error or panic path should use Drop as a fallback.

pub async fn run(self) -> Result<(), Error>

Run all the plans in the runner.

Trait Implementations

impl Debug for PlanRunner

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

Formats the value using the given formatter.