Struct DataflowDebugger 

pub struct DataflowDebugger { /* private fields */ }

Dataflow debugger for DataFrame pipeline analysis

Implementations

impl DataflowDebugger

pub fn new(config: DataflowConfig) -> Self

Create a new dataflow debugger

pub fn start_session(&self) -> Result<()>

Start a new debugging session

pub fn add_breakpoint(&self, breakpoint: Breakpoint) -> Result<()>

Add a breakpoint to the debugger

pub fn remove_breakpoint(&self, stage_id: &str) -> Result<bool>

Remove a breakpoint by stage ID

pub fn execute_stage( &self, pipeline_stage: &mut PipelineStage, ) -> Result<StageExecutionResult>

Execute a pipeline stage with debugging support

pub fn materialize_stage(&self, stage_id: &str) -> Result<MaterializedFrame>

Materialize DataFrame data at a specific stage

pub fn compute_stage_diff( &self, stage1_id: &str, stage2_id: &str, ) -> Result<StageDiff>

Compute diff between two pipeline stages

pub fn get_session_status(&self) -> Result<SessionState>

Get current debugging session status

pub fn get_execution_history(&self) -> Result<Vec<ExecutionEvent>>

Get execution history

pub fn get_stage_metrics(&self) -> Result<HashMap<String, StageMetrics>>

Get performance metrics for all stages

pub fn export_debug_data( &self, format: ExportFormat, output_path: &str, ) -> Result<()>

Export debugging data to various formats

pub fn stop_session(&self) -> Result<()>

Stop the debugging session

pub fn add_stage(&self, stage: PipelineStage) -> Result<()>

Add a stage to the pipeline

pub fn set_breakpoint( &self, stage_id: String, condition: Option<BreakpointCondition>, ) -> Result<()>

Set a breakpoint at a specific stage