Struct ProcessingContext 

pub struct ProcessingContext<'a> { /* private fields */ }

Context for processing phase execution

Provides:

• Read access to acquisition results
• Write capabilities for processing step outputs
• Result accumulation for downstream phases

Implementations

impl<'a> ProcessingContext<'a>

pub fn new(acquisition_results: &'a ResultContext, output_dir: &'a Path) -> Self

Create a new processing context

pub fn output_dir(&self) -> &Path

Get the output directory

pub fn writer(&self, step_name: &str) -> Result<ResultWriter>

Create a result writer for a processing step

pub fn register_result( &mut self, step_name: impl Into<String>, handle: ResultHandle, )

Register a completed step’s result handle

pub fn results(&self) -> &ResultContext

Get the accumulated processing results

pub fn take_results(self) -> ResultContext

Take ownership of the accumulated processing results

Called at the end of the processing phase.

pub fn acquisition_results(&self) -> &ResultContext

Get the acquisition results context

pub fn get_rows(&self, step_name: &str) -> Result<Vec<JsonValue>>

Get all rows for an acquisition step (materializes data)

WARNING: This loads all rows into memory.

pub fn row_count(&self, step_name: &str) -> Result<usize>

Get row count for an acquisition step

pub fn has_results(&self, step_name: &str) -> bool

Check if acquisition step has results

pub fn is_step_empty(&self, step_name: &str) -> Result<bool>

Check if acquisition step is empty

pub fn first(&self, step_name: &str) -> Result<Option<JsonValue>>

Get first row for an acquisition step

pub fn column_values( &self, step_name: &str, column: &str, ) -> Result<Vec<String>>

Get column values for an acquisition step